如何在Reactive Redis通用读取API中正确返回Mono响应值？

你的代码核心问题是违背了响应式编程的异步非阻塞设计：调用subscribe()后方法立刻返回null，此时Redis的异步操作还没完成，自然拿不到有效结果。最优实现需要遵循响应式范式，直接传递数据流而非强行阻塞获取结果。

推荐的非阻塞实现 #

把方法返回值改为Mono类型（用泛型可实现通用API），通过map操作符完成字符串到目标对象的转换，无需手动订阅：

// 泛型版本更通用，支持任意目标类型
public <T> Mono<T> getObject(final String key, final String field, Class<T> targetType) {      
    return reactiveRedisCommands.hget(key, field)
            // 在这里完成String到目标对象的转换逻辑
            .map(value -> {
                if (value == null) {
                    return null;
                }
                // 替换为你的实际类型转换代码：比如JSON反序列化、自定义类型转换等
                return objectMapper.readValue(value, targetType);
            })
            // 可选：处理Redis操作或转换过程中的异常
            .onErrorResume(ex -> {
                log.error("Redis读取或类型转换失败", ex);
                return Mono.empty();
            });
}

如果不需要泛型，保持返回Mono<Object>：

public Mono<Object> getObject(final String key, final String field) {      
    return reactiveRedisCommands.hget(key, field)
            .map(value -> {
                // 执行你的类型转换和额外处理逻辑
                // 示例：return convertStringToCustomObject(value);
                return null; // 替换为实际转换结果
            });
}

这种实现的优势：

• 完全符合响应式非阻塞原则，不会阻塞当前线程
• 调用方可灵活处理结果：比如subscribe()消费数据、flatMap()串联异步操作，或在非响应式环境下用block()（不推荐但兼容）

不推荐的阻塞实现（仅用于兼容传统代码） #

如果必须同步获取结果（违背响应式设计初衷，仅过渡场景使用），可使用block()方法阻塞线程等待结果：

public Object getObject(final String key, final String field) {      
    try {
        String value = reactiveRedisCommands.hget(key, field).block();
        if (value == null) {
            return null;
        }
        // 执行类型转换和额外处理逻辑
        return convertStringToObject(value);
    } catch (Exception ex) {
        log.error("Redis读取失败", ex);
        return null;
    }
}

关键注意事项 #

• 绝对不要在响应式方法内部调用subscribe()后返回结果，这会导致异步操作与方法返回完全脱节，无法拿到正确结果
• 响应式编程的核心是传递数据流，方法应返回Mono/Flux，由上游调用方处理订阅和结果消费

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