发布订阅

Redis提供了基于“发布/订阅”模式的消息机制，此种模式下，消息发布者和订阅者
不进行直接通信，发布者客户端向值指定的频道（channel）发布消息，订阅该频道
的每个客户端都可以收到该消息，如下图所示。Redis听了若干命令支持该功能，在
实际应用开发时，能够为此类问题提供实现方法。

2019-04-09-21-46-29.png

1. 命令

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

   • 发布消息

     publish channel message

     下面操作会向channel:sports频道发布一条消息
     “Tim won the championship”,返回结果为订阅者个数，因为此时没有订
     阅，所以返回结果为0：

     127.0.0.1:6379> publish channel:sports "Tim won the championship"
     (integer) 0
     

   • 订阅消息

     subscribe channel [channel ...]

     订阅者可以订阅一个或多个频道，下面操作为当前客户端订阅了
     channel:sports频道：

     127.0.0.1:6379> subscribe channel:sports
     Reading message... (press Ctrl-C to quit)
     ...
     1) "message"
     2) "channel:sports"
     3) "James lost the championship"
     

     如果有多个客户端同时订阅了channel:sports，整个过程如下图：
     有关订阅命令有点需要注意：

     • 客户端在执行订阅命令之后进入了订阅状态，只能接收subscribe、
       psubscibe、unsubscribe、punsubscribe的四个命令。
     • 新开启的订阅客户端，无法收到该频道之前的消息，因为Redis不会对发
       布的消息进行持久化。
     2019-04-09-22-29-07.png

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

   • 取消订阅

     unsubscribe [channel [channel ...]]

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

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

   • 按照模式订阅和取消订阅

     psubscribe pattern [pattern ...]

     punsubscribe [pattern [pattern ...]]

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

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

   • 查询订阅

     （1） 查看活跃的频道

     pubsub channels [pattern]

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

     127.0.0.1:6379> pubsub channels
     1) "channel:sports"
     2) "channel:it"
     3) "channel:travel"
     
     127.0.0.1:6379> pubsub channels channel:*r*
     1) "channel:sports"
     2) "channel:travel"
     

     （2） 查看频道订阅数

     pubsub numsub [channel ...]

     当前channel:sports频道的订阅数为2：

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

     （3） 查看模式订阅数

     pubsub numpat

     当前只有一个客户端通过模式来订阅：

     127.0.0.1:6379> pubsub numpat
     (integer) 1
     

2. 使用场景

   聊天室、公告牌、服务之间利用消息解耦都可以使用发布订阅模式，下面以简单
   的服务解耦进行说明。如下图所示，图中有两套业务，上面为视频管理系统，负
   责管理视频信息；下面为视频服务面向客户，用户可以通过各种客户端（手机、
   浏览器、接口）获取到视频信息。

   2019-04-09-22-51-59.png

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

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

   subscribe video:changes

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

   publish video:changes "video1, video3, video5"

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

   for video in video1, video3, video5
       update(video)