Redis开发与运维之小功能大用处(4)——发布订阅

Redis开发与运维之小功能大用处(4)——发布订阅

Redis除了提供了强大的5种数据结构外,还提供了慢查询分析、Redis Shell、Pipeline、事务与Lua脚本、Bitmaps、HyperLogLog、发布订阅、GEO等附加功能。本章节主要说发布订阅。

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

命令

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

1、发布命令

publish channel message

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

publish channel:sports "Tim won the championship"

2、订阅命令

subscribe channel [channel ...]

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

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

此时另一个客户端发布一条消息

publish channel:sports "James lost the championship"

订阅客户端会收入信息

1) "message" 
2) "channel:sports" 
3) "James lost the championship"

如果有多个客户端同时订阅了channel:sports,会同时收到发布者信息。订阅命令需要注意一下两点:

  • 客户端在执行订阅命令之后进入了订阅状态,只能接收subscribe、psubscribe、unsubscribe、punsubscribe的四个命令。

  • 新开启的订阅客户端,无法收到该频道之前的消息,因为Redis不会对发布的消息进行持久化。

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

3、取消订阅

unsubscribe [channel [channel ...]]

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

4、按照模式订阅和取消订阅

psubscribe pattern [pattern...] 
punsubscribe [pattern [pattern ...]]

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

psubscribe it*

5、查询订阅

  • 查看活动的订阅

    pubsub channels [pattern]
    

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

  • 查看频道订阅数

    pubsub numsub [channel ...]
    
  • 查看模式订阅数

    pubsub numpat
    

使用场景

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

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