用 hiredis 同步 API 调用 SUBSCRIBE 会阻塞线程,因其进入只收不发的监听状态,redisCommand 长期等待永不返回的 OK;正确做法是启用独立线程循环调用 redisGetReply 轮询,或改用异步 API。

直接说结论:用 hiredis 的同步 API 做 SUBSCRIBE 会阻塞线程,必须配合独立线程 + redisGetReply 轮询,或改用异步 API(redisAsyncConnect);否则一订阅就卡死,根本没法收消息。
为什么不能直接用 SUBSCRIBE 同步发命令
很多人照着 Redis CLI 示例写 C++ 代码,一上来就调 redisCommand(sub_ctx, "SUBSCRIBE %s", channel),结果程序停在那儿不动了——因为 SUBSCRIBE 是“进入订阅模式”的开关命令,执行后连接就切换成只收不发的监听状态,redisCommand 会一直等 reply,但 Redis 根本不会返回 OK,它只往里推 message、subscribe 这类事件。
常见错误现象:
- 主线程卡死,CPU 占用低,日志停在 “subscribed” 就再无输出
- 后续
PUBLISH调用成功,但订阅端完全收不到 - 误以为是网络或 Redis 配置问题,反复检查
bind、protected-mode
正确做法是:
- 用一个专用
redisContext*仅用于订阅,且不混用其他命令 - 启动独立线程,在该线程里循环调用
redisGetReply(sub_ctx, &reply) - 收到 reply 后手动判断
reply->type:是REDIS_REPLY_ARRAY且首元素为"message"才是业务消息 - 别忘了
freeReplyObject(reply),否则内存泄漏
PSUBSCRIBE 通配符订阅要注意匹配规则
想让一个消费者监听 device:1001:status、device:1002:status 等动态频道,得用 PSUBSCRIBE device:*:status,但注意:* 只能出现在 pattern 开头或结尾,不能中间夹杂,比如 device:*:alarm 合法,dev*:alarm 不合法,Redis 会直接报错 NOAUTH(实际是语法错误,但错误码误导性很强)。
使用场景:
- 物联网设备按 ID 分频道时,避免为每个设备单独建连接
- 微服务间约定前缀(如
order.*、user.*),降低配置耦合
参数差异:
-
SUBSCRIBE返回的 reply 结构是["message", "channel", "payload"] -
PSUBSCRIBE返回的是["pmessage", "pattern", "channel", "payload"],多一层 pattern 字段,必须多取一个reply->element[1] - 同一个连接不能混用
SUBSCRIBE和PSUBSCRIBE,否则后续命令全失败
连接断开后自动重连 + 订阅恢复很麻烦
Redis Pub/Sub 没有内置重连机制。网络抖动、Redis 重启、client-output-buffer-limit 触发断连,都会导致订阅丢失,且不会通知客户端——你还在 happily redisGetReply,其实 socket 已经 EOF,redisGetReply 返回 NULL,但很多人没判空,直接 dereference 导致 crash。
实操建议:
- 每次
redisGetReply前先检查sub_ctx->err,等于非零就说明连接异常 - 检测到断连后,不要直接
redisFree+redisConnect,要先redisFree再重建新 context,并重新PSUBSCRIBE - 重连间隔加 jitter(比如 1–3 秒随机),避免所有客户端同一时刻涌上去打崩 Redis
- 如果业务不能丢消息,Pub/Sub 本身就不适合——该换
Redis Streams或 Kafka
集群模式下 SUBSCRIBE 会失败
Redis Cluster 把 key 映射到不同分片,但 Pub/Sub 是全局广播行为,所有节点都会收消息。官方明确不支持在集群模式下使用 SUBSCRIBE,客户端执行会直接报错 MOVED 或 ASK,即使你连的是正确的 master 节点。
解决方案只有两个:
- 退回到单节点或主从模式部署 Redis,专用于 Pub/Sub 流量
- 切到
Redis Streams(支持 consumer group + 持久化 + ACK),但要用XADD/XREADGROUP,API 完全不同,不是简单替换
容易被忽略的一点:很多公司用哨兵(Sentinel)做高可用,这没问题;但一旦启用了 Cluster 模式,哪怕只开一个分片,SUBSCRIBE 就彻底不可用——这个限制不会在文档首页标红,得翻到 Cluster FAQ 底部才看到。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











