Redis系列之Redis的发布与订阅

发表于 | 阅读数
字数统计: 1.2k | 阅读时长 ≈ 5

如无特殊说明，本站Redis系列文章均基于Redis 5.0.8，CentOS 7.9，远程连接工具RDM。

Redis提供了发布（publish）订阅（subscribe）功能。

从pub/sub的机制来看，更像是一个广播系统。多个sub可以订阅多个channel，多个pub可以往多个channel中发布消息，可以理解成：

Subscribe：收音机，可以收到多个频道，并以队列的方式显示

Publish: 电台，可以往不同的频道中发消息

Channel：不同频率的频道。

发布订阅的命令

主要有发布消息、订阅频道、取消订阅以及按照模式订阅和取消订阅等命令。

PUBLISH channel msg ： 将信息 message 发送到指定的频道 channel
SUBSCRIBE channel [channel ...] ： 订阅频道，可以同时订阅多个频道
UNSUBSCRIBE [channel ...] ： 取消订阅指定的频道, 如果不指定频道，则会取消订阅所有频道
PSUBSCRIBE pattern [pattern ...]： 订阅一个或多个符合给定模式的频道，每个模式以 * 作为匹配符，比如 it* 匹配所 有以 it 开头的频道( it.news 、 it.blog 、 it.tweets 等等)， news.* 匹配所有 以 news. 开头的频道( news.it 、 news.global.today 等等)，诸如此类
PUNSUBSCRIBE [pattern [pattern ...]] ： 退订指定的规则, 如果没有参数则会退订所有规则
PUBSUB subcommand [argument [argument ...]] ： `查看订阅与发布系统状态

注意：使用发布订阅模式实现的消息队列，当有客户端订阅channel后只能收到后续发布到该频道的消息，之前发送的不会缓存，必须Provider和Consumer同时在线。因为Redis不会对发布的消息进行持久化。

同时，客户端在执行订阅命令之后进入订阅状态，只能接受：subscribe、psubscribe、unsubscribe、punsubscribe

与专业的消息队列相比（比如kafka，rocketmq），redis的发布订阅很粗糙，例如无法实现消息堆积和回溯，但胜在足够简单。

启动两个redis-cli窗口，均订阅JUST 频道（channel）

1
2
3
4
5
6
7
8
9
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> SUBSCRIBE JUST
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "JUST"
3) (integer) 1
1) "message"
2) "JUST"
3) "123"
1
2
3
4
5
6
7
8
9
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> SUBSCRIBE JUST
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "JUST"
3) (integer) 1
1) "message"
2) "JUST"
3) "123"

启动发布者向频道JUST发送消息

l
1
2
3
4
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> PUBLISH JUST "123"
(integer) 2  # 此时返回的是订阅者的个数，没有订阅则返回0
127.0.0.1:6379>

订阅一个或者多个符合模式的频道

启动两个redis-cli窗口，分别订阅 J* 和 JU*频道

1
2
3
4
5
6
7
8
9
10
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> psubscribe JU*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "JU*"
3) (integer) 1
1) "pmessage"
2) "JU*"
3) "JUST"
4) "Testing~"
1
2
3
4
5
6
7
8
9
10
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> psubscribe J*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "J*"
3) (integer) 1
1) "pmessage"
2) "J*"
3) "JUST"
4) "Testing~"

发布消息

1
2
3
127.0.0.1:6379> PUBLISH JUST "Testing~"
(integer) 2
127.0.0.1:6379>

取消订阅

客户端可以通过画unsubscribe命令取消对指定频道的订阅，取消成功后，不会再收到该频道发布的消息

1
2
3
4
5
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> unsubscribe Just
1) "unsubscribe"
2) "Just"
3) (integer) 0

按照模式订阅和取消订阅

除了subscribe和unsubscribe命令，redis还支持glob风格的订阅命令psubscribe和取消订阅命令punsubscribe，例如下面会订阅it开头的所有频道：

1
2
3
4
5
6
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> psubscribe it*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "it*"
3) (integer) 1

查询订阅

可以查询：

  • 活跃的频道
  • 频道订阅数
  • 查看模式订阅数

查看活跃的频道

所谓活跃的频道是指当前频道至少有一个订阅者：

1
2
3
4
5
6
7
8
9
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> pubsub channels
1) "sport"
2) "just"
3) "travel"
127.0.0.1:6379> pubsub channels *r*
1) "sport"
2) "travel"
127.0.0.1:6379>

查看频道订阅数

1
2
3
127.0.0.1:6379> pubsub numsub just
1) "just"
2) (integer) 1

查看模式订阅数

1
2
3
4
5
6
7
8
9
[root@iZ8vbavndeiwj2ctanxb49Z ~]# redis-cli
127.0.0.1:6379> psubscribe channel *r*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "channel"
3) (integer) 1
1) "psubscribe"
2) "*r*"
3) (integer) 2
1
2
127.0.0.1:6379> pubsub numpat
(integer) 2  #

应用

聊天室、公告牌、服务之间利用消息解耦都可以使用发布订阅模式。比如发布变化到指定频道，下游服务订阅这个变化并进行相应的操作，通过这种方式可以有效解决不同业务间的耦合性。

如果觉得写的还行，赞助瓶脉动～
0%