一、发布与订阅概述
- Redis提供了基于“发布/订阅”模式的消息机制,此种模式下,消息发布者和订阅者不进行直接通信,发布者客户端向指定的频道(channel)发布消息,订阅该频道的每个客户端都可以收到该消息。
- 下图展示了频道 channel1 , 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系:
当有新消息通过 PUBLISH 命令发送给频道 channel1 时, 这个消息就会被发送给订阅它的三个客户端:
- Redis主要提供了发布消息、订阅频道、取消订阅以及按照模式订阅和取消订阅等命令
二、发布消息(publish)
PUBLISH <channel> <message>
- 当一个客户端执行PUBLISH命令的时候,会将消息message发送给频道channel
- 例如:下面操作会向channel:sports频道发布一条消息“Tim won the championship”,返回结果为订阅者个数,因为此时没有订阅,所以返回结果为0
publish channel:sports "Tim won the championship"
二、订阅消息(subscribe)
subscribe channel [channel...]
- 客户端在执行订阅命令之后进入了订阅状态,只能接收subscribe、 psubscribe、unsubscribe、punsubscribe的四个命令
- 新开启的订阅客户端,无法收到该频道之前的消息,因为Redis不会对发布的消息进行持久化
演示案例
- 下面操作为当前客户端订阅了channel:sports频道:
- 此时右侧另一个客户端向channel:sports频道发布一条消息,右侧客户端会收到这条消息
publish channel:sports "James lost the championship"
- 开发提示:和很多专业的消息队列系统(例如Kafka、RocketMQ)相比,Redis的发布订阅略显粗糙,例如无法实现消息堆积和回溯。但胜在足够简单,如果当前场景可以容忍的这些缺点,也不失为一个不错的选择
三、取消订阅(unsubscribe)
unsubscribe [channel [channel ...]]
- 客户端可以通过unsubscribe命令取消对指定频道的订阅,取消成功后, 不会再收到该频道的发布消息
- 取消订阅只对本个客户端有效,不会对其他客户端造成影响
- 例如:
四、模式订阅/取消模式订阅(psubscribe、punsubscribe)
psubscribe pattern [pattern...]
punsubscribe [pattern [pattern ...]]
- psubscribe和punsubscribe是支持glob风格的订阅/取消订阅,称之为“模式订阅”
例如:
发表评论