Redis入门到入坑14——发布订阅

Redis 入门到入坑14——发布订阅

Redis发布/订阅模式

简介

Redis发布订阅（Pub/Sub）是一种消息传递模式，它允许发送消息的进程（发布者）向特定的接收消息的进程（订阅者）传递消息。在Redis中，发布者和订阅者都可以通过频道（channel）来发送和接收消息。

• 发布者：发布者向指定的频道发送消息。发布者可以发送各种类型的消息，例如字符串、哈希、列表等。

• 订阅者：订阅者订阅一个或多个频道，并接收这些频道中的消息。订阅者可以同时订阅多个频道，以接收不同类型的信息。

• 频道：频道是发布者和订阅者之间的通信媒介。发布者将消息发送到特定的频道，订阅者从这些频道接收消息。

• 持久化：Redis的发布订阅是持久化的，即使订阅者在消息发送时不在线，当订阅者再次连接时，它可以获取所有未接收的消息

下图展示了频道与订阅者的关系以及新消息发布时的流程

Redis 发布/订阅模式的工作流程

发布订阅模式的常用命令

• SUBSCRIBE channel [channel ...]
  ：订阅指定的一个或者多个频道（推荐先执行订阅之后再发布，订阅成功之前发布的消息是接收不到的）

127.0.0.1:6379> subscribe c1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "c1"
3) (integer) 1

• PUBLISH channel message:将消息发送到指定的频道

--- 发布消息的客户端
[root@gone ~]# redis-cli
127.0.0.1:6379> publish c1 hello_c1
(integer) 2
 
--- 之前订阅消息的客户端
127.0.0.1:6379> subscribe c1 
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "c1"
3) (integer) 1
1) "message"         ------- 消息的种类
2) "c1"              ------- 始发频道的名称
3) "hello_c1"        ------- 实际的消息内容

• PSUBSCRIBE [pattern [pattern ...]]：订阅一个或多个符合给定模式的频道

-- 这个命令订阅了所有以 "redis1" 开头和以 "redis2" 开头的频道，并输出多条显示订阅成功的消息
PSUBSCRIBE redis1* redis2* 

• PUBSUB [argument [argument ...]]]：查看订阅与发布系统状态。它由数个不同格式的子命令组成

--- 返回活跃频道的列表
127.0.0.1:6379> pubsub channels
1) "c1"
2) "c2"
--- 返回c1频道的订阅者数量
127.0.0.1:6379> pubsub numsub c1
1) "c1"
2) (integer) 3
-- 只统计使用PSUBSCRIBE命令执行的，返回客户端订阅的唯—模式的数量
--- 客户端1下执行
127.0.0.1:6379> psubscribe a* b* c* d*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "a*"
3) (integer) 1
1) "psubscribe"
2) "b*"
3) (integer) 2
1) "psubscribe"
2) "c*"
3) (integer) 3
1) "psubscribe"
2) "d*"
3) (integer) 4
--- 客户端2下执行
127.0.0.1:6379> pubsub numpat
(integer) 4

• PUNSUBSCRIBE [pattern [pattern ...]]：退订所有给定模式的频道

--- 命令退订了所有以"redis1"开头和以"redis2"开头的频道，并输出多条显示退订成功的消息
PUNSUBSCRIBE redis1* redis2*
    

• UNSUBSCRIBE [channel ...]：取消订阅指定的频道

127.0.0.1:6379> unsubscribe c1
1) "unsubscribe"
2) "c1"
3) (integer) 0    

案例演示

• 开启3个客户端，客户端A、B订阅消息，C发布消息

--- 1.客户端A订阅:
127.0.0.1:6379> subscribe c1 
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "c1"
3) (integer) 1    
 
--- 2.客户端B订阅
127.0.0.1:6379> subscribe c1 
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "c1"
3) (integer) 1 
 
--- 3.客户端C发布
127.0.0.1:6379> publish c1 'hello channel c1'
(integer) 2 
 
--- 4.查看客户端A
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "c1"
3) (integer) 1
1) "message"
2) "c1"
3) "hello channel c1"
    
--- 5.查看客户端B
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "c1"
3) (integer) 1
1) "message"
2) "c1"
3) "hello channel c1"

• 批量订阅和发布

--- 批量订阅
--- 1.客户端A执行
127.0.0.1:6379> psubscribe a* b* c* d*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "a*"
3) (integer) 1
1) "psubscribe"
2) "b*"
3) (integer) 2
1) "psubscribe"
2) "c*"
3) (integer) 3
1) "psubscribe"
2) "d*"
3) (integer) 4
 
---2.客户端B执行
127.0.0.1:6379> pubsub numpat
(integer) 4
127.0.0.1:6379> publish c10 hello_channel_c10
(integer) 1
127.0.0.1:6379> publish a11 hello_channel_a11
(integer) 1
 
--- 3.查看客户端A的信息输出
127.0.0.1:6379> psubscribe a* b* c* d*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "a*"
3) (integer) 1
1) "psubscribe"
2) "b*"
3) (integer) 2
1) "psubscribe"
2) "c*"
3) (integer) 3
1) "psubscribe"
2) "d*"
3) (integer) 4
    
---- 输出的信息
1) "pmessage"
2) "c*"
3) "c10"
4) "hello_channel_c10"
1) "pmessage"
2) "a*"
3) "a11"
4) "hello_channel_a11"

发布订阅模式的缺点

Redis 的发布-订阅模式是一种非常强大的消息传递机制，它允许订阅者监听一个或多个频道，并在有消息发布到这些频道时接收它们。然而，这种模式也有一些潜在的缺点：