欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Redis(开发与运维):24---常用功能之(发布与订阅)

程序员文章站 2022-05-19 14:46:37
...

一、发布与订阅概述

  • Redis提供了基于“发布/订阅”模式的消息机制,此种模式下,消息发布者和订阅者不进行直接通信,发布者客户端向指定的频道(channel)发布消息,订阅该频道的每个客户端都可以收到该消息,如下图所示:

Redis(开发与运维):24---常用功能之(发布与订阅)

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

二、发布消息(publish)

PUBLISH <channel> <message>
  • 当一个客户端执行PUBLISH命令的时候,会将消息message发送给频道channel
  • 例如:下面操作会向channel:sports频道发布一条消息“Tim won the championship”,返回结果为订阅者个数,因为此时没有订阅,所以返回结果为0
publish channel:sports "Tim won the championship"

Redis(开发与运维):24---常用功能之(发布与订阅)

二、订阅消息(subscribe)

subscribe channel [channel...]
  • 订阅者可以订阅一个或多个频道
  • 注意事项:
    • 客户端在执行订阅命令之后进入了订阅状态,只能接收subscribe、 psubscribe、unsubscribe、punsubscribe的四个命令
    • 新开启的订阅客户端,无法收到该频道之前的消息,因为Redis不会对发布的消息进行持久化

演示案例

  • 下面操作为当前客户端订阅了channel:sports频道:
subscribe channel:sports

Redis(开发与运维):24---常用功能之(发布与订阅) 

  • 此时右侧另一个客户端向channel:sports频道发布一条消息,右侧客户端会收到这条消息
publish channel:sports "James lost the championship"

Redis(开发与运维):24---常用功能之(发布与订阅)

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

三、取消订阅(unsubscribe

unsubscribe [channel [channel ...]]
  • 客户端可以通过unsubscribe命令取消对指定频道的订阅,取消成功后, 不会再收到该频道的发布消息
  • 取消订阅只对本个客户端有效,不会对其他客户端造成影响
  • 例如:

Redis(开发与运维):24---常用功能之(发布与订阅) 

四、模式订阅/取消模式订阅(psubscribe、punsubscribe)

psubscribe pattern [pattern...]
punsubscribe [pattern [pattern ...]]
  • psubscribe和punsubscribe是支持glob风格的订阅/取消订阅,称之为“模式订阅”

例如:

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

Redis(开发与运维):24---常用功能之(发布与订阅) 

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

Redis(开发与运维):24---常用功能之(发布与订阅)

五、查询订阅

①查询活跃的频道

pubsub channels [pattern]
  • 所谓活跃的频道是指当前频道至少有一个订阅者,其中[pattern]是可以指定具体的模式
  • 例如,下面左侧客户端订阅一个名为“it_redis”的频道,右侧使用pubsub查询,结果会显示出来

Redis(开发与运维):24---常用功能之(发布与订阅)

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

Redis(开发与运维):24---常用功能之(发布与订阅)

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

Redis(开发与运维):24---常用功能之(发布与订阅)

②查看频道订阅数

pubsub numsub [channel ...]
  • 该命令不仅可以检测出是否有活跃的频道,还能检测出频道的订阅数
  • 例如,左侧一个客户端订阅channel:sports频道,右侧客户端查询结果为1
Redis(开发与运维):24---常用功能之(发布与订阅)

③查看模式订阅数

pubsub numpat
  • 该命令可以查询出当前服务器中有多少个模式订阅
  • 例如,当前所有客户端中只有左侧一个订阅,并且不是模式订阅,所以右侧结果显示为0
Redis(开发与运维):24---常用功能之(发布与订阅)
  • 现在我们在左侧开启模式订阅,右侧查询结果显示为1

Redis(开发与运维):24---常用功能之(发布与订阅)

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

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

Redis(开发与运维):24---常用功能之(发布与订阅)

  • 假如视频管理员在视频管理系统中对视频信息进行了变更,希望及时通知给视频服务端,就可以采用发布订阅的模式,发布视频信息变化的消息到指定频道,视频服务订阅这个频道及时更新视频信息,通过这种方式可以有效解决两个业务的耦合性
  • 视频服务订阅video:changes频道如下:
subscribe video:changes
  • 视频管理系统发布消息到video:changes频道如下:
publish video:changes "video1,video3,video5"
  • 当视频服务收到消息,对视频信息进行更新,如下所示:
for video in video1,video3,video5
    update {video}
相关标签: Redis(开发与运维)