Redis的订阅发布功能介绍

Redis 发布订阅 Pub/Sub 概览

Redis 的发布订阅（Pub/Sub）是一种面向消息的通信机制：发送者将消息发布到某个频道（Channel），所有订阅该频道的客户端会即时收到消息；客户端也可以按模式（Pattern，支持 glob 风格通配符）订阅一类频道。该机制用于解耦消息生产者和消费者，适合实时广播、事件通知等场景。需要注意的是，Redis 的 Pub/Sub 为实时推送模型，消息不落盘、不持久化，离线期间消息会丢失，且没有ACK/重试等可靠性保障。

核心概念与消息类型

• 发布者 Publisher：调用 PUBLISH 向指定频道发送消息。
• 订阅者 Subscriber：调用 SUBSCRIBE/PSUBSCRIBE 订阅频道或模式，收到消息类型为“message”。
• 频道 Channel：消息的逻辑通道，名称自定义，如“news.sports”。
• 模式 Pattern：按通配符订阅，如“news.*”“it?”。
• 订阅者在订阅状态下主要会收到三类消息：
  • subscribe：订阅成功反馈（包含频道名、当前订阅数）。
  • message：收到的实际消息（包含频道名、消息体）。
  • unsubscribe：退订反馈（当未传参时表示退订全部）。

常用命令与快速示例

• 常用命令
  • PUBLISH channel message：向频道发布消息，返回接收到消息的订阅者数量。
  • SUBSCRIBE channel [channel …]：订阅一个或多个频道。
  • UNSUBSCRIBE [channel …]：退订指定频道；无参表示退订全部。
  • PSUBSCRIBE pattern [pattern …]：按模式订阅。
  • PUNSUBSCRIBE [pattern …]：按模式退订；无参表示退订全部。
  • PUBSUB subcommand [argument …]：查看订阅/发布系统状态（如列出频道、模式、订阅数等）。
• 快速示例（redis-cli）
  • 终端 1（订阅）：
    • SUBSCRIBE channel:1
    • 输出示例：1) “subscribe” 2) “channel:1” 3) (integer) 1
  • 终端 2（发布）：
    • PUBLISH channel:1 “hi” → 返回 (integer) 1（表示有 1 个订阅者收到）
  • 终端 1 将收到：1) “message” 2) “channel:1” 3) “hi”。

实现原理与消息路由

• 频道订阅关系：Redis 服务端维护一个字典 pubsub_channels，键为频道名，值为订阅该频道的客户端链表；订阅即把客户端加入对应链表，退订则移除。
• 模式订阅关系：另维护 pubsub_patterns 列表，保存“模式 → 客户端”的映射；发布消息时，除了发给精确匹配的频道订阅者，还会遍历模式列表，将消息发给所有匹配该频道的模式订阅者。
• 发布路径简述：执行 PUBLISH 时，服务器先在 pubsub_channels 中查找精确订阅者并推送；再遍历 pubsub_patterns 做模式匹配推送；若开启集群，会进行集群内传播。以上数据结构与流程均为 Redis 内存态维护，订阅关系不持久化。

适用场景与局限

• 典型场景
  • 实时通知/广播：系统公告、在线聊天室、实时监控告警。
  • 事件驱动：微服务/组件间轻量事件通知（如缓存失效广播）。
  • 运维与联动：如 Redis Sentinel 节点间用 Pub/Sub 进行故障切换通信。
• 局限与避坑
  • 不持久化、无 ACK：消息错过即丢失，网络闪断或客户端短暂下线期间无法补发，不适合作为需要可靠投递的业务消息队列。
  • 离线不补发：新订阅者只能收到订阅之后的消息。
  • 无重试/回溯/优先级：功能轻量，复杂场景建议使用 RabbitMQ/Kafka/RocketMQ 等专业消息中间件。
  • 客户端缓冲限制：订阅者接收缓冲超限可能被服务端关闭连接，需做好重连与恢复订阅逻辑。