应使用LettuceConnectionFactory替代JedisConnectionFactory,因其原生支持Netty和响应式API;必须配合ReactiveRedisTemplate,并正确配置StringRedisSerializer等序列化器,避免阻塞调用与序列化不匹配问题。

用 LettuceConnectionFactory 替代 JedisConnectionFactory
WebFlux 是响应式栈,Jedis 是阻塞式客户端,直接套用会拖垮整个事件循环。Lettuce 原生支持 Netty 和响应式 API,是唯一合理选择。
常见错误:在 RedisTemplate 上调用 opsForValue().get("key") —— 这返回的是 String,不是 Mono<string></string>,本质还是阻塞调用。
- 必须用
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<list>></list>,里面每个元素仍是原始响应类型(比如 byte[]),没帮你反序列化。
发布订阅更麻烦:传统 MessageListener 是回调式,而 ReactiveRedisMessageListenerContainer 返回的是 Flux,但必须手动管理订阅生命周期,否则内存泄漏。
- 事务中所有命令的参数、返回值都要自己做序列化/反序列化,
ReactiveRedisTemplate不介入 - 订阅场景优先考虑用
reactiveRedisTemplate.listenToChannel("ch1"),它返回Flux<bytebuffer></bytebuffer>,比手动管容器更轻量 - 记得在
Flux订阅时加onBackpressureBuffer()或onBackpressureDrop(),不然消息积压会崩掉下游
最常被忽略的一点:Lettuce 的 ReactiveRedisConnection 不是线程安全的“工具类”,它是有状态的连接抽象,背后共享 Netty Channel。别把它当普通工具反复 new 或跨 Mono 共享实例——该用 ConnectionFactory 拿新连接就拿新连接。










