写在前面
今天学习redis最后的知识。
Redis 的发布与订阅
发布/订阅模式
Redis 提供了两种发布/订阅模式:
- 基于频道 (Channel) 的发布/订阅
- 基于模式 (Pattern) 的发布/订阅
相关命令
-
订阅频道
subscribe channel [channel ...]
订阅给定的一个或多个频道。
-
退订频道
unsubscribe channel [channel ...]
退订给定的频道。若没有指定频道,则默认退订所有频道。
-
发布消息
publish channel message
将消息发送给指定频道
channel
。返回结果:接收到信息的订阅者数量,无订阅者返回 0。 -
查看活跃频道
pubsub channels [argument [argument ...]]
查看订阅与发布系统的状态。返回活跃频道列表(即至少有一个订阅者的频道,订阅模式的客户端除外)。
-
按模式订阅
psubscribe pattern1 [pattern ...]
订阅一个或多个符合给定模式的频道。每个模式以
*
作为匹配符;例如shujia*
匹配所有以shujia
开头的频道,如shujia.java
、shujia.hadoop
。 -
按模式退订
punsubscribe [pattern [pattern ...]]
退订所有给定模式的频道。若
pattern
未指定,则退订所有模式;否则只退订指定的模式。
消息队列
在 Redis 中,List 数据类型可以用于排队数据,按照顺序取出,但无法精确获取(双端队列)。这种方式存在两个局限性:
- 不能支持一对多的消息分发。
- 如果生产者生成的速度远大于消费者的消费速度,易堆积大量未消费的消息。
角色
- 发布者(Publisher) :使用
PUBLISH
命令将消息发布到指定的频道。 - 订阅者(Subscriber) :使用
SUBSCRIBE
命令订阅一个或多个频道以接收消息。所有订阅同一频道的订阅者都会收到此消息。 - 频道(Channel) :频道是消息的通道,发布者通过指定频道来发布消息,订阅者通过订阅频道来接收相关消息。
- 消息(Message) :由发布者发送给订阅者的数据。
注意
- 订阅者使用
SUBSCRIBE
命令订阅频道后,将会一直等待新消息。可以使用UNSUBSCRIBE
命令取消订阅。 - Redis 的发布订阅模式不保证消息的可靠传递。如果订阅者在消息发布之前已断开连接,则无法接收到已发布的消息。换句话说,如果先发布消息,再订阅频道,不会收到订阅之前就发布到该频道的消息!
- Redis 提供了其他相关命令和功能,如按模式订阅 (
PSUBSCRIBE
)、取消订阅 (UNSUBSCRIBE
) 等。可以查阅 Redis 文档以获取更多信息。
请注意 :在高吞吐量和大规模发布订阅场景下,Redis 的发布订阅模式可能不是最佳选择,可以考虑使用专门的消息队列系统来替代。
状态解释
localhost:7000> subscribe xiaohu1Reading messages... (press Ctrl-C to quit)1) "subscribe" # 返回值类型:表示订阅成功!2) "xiaohu1" # 订阅频道的名称3) (integer) 1 # 当前客户端已订阅频道的数量
示意图
- 频道订阅 :订阅频道时先检查字段内部是否存在;不存在则为当前频道创建一个字典,并创建一个链表存储客户端 ID;否则直接将客户端 ID 插入到链表中。
- 取消频道订阅 :取消时将客户端 ID 从对应的链表中删除;如果删除之后链表为空,则将会把这个频道从字典中删除。
- 发布 :首先根据
channel
定位到字典的键,然后将信息发送给字典值链表中的所有客户端。