ReactiveRedisOperations循环保存Redis对象无效问题咨询

问题核心：响应式流的冷流特性 #

你遇到的问题本质是响应式流的冷流机制：Mono/Flux是"惰性"的，只有当被**订阅（subscribe）**时，才会触发背后的实际逻辑执行。你在for循环里只是创建了put操作对应的Mono对象，但没有触发订阅，所以Redis的写入逻辑根本没被执行。

修复代码：用响应式方式批量处理并触发订阅 #

不要用普通for循环处理响应式操作，建议将集合转为Flux，统一处理并触发订阅：

// 将List转为Flux，批量处理每个对象
Flux.fromIterable(list)
    .flatMap(obj -> reactiveRedisOperations.opsForHash().put(key, hashKey, obj))
    .subscribe(); // 触发所有Redis写入操作执行

如果需要等待所有写入完成再继续后续逻辑（比如阻塞场景），可以用blockLast()替代subscribe()：

Flux.fromIterable(list)
    .flatMap(obj -> reactiveRedisOperations.opsForHash().put(key, hashKey, obj))
    .blockLast(); // 阻塞等待所有操作完成

REST场景能生效的原因 #

在Spring WebFlux的REST服务中，当你返回Mono/Flux时，Spring Web框架会自动帮你订阅这个响应式流：

1. 框架订阅后触发Redis写入逻辑
2. 操作完成后，将结果（或响应状态）返回给客户端
   所以你不需要手动调用subscribe()，框架已经完成了订阅触发的步骤。

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