WebFlux中实现响应式Redis操作方法

在WebFlux响应式编程中，正确集成Redis需摒弃阻塞式Jedis，转而采用原生支持Netty与响应式API的LettuceConnectionFactory，并严格配合ReactiveRedisTemplate使用；关键在于精准配置StringRedisSerializer等序列化器以避免键匹配失败，杜绝阻塞调用（如误用RedisTemplate的同步方法），慎用execute等“伪响应式”后门，优先通过ReactiveRedisConnection调用eval、pipelined等原生命令，同时妥善处理事务反序列化、发布订阅的背压管理及连接生命周期——稍有疏忽便会破坏非阻塞语义、引发内存泄漏或性能雪崩。

用 LettuceConnectionFactory 替代 JedisConnectionFactory

WebFlux 是响应式栈，Jedis 是阻塞式客户端，直接套用会拖垮整个事件循环。Lettuce 原生支持 Netty 和响应式 API，是唯一合理选择。

常见错误：在 RedisTemplate 上调用 opsForValue().get("key") —— 这返回的是 String，不是 Mono，本质还是阻塞调用。

• 必须用 ReactiveRedisTemplate，它底层绑定的是 LettuceConnectionFactory
• Spring Boot 2.0+ 默认自动配置 LettuceConnectionFactory，但需确认未被 @Primary 的 Jedis Bean 覆盖
• 若手动配置，删掉所有 JedisConnectionFactory 相关 Bean，显式声明 LettuceConnectionFactory

ReactiveRedisTemplate 的 key/value 序列化要设对

默认序列化器对字符串 key 不友好：比如你存 "user:100"，它可能被转成字节数组再 Base64 编码，查的时候根本匹配不上。

典型现象：reactiveRedisTemplate.opsForValue().get("user:100") 返回 Mono.empty()，但用 redis-cli 明明能 GET user:100 出来。

• key 必须用 StringRedisSerializer（不能用 GenericJackson2JsonRedisSerializer）
• value 可按需选：简单类型用 StringRedisSerializer；对象用 GenericJackson2JsonRedisSerializer，但需确保类有无参构造、字段 public 或有 getter
• 别漏掉设置 setKeySerializer 和 setValueSerializer，仅设 setDefaultSerializer 不生效

慎用 ReactiveRedisOperations 的 execute 方法

想执行 EVAL 或管道命令时，容易直接传 RedisCallback —— 这是响应式 API 里的“阻塞后门”，会在线程池里跑，破坏背压和非阻塞语义。

正确路径是走 ReactiveRedisConnection 的原生命令方法，比如 eval、pipelined、scan。

• reactiveRedisTemplate.getConnectionFactory().getReactiveConnection() 拿连接
• connection.eval(...) 返回 Mono，不是 Object
• 管道操作要用 connection.pipelined().map(...).flatMap(...) 链式组合，不能攒一堆命令再 exec
• Lua 脚本里避免耗时计算，Redis 是单线程，脚本卡住等于整个实例卡住

事务和发布订阅在响应式里不是“自动变响应式”

multi() + exec() 看似能用，但 exec() 返回的是 Mono>，里面每个元素仍是原始响应类型（比如 byte[]），没帮你反序列化。

发布订阅更麻烦：传统 MessageListener 是回调式，而 ReactiveRedisMessageListenerContainer 返回的是 Flux，但必须手动管理订阅生命周期，否则内存泄漏。

• 事务中所有命令的参数、返回值都要自己做序列化/反序列化，ReactiveRedisTemplate 不介入
• 订阅场景优先考虑用 reactiveRedisTemplate.listenToChannel("ch1")，它返回 Flux，比手动管容器更轻量
• 记得在 Flux 订阅时加 onBackpressureBuffer() 或 onBackpressureDrop()，不然消息积压会崩掉下游

最常被忽略的一点：Lettuce 的 ReactiveRedisConnection 不是线程安全的“工具类”，它是有状态的连接抽象，背后共享 Netty Channel。别把它当普通工具反复 new 或跨 Mono 共享实例——该用 ConnectionFactory 拿新连接就拿新连接。

本篇关于《WebFlux中实现响应式Redis操作方法》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于数据库的相关知识，请关注golang学习网公众号！