直接用LettuceClientResources创建的StatefulRedisPubSubConnection无法响应式订阅，因其默认为阻塞式事件驱动，subscribe()返回void且不产生Mono/Flux；响应式订阅必须通过ReactiveRedisConnectionFactory获取ReactiveRedisConnection，再调用subscribe()获得Flux流。
为什么直接用 LettuceClientResources 创建的 StatefulRedisPubSubConnection 无法响应式订阅？
因为 Lettuce 原生 API 中，StatefulRedisPubSubConnection 默认是阻塞式事件驱动（基于 Netty 的 ChannelHandler），它把消息回调交给 RedisPubSubAdapter 或自定义监听器处理，但这些回调本身不返回 Mono/Flux。你不能对 connection.subscribe("channel") 的返回值做 .flatMap(...) —— 它返回的是 void。
真正的响应式订阅必须走 Lettuce 的 ReactiveRedisConnection，它底层封装了 StatefulRedisPubSubConnection 并桥接为 Flux 流。别试图在原生连接上“手动转响应式”，那会绕过 Lettuce 的事件分发机制，导致消息丢失或线程错乱。
如何用 ReactiveRedisConnectionFactory 获取响应式 Pub/Sub 连接？
必须通过 Spring Data Redis 提供的 ReactiveRedisConnectionFactory（即使你不用 Spring 容器，也能手动构造），而不是直接 new RedisClient。Lettuce 自身不提供独立的响应式 Pub/Sub 连接类；ReactiveRedisConnection 是 Spring 对其的适配封装。
-
ReactiveRedisConnectionFactory的实现类是LettuceConnectionFactory，它内部持有RedisClient和ClientResources - 调用
factory.getConnection()得到ReactiveRedisConnection，再调用subscribe(…)才返回Flux<redismessage></redismessage> - 注意：该
Flux是热流（hot stream），一旦有订阅者就立即开始接收消息；没有订阅者时消息会被丢弃（默认行为）
Flux<redismessage></redismessage> 消费时要注意哪些线程与生命周期问题？
这个 Flux 由 Lettuce 的 Netty EventLoop 驱动，所有 onNext 回调都在 Netty 线程中执行。如果你在其中做耗时操作（比如写数据库、HTTP 调用），会阻塞整个连接的事件循环，导致后续消息积压甚至断连。
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
立即学习“Java免费学习笔记（深入）”；
- 务必用
.publishOn(Schedulers.boundedElastic())或.subscribeOn(Schedulers.boundedElastic())切换线程（不要用parallel()，它不适合 I/O 密集型） - 必须显式调用
connection.close()或让Flux取消订阅（如Disposable.dispose()），否则连接不会释放，RedisClient会持续占用资源 - 如果用
Flux.take(1)订阅后没取消，连接仍保持活跃；建议配合doFinally清理
示例片段：
Flux<RedisMessage> messages = connection.subscribe(Mono.just("my-channel"));
messages
.publishOn(Schedulers.boundedElastic())
.map(msg -> {
String channel = ((ChannelTopic) msg.getChannel()).getTopic();
String body = ((ByteArrayRedisMessage) msg.getMessage()).toString();
return String.format("[%s] %s", channel, body);
})
.doOnNext(System.out::println)
.doFinally(signal -> connection.close())
.subscribe();
为什么订阅后收不到消息？常见配置和权限陷阱
不是代码问题，大概率是服务端或客户端配置未对齐：
- Redis 服务器需开启
notify-keyspace-events（若监听 keyspace 事件），普通 channel 订阅无需此配置 - Lettuce 默认禁用
autoReconnect，网络抖动后订阅关系不会自动恢复 —— 必须手动重连并重新subscribe - 某些 Redis 代理（如 Twemproxy、Redis Cluster Proxy）不支持 Pub/Sub，会静默丢弃
SUBSCRIBE命令；务必直连 Redis 节点或确认代理兼容性 - Spring Boot 2.7+ 默认启用
lettuce.client-options.auto-reconnect=true，但老版本需显式配置：ClientOptions.builder().autoReconnect(true).build()
最易被忽略的一点：Lettuce 的 ReactiveRedisConnection 在首次 subscribe() 时才真正建立底层 StatefulRedisPubSubConnection。如果之前已存在普通连接（如用 RedisTemplate），它们共用一个 RedisClient，但 Pub/Sub 连接是独占的 —— 别指望复用非 Pub/Sub 连接来收消息。
