一、发布与订阅概述

• 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频道：

subscribe 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风格的订阅/取消订阅，称之为“模式订阅”

例如：

• 下面左侧客户端订阅以it开头的所有频道

psubscribe it*

• 右侧客户端向itformation频道发送一条消息，左侧客户端可以收到这条消息

五、查询订阅

①查询活跃的频道

pubsub channels [pattern]

• 所谓活跃的频道是指当前频道至少有一个订阅者，其中[pattern]是可以指定具体的模式

• 例如，下面左侧客户端订阅一个名为“it_redis”的频道，右侧使用pubsub查询，结果会显示出来

• 当然，我们也可以具体指出查询哪个频道，如果频道不存在会返回空

• 当有模式订阅时，也可以检测出来

②查看频道订阅数

pubsub numsub [channel ...]

• 该命令不仅可以检测出是否有活跃的频道，还能检测出频道的订阅数

• 例如，左侧一个客户端订阅channel:sports频道，右侧客户端查询结果为1

③查看模式订阅数

pubsub numpat

• 该命令可以查询出当前服务器中有多少个模式订阅

• 例如，当前所有客户端中只有左侧一个订阅，并且不是模式订阅，所以右侧结果显示为0

• 现在我们在左侧开启模式订阅，右侧查询结果显示为1

六、发布-订阅的使用场景

• 聊天室、公告牌、服务之间利用消息解耦都可以使用发布订阅模式

• 下面以简单的服务解耦进行说明。如下图所示，图中有两套业务：

• • 上面为视频管理系统，负责管理视频信息

  • 下面为视频服务面向客户，用户可以通过各种客户端（手机、浏览器、接口）获取到视频信息

• 假如视频管理员在视频管理系统中对视频信息进行了变更，希望及时通知给视频服务端，就可以采用发布订阅的模式，发布视频信息变化的消息到指定频道，视频服务订阅这个频道及时更新视频信息，通过这种方式可以有效解决两个业务的耦合性

• 视频服务订阅video：changes频道如下：

subscribe video:changes

• 视频管理系统发布消息到video：changes频道如下：

publish video:changes "video1,video3,video5"

• 当视频服务收到消息，对视频信息进行更新，如下所示：

for video in video1,video3,video5
update {video}