Redis（八）【发布与订阅】

川长思鸟来 2024-04-07 11:52 100阅读 0赞

### 八、 Redis发布订阅 ###

--------------------

Redis 发布订阅（pub/sub）是一种消息通信模式：发送者（pub）发送消息，订阅者（sub）接收消息

Redis 客户端可以订阅任意数量的频道

订阅 / 发布消息图

![在这里插入图片描述][c2fdb5bab71d4a418fbba57889ab3f69.png_pic_center]

下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系：

![在这里插入图片描述][63ddf0baecee452eb0f604f8489aa9a4.png_pic_center]

当有新消息通过 PUBLISH 命令发送给频道 channel1 时， 这个消息就会被发送给订阅它的三个客户端：

![在这里插入图片描述][ee26ebcd81bc4bb69ff5c5b538430c2c.png_pic_center]

#### 8.1 Redis 发布订阅命令 ####

下表列出了 redis 发布订阅常用命令：

<table> 
 <thead> 
  <tr> 
   <th align="left">序号</th> 
   <th align="left">命令及描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">1</td> 
   <td align="left">[PSUBSCRIBE pattern <a href="https://www.runoob.com/redis/pub-sub-psubscribe.html" rel="nofollow">pattern …]</a> <br>订阅一个或多个符合给定模式的频道</td> 
  </tr> 
  <tr> 
   <td align="left">2</td> 
   <td align="left">[PUBSUB subcommand <a href="https://www.runoob.com/redis/pub-sub-pubsub.html" rel="nofollow">argument [argument …]]</a> <br>查看订阅与发布系统状态</td> 
  </tr> 
  <tr> 
   <td align="left">3</td> 
   <td align="left"><a href="https://www.runoob.com/redis/pub-sub-publish.html" rel="nofollow">PUBLISH channel message</a> <br>将信息发送到指定的频道</td> 
  </tr> 
  <tr> 
   <td align="left">4</td> 
   <td align="left">[PUNSUBSCRIBE <a href="https://www.runoob.com/redis/pub-sub-punsubscribe.html" rel="nofollow">pattern [pattern …]]</a> <br>退订所有给定模式的频道</td> 
  </tr> 
  <tr> 
   <td align="left">5</td> 
   <td align="left">[SUBSCRIBE channel <a href="https://www.runoob.com/redis/pub-sub-subscribe.html" rel="nofollow">channel …]</a> <br>订阅给定的一个或多个频道的信息</td> 
  </tr> 
  <tr> 
   <td align="left">6</td> 
   <td align="left">[UNSUBSCRIBE <a href="https://www.runoob.com/redis/pub-sub-unsubscribe.html" rel="nofollow">channel [channel …]]</a> <br>指退订给定的频道</td> 
  </tr> 
 </tbody> 
</table>

> 测试

开启两个**redis-cli**

### 订阅端
    # 订阅一个频道 "vinjcent"
    127.0.0.1:6379> SUBSCRIBE vinjcent
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "vinjcent"
    3) (integer) 1
    # 等待读取推送的信息
    1) "message"	# 消息
    2) "vinjcent"	# 接收的频道
    3) "hello world"	# 频道的消息内容
    
    ### 发送端
    # 发布者发布消息到频道
    127.0.0.1:6379> PUBLISH vinjcent "hello world"
    (integer) 1
    127.0.0.1:6379>

> 原理

*  **Redis 是使用 C 实现的，通过分析 Redis 源码里的 public.c 文件，了解发布和订阅机制的底层实现**
 *  **Redis 通过 PUBLISH、SUBSCRIBE 和 PSUBSCRIBE 等命令实现发布和订阅功能**
 *  **通过 SUBSCRIBE 命令订阅某频道后，redis-server 里维护一个字典，字典的键就是一个个 channel，而字典的值则是一个链表，链表中保存了所有订阅者个 channal 的客户端。SUBSCRIBE 命令的关键，就是将客户端添加到给定 channel 的订阅链表中**
 *  **通过 PUBLISH 命令向订阅者发送消息，redis-server 会使用给定的频道作为建，在它所维护的 channel 字段中查找记录了订阅这个频道的所有客户端的链表，遍历这个链表，将消息发布给所有订阅者**
 *  **Pub/Sub 从字面理解就是 发布（Publish）和 订阅（Subscribe），在 Redis中，可以设定对某一个key值进行消息发布及消息订阅，当一个key值上进行了消息发布后，所有订阅他的客户端都会接受到相应的消息。这一功能最明显的用法就是用作实时消息系统，比如普通的即使聊天，群聊等功能**

[c2fdb5bab71d4a418fbba57889ab3f69.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/6fd79383eafb4caabdd8c9fe3e8fc1c0.png
[63ddf0baecee452eb0f604f8489aa9a4.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/80fa76ff112e4783b9df7b1a256ddfc0.png
[ee26ebcd81bc4bb69ff5c5b538430c2c.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/7e6177ffcb8d46cfbb308036274e4121.png