Redis发布订阅

作者: huxt | 来源:发表于2019-06-26 09:56 被阅读0次

    发布订阅

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

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

    1.发布消息

    publish channel message

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

    127.0.0.1:6379> publish channel:sports "Tim won the championship" 

    (integer) 0

    2.订阅消息

    subscribe channel [channel ...]

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

    127.0.0.1:6379> subscribe channel:sports 

    Reading messages... (press Ctrl-C to quit) 

    1) "subscribe" 

    2) "channel:sports" 

    3) (integer) 1

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

    127.0.0.1:6379> publish channel:sports "James lost the championship" 

    (integer) 1

    当前订阅者客户端会收到如下消息:

    127.0.0.1:6379> subscribe channel:sports 

    Reading messages... (press Ctrl-C to quit) ... 

    1) "message" 

    2) "channel:sports" 

    3) "James lost the championship"

    如果有多个客户端同时订阅了channel:sports会同时收到信息

    两点需要注意:

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

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

    3.取消订阅

    unsubscribe [channel [channel ...]]

    127.0.0.1:6379> unsubscribe channel:sports

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

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

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

    127.0.0.1:6379> psubscribe it*

    5.查询订阅

    (1)查看活跃的频道

    pubsub channels [pattern]

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

    pubsub channels

    (2)查看频道订阅数

    pubsub numsub [channel ...]

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

    127.0.0.1:6379> pubsub numsub channel:sports

    (3)查看模式订阅数

    pubsub numpat

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

    127.0.0.1:6379> pubsub numpat

    使用场景

    聊天室、公告牌、服务之间利用消息解耦都可以使用发布订阅模式,下 面以简单的服务解耦进行说明

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

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

    subscribe video:changes

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

    publish video:changes "video1,video3,video5"

    ·当视频服务收到消息,对视频信息进行更新,如下所示:

    for video in video1,video3,video5    

            update {video}

    相关文章

      网友评论

        本文标题:Redis发布订阅

        本文链接:https://www.haomeiwen.com/subject/lsdqcctx.html