pubsub numsub 命令可实时获取指定频道的活跃订阅者数量,返回整数(无人订阅时为0),支持多频道批量查询,但不区分subscribe/psubscribe,且在redis cluster中需直连对应节点执行。

用 PUBSUB NUMSUB 命令查指定频道订阅数
Redis 不提供“列出所有订阅者连接 ID”这类细粒度信息,但能准确返回某个频道当前有多少个活跃订阅者——前提是这些订阅者仍处于连接且未断开。核心命令就是 PUBSUB NUMSUB,它不依赖客户端状态缓存,而是实时扫描 pubsub 内部注册表。
-
PUBSUB NUMSUB返回的是整数,不是布尔值或空值;如果频道没人订阅,结果就是0 - 支持一次查多个频道:
PUBSUB NUMSUB ch1 ch2 ch3,返回结果按输入顺序一一对应 - 注意:该命令**不区分普通订阅(
SUBSCRIBE)和模式订阅(PSUBSCRIBE)**,只统计所有绑定到该频道名的订阅者 - 在 Redis Cluster 模式下,必须连到目标 key 所在的节点执行,否则返回
0(因为 pubsub 是单节点本地状态)
Python 中调用 pubsub_numsub() 的正确姿势
用 redis-py 时别直接调 r.execute_command('PUBSUB NUMSUB', channel),虽然可行,但易出错——比如传参类型不对导致返回空列表,或忽略返回结构是 [(b'channel', 3)] 这样的二元组列表。
- 推荐用封装好的方法:
r.pubsub_numsub(channel),它自动解析并返回{b'channel': 3}字典 - 如果你查的是字符串频道名(如
'news.sports'),而 Redis 返回的是 bytes,记得统一编码:r.pubsub_numsub(b'news.sports')或用decode_responses=True初始化 client - 别在 pubsub 实例上调这个方法——
pubsub.numsub()不存在,那是常见误写 - 示例:
r = redis.Redis(decode_responses=True)<br>count = r.pubsub_numsub('alarm.high')[0][1] # 注意索引取值
为什么 PUBSUB CHANNELS 不能代替查人数
PUBSUB CHANNELS 只告诉你“哪些频道 currently 有至少一个订阅者”,但它**完全不返回数字**。你看到 ['chat.room1', 'notify.urgent'],却不知道每个频道到底有 1 个还是 50 个订阅者。
- 它的用途是运维巡检:“有没有人还在监听旧频道?”而不是容量评估
- 它不接受通配符,
PUBSUB CHANNELS 'notify.*'会报错,得用PUBSUB NUMPAT查模式订阅总数(但依然不拆分到具体 pattern) - 如果频道刚被创建、还没人订阅,
PUBSUB CHANNELS就不会列出它;而NUMSUB明确返回0,这对监控告警更友好
容易被忽略的“掉线即清零”特性
Redis 的 pubsub 是纯内存、无持久化的轻量机制,只要订阅者断开连接(网络闪断、进程崩溃、没发 UNSUBSCRIBE 就关连接),它立刻从计数中剔除——没有重连补偿,也没有离线消息队列。
- 这意味着:查到
NUMSUB是5,不代表系统稳定;下一秒可能就变成0,尤其在容器化或 Serverless 环境下 - 别拿这个数做业务逻辑判断(比如“等凑够 3 个订阅者再发配置”),它不可靠;适合场景仅限于:监控水位、自动扩缩容触发阈值、调试时确认订阅是否生效
- 若需可靠投递和连接状态追踪,应切换到
Stream+ 消费组(XGROUP),那是另一套设计
查订阅数这事本身很简单,难的是理解它背后那个“瞬时快照”的本质——它反映的不是业务意图,只是此刻内核里还挂着几个 socket。










