异步上下文调用subscribe是否合规？Redis加密密钥 fallback 实现咨询

你的代码核心问题是在Mono.create内部手动调用了subscribe()，这违背了响应式编程的原则：手动订阅会让这个Redis操作脱离当前的响应式流上下文，无法正确处理背压、线程调度，还可能引发竞态条件（多个并发请求同时触发密钥生成，导致重复写入）。

修正后的基础实现 #

直接用响应式操作的链式调用替代手动订阅，让流自行管理订阅生命周期：

public Mono<String> getEncryptionKey(String entity) {
    String privateKeyKey = "private";
    String publicKeyKey = "public";

    return reactiveRedisOperations.opsForValue()
            .get(privateKeyKey)
            .switchIfEmpty(
                // 生成密钥对
                Mono.fromCallable(() -> {
                    // 替换为你的实际密钥生成逻辑
                    String privateKeyEncoded = generatePrivateKey();
                    String publicKeyEncoded = generatePublicKey();
                    return Map.of(privateKeyKey, privateKeyEncoded, publicKeyKey, publicKeyEncoded);
                })
                // 保存到Redis并返回私钥
                .flatMap(keyMap -> reactiveRedisOperations.opsForValue()
                        .multiSet(keyMap)
                        .thenReturn(keyMap.get(privateKeyKey))
                )
            );
}

// 示例密钥生成方法，替换成你的实际逻辑
private String generatePrivateKey() {
    // ... 生成私钥并编码的逻辑
}

private String generatePublicKey() {
    // ... 生成公钥并编码的逻辑
}

解决竞态条件（关键优化） #

上面的基础实现仍存在并发风险：如果多个请求同时进入switchIfEmpty，都会生成密钥对并执行multiSet，导致重复生成和覆盖。需要用Redis的原子操作保证检查-生成-写入的原子性，推荐使用Lua脚本：

public Mono<String> getEncryptionKey(String entity) {
    String privateKeyKey = "private";
    String publicKeyKey = "public";

    // Lua脚本：原子执行「检查私钥是否存在→不存在则写入密钥对→返回私钥」逻辑
    String script = """
            if redis.call('EXISTS', KEYS[1]) == 0 then
                redis.call('SET', KEYS[1], ARGV[1])
                redis.call('SET', KEYS[2], ARGV[2])
                return ARGV[1]
            else
                return redis.call('GET', KEYS[1])
            end
            """;

    return reactiveRedisOperations.execute(RedisScript.of(script, String.class),
                    List.of(privateKeyKey, publicKeyKey),
                    generatePrivateKey(), generatePublicKey())
            // 兜底处理极端异常情况
            .switchIfEmpty(Mono.error(new IllegalStateException("Failed to retrieve or generate encryption key")));
}

Lua脚本会在Redis服务器端原子执行整个逻辑，确保只有第一个触发的请求会生成并写入密钥，后续请求直接读取已存在的密钥，彻底避免竞态问题。

原代码subscribe()的问题本质 #

• 手动订阅会创建独立的流，无法和外部Mono<String>共享上下文（比如线程池、超时、错误处理）。
• 无法正确处理背压，可能引发资源泄漏。
• 并发场景下会重复执行密钥生成和写入，浪费资源且可能导致数据不一致。

内容的提问来源于stack exchange，提问作者VladRia