Redis 6.0发布订阅性能为何提升？探究多线程IO对Pub/Sub吞吐量的影响
先说一个核心判断：Redis 6.0引入的多线程IO，其设计初衷是加速网络读写，而非改变其核心的消息分发模型。这对于依赖发布订阅（Pub/Sub）功能的场景，意味着什么？我们往下看。
Redis 6.0 的 pub/sub 还是单线程处理，多线程 IO 不加速消息分发
直接说结论：Redis 6.0 引入的多线程 IO（由 io-threads 配置控制）**不参与 PUBLISH 消息的路由与分发逻辑**，它只负责网络读写（read/write 系统调用层面）这些“体力活”。而 SUBSCRIBE 客户端的消息广播，这个最核心的环节，依然由主线程串行执行。
这意味着什么？意味着订阅者越多、频道越热，主线程在遍历客户端列表、序列化消息、写入 socket 上的开销就越大。吞吐量的瓶颈，依然牢牢地卡在主线程这里。
这里有个常见的误判现象：使用 redis-benchmark -r 10000 -n 100000 -P 50 -t publish 进行测试时，开启多线程后QPS（每秒查询率）确实会提升。但这背后的真相是，多线程分摊了连接建立、命令解析前的 socket 接收压力，而并非 pub/sub 的核心消息分发路径变快了。这就像给仓库增加了更多卸货的工人，但仓库内部分拣和派送还是只有一个人在忙。
io-threads 开启后反而可能降低 pub/sub 稳定性
事情可能更复杂一些。当启用 io-threads（比如设为4），主线程就需要与多个IO线程频繁同步客户端状态。举个例子，某个客户端突然断连，主线程必须通知所有IO线程去清理与其关联的socket资源。在Pub/Sub场景下，如果存在大量短连接或频繁的 UNSUBSCRIBE 操作，这种同步开销就会被急剧放大。
其外在表现通常是：
- 使用
latency doctor命令会报出client-unlink或client-link相关的延时毛刺。 - 查看
INFO clients信息，会发现connected_clients数值波动剧烈，但client_longest_output_list（客户端最长输出列表）却持续升高。 - 部分订阅者出现间歇性丢失消息的情况，这并非网络断开，而是主线程来不及将消息推送到客户端的输出缓冲区。
基于此，一个实操建议是：对于纯 Pub/Sub 架构的应用（例如实时日志分发、IoT设备广播），应考虑关闭 io-threads（将其设为1），并调大 client-output-buffer-limit pubsub 参数。 这样可以避免因缓冲区溢出而触发强制 UNSUBSCRIBE，从而提升稳定性。
真正影响 pub/sub 吞吐的三个配置项
比起纠结多线程，调整以下参数对Pub/Sub实际吞吐量的影响往往更为直接：
client-output-buffer-limit pubsub：默认值是8mb 2mb 60。在高吞吐场景下，这很容易触达硬限制导致客户端被强制断开。建议根据峰值消息体积 × 订阅者数量 × 秒级积压量来预估，宁大勿小。例如可以设置为32mb 8mb 60。hz：默认值为10，它控制主线程每秒执行多少次常规任务（包括清理pubsub客户端缓冲区）。将其适当调高，比如设为100，可以加快积压缓冲区的刷出速度，但代价是会增加CPU占用。tcp-keepalive：将其设为300（秒）可以更快地感知到异常的客户端断开连接，从而减少无效客户端占用输出缓冲区资源。
需要注意的是，hz 值超过100后，边际收益会变得极低，并且可能干扰 EXPIRE 等功能的精度。线上环境建议在50–80的区间内进行实测，以找到最佳平衡点。
横向对比：为什么 Kafka / NATS 在高扇出场景更稳
要理解Redis Pub/Sub的局限性，需要看清它的本质：它是一种内存广播。每一个 PUBLISH 命令，都需要将消息体复制N份到N个客户端的输出缓冲区。相比之下，Kafka采用的是存储转发模式，而NATS则使用了共享内存加事件驱动分发。
这种架构差异带来的影响是直观的：
- 向1000个订阅者发送一条1KB的消息，Redis主线程至少需要执行1000次 × 1KB的内存拷贝，外加调度1000次的socket写入。
- 在同样的场景下，NATS的主线程可能只做一次消息序列化，然后通过内存引用进行分发，效率更高。
- 此外，Redis Pub/Sub不提供消息确认、重试或持久化保证。一旦客户端缓冲区溢出，消息就会被静默丢弃。
所以，如果业务需要可靠投递、高扇出（订阅者超过500）、或者消费者处理速度不均，那么硬扛Redis Pub/Sub可能并非明智之举——它本就不是为这些复杂场景设计的。在这种情况下，盲目调优 io-threads 参数，往往只是在掩盖更深层的架构问题。
