Redis学习笔记—发布订阅

发表于 更新于 分类于

Redis提供了基于“发布/订阅”模式的消息机制，此种模式下，消息发布者和订阅者不进行直接通信，发布者客户端向指定的频道（channel）发布消息，订阅该频道的每个客户端都可以收到该消息

和很多专业的消息队列系统（例如Kafka、RocketMQ）相比，Redis的发布订阅略显粗糙，例如无法实现消息堆积和回溯。但胜在足够简单，如果当前场景可以容忍的这些缺点，也不失为一个不错的选择

Redis主要提供了发布消息、订阅频道、取消订阅以及按照模式订阅和取消订阅等命令；

发布消息

1
publish channel message

发布一条”channel:sports”体育频道消息”James in Los Angeles”

1
2
127.0.0.1:6379> publish channel:sports "James in Los Angeles"  
(integer) 0

订阅消息

1
subscribe channel [channel ...]

订阅消息可以订阅多条消息

订阅这个体育频道

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

此时新开一个客户端往这个频道发布一条消息

1
2
127.0.0.1:6379> publish channel:sports "Harden in Houston"  
(integer) 1

这时候这个订阅者会受到刚刚发布消息的推送

1
2
3
4
5
6
7
8
127.0.0.1:6379> subscribe channel:sports  
Reading messages... (press Ctrl-C to quit)  
1) "subscribe"  
2) "channel:sports"  
3) (integer) 1  
1) "message"  
2) "channel:sports"  
3) "Harden in Houston"
  • 客户端在执行订阅命令之后进入了订阅状态，只能接收subscribe、psubscribe、unsubscribe、punsubscribe的四个命令
  • 新开启的订阅客户端，无法收到该频道之前的消息，因为Redis不会对发布的消息进行持久化

取消订阅

1
unsubscribe channel [channel ...]

取消订阅体育频道

1
2
3
4
127.0.0.1:6379> unsubscribe channel:sports  
1) "unsubscribe"  
2) "channel:sports"  
3) (integer) 0

按照模式订阅和取消订阅

1
2
psubscribe pattern [pattern...]  
punsubscribe [pattern [pattern ...]]

订阅以it开头的所有频道

1
2
3
4
5
127.0.0.1:6379> psubscribe it*  
Reading messages... (press Ctrl-C to quit)  
1) "psubscribe"  
2) "it*"  
3) (integer) 1

查询订阅

1.查看活跃的频道

1
pubsub channels [pattern]

所谓活跃指的是最少有一个人订阅，其中[pattern]是可以指定具体的模式

1
2
127.0.0.1:6379> pubsub channels  
1) "channel:sports"

2.查看频道订阅数

1
pubsub numsub [channel ...]

查询channel:sports频道订阅数是1个

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

3.查看模式订阅数

1
pubsub numpat

当前通过模式订阅的有1个客户端

1
2
127.0.0.1:6379> pubsub numpat  
(integer) 1