当前位置：首页 > 问答 > 正文

怎么查Redis里到底有多少订阅者，想知道有没有人在订阅消息

盘雅霜
问答
2026-01-04 17:52:51
14

要弄清楚Redis里有多少订阅者，以及是否真的有人在监听消息，我们需要分几种情况来看，因为Redis的“订阅”这个概念，在不同的使用场景下，含义和查询方法是不一样的，你不能像查一个普通键值对那样，用一个简单的 GET 命令来得到订阅者的数量，核心在于，Redis的发布订阅模式是一种动态的、临时的连接关系。

第一种情况：使用PUB/SUB（发布/订阅）模式

这是最经典的消息订阅场景，假设你的应用程序使用 SUBSCRIBE 命令订阅了像 news 或 stock_price 这样的频道。

核心特点：这种订阅关系是绑定在客户端连接上的，只要订阅了的客户端不断开连接，它就一直是订阅者，一旦客户端断开（比如网络问题、程序重启），它的订阅关系就立刻消失了,Redis服务器端不会持久化这些信息。
如何查询：
1. 使用 PUBSUB 命令族：这是Redis专门为查询发布订阅系统状态提供的工具，有两个子命令最有用：
  - 查看特定频道的订阅者数量：使用 PUBSUB NUMSUB <channel_name> 命令，你想知道有多少个客户端订阅了 news 这个频道，就在Redis命令行里输入 PUBSUB NUMSUB news，命令会返回一个结果，第一行是频道名，第二行就是当前连接着的订阅者数量，如果返回0,就表示此刻没有任何活跃的客户端在监听这个频道。
  - 查看当前活跃的频道模式：使用 PUBSUB CHANNELS [pattern] 命令，如果不加任何模式，PUBSUB CHANNELS 会列出当前至少有一个订阅者的所有频道名字，这能让你快速了解现在有哪些频道是“活跃”的，你也可以用它来匹配，PUBSUB CHANNELS news.* 来查找所有以 news. 开头的频道。
2. 使用 CLIENT LIST 命令：这个命令会列出所有连接到Redis服务器的客户端详细信息列表，虽然看起来有点复杂，但你可以通过管道和文本查找工具（如grep）来筛选出订阅者，在Linux终端中，你可以输入 redis-cli CLIENT LIST | grep pubsub，因为一个处于订阅模式的客户端，其标志（flags）里会包含 pubsub 字样，通过计算有多少行结果，你就能知道当前总共有多少个客户端处于订阅状态,但这不能告诉你每个频道具体的订阅数。
重要提醒：通过 PUBSUB 命令查到的都是实时快照，你查询的那一刻有3个订阅者，可能一毫秒后就变成2个了，如果你发现某个频道的订阅数偶尔为0,很可能是因为客户端正常重连或发生了短暂的网络波动。

第二种情况：使用Streams（流）类型

Redis Streams是一种更现代、更强大的消息队列实现，它和PUB/SUB的主要区别在于，消息会被持久化,并且消费者组可以管理消费进度。

怎么查Redis里到底有多少订阅者，想知道有没有人在订阅消息

核心特点：订阅者（在这里更准确地叫“消费者”）是归属于一个“消费者组”的，Stream会记录每个消费者组，以及组内每个消费者的消息读取进度，这种订阅关系是会被Redis记录下来的，即使消费者离线再上线,它也能从上次断开的地方继续读取。
如何查询：
1. 查看流的消费者组：使用 XINFO GROUPS <stream_key> 命令，比如你的流叫 mystream，就输入 XINFO GROUPS mystream，这个命令会列出这个流创建的所有消费者组的信息，包括组名、当前待处理消息数量、最后递送的消息ID等。
2. 查看特定消费者组内的消费者：使用 XINFO CONSUMERS <stream_key> <group_name> 命令，在知道了组名（mygroup）之后，输入 XINFO CONSUMERS mystream mygroup，这个命令会列出这个组内所有当前在线的消费者，每个消费者都有一个“空闲时间”（idle time，单位毫秒）的字段，如果这个空闲时间非常大（比如好几天），说明这个消费者可能已经下线了，或者出了故障,但它依然被记录在案。
如何判断“有没有人”：对于Streams来说，“有没有人在订阅”这个问题变得复杂一些。
- XINFO CONSUMERS 返回的列表是空的，表示这个组内当前没有任何活跃的消费者。
- 即使列表里有消费者，但如果它们的“空闲时间”都很长，也意味着很长一段时间内没有人在实际处理消息。
- 你可以结合 XINFO GROUPS 结果中的“待处理消息数”（pending）来看，如果这个数字持续增长，而消费者又不活跃，那就说明消息积压了，订阅者可能“名存实亡”。

第三种情况：键空间通知（Key-space Notifications）

这其实是一种特殊的PUB/SUB应用，你可以让Redis在某个键被删除、过期、修改时，自动向一个特定的频道发布通知,然后你的程序去订阅那个频道。

如何查询：查询方法和第一种经典的PUB/SUB完全一样，因为本质上它也是创建了一些频道（__keyspace@0__:mykey），你需要用 PUBSUB NUMSUB 命令去查询这些系统频道的订阅者数量。

总结与建议

明确你的技术方案：你得清楚你的应用程序用的是哪种方式来做“订阅”，是简单的 SUBSCRIBE 命令，还是基于Streams的消费者组？这决定了你该用什么命令。
实时查询用PUBSUB：如果你用的是经典发布订阅或键空间通知，想秒级知道当前活跃订阅数，PUBSUB NUMSUB <频道名> 是你的首选。
持久化订阅看Streams：如果你用的是Streams，XINFO GROUPS 和 XINFO CONSUMERS 是你需要关注的命令，它们能告诉你更丰富的状态信息,包括历史订阅者和它们的处理进度。
监控与告警：有没有人订阅”这个问题对你来说非常重要（消息系统不能中断），你就不应该只靠手动登录Redis去查询，最好的办法是写一个监控脚本，定期执行上述相应的命令（例如每分钟执行一次 PUBSUB NUMSUB critical_channel），如果发现订阅数变为0，就自动发送告警通知给运维或开发人员,这样能确保问题被及时发现。