一个客户端触发,多个客户端被动接受,通过Redis服务器中转,这种模式成为发布/订阅模式。
发布/订阅交互模式
角色关系:
客户端分为发布者和订阅者两种角色
发布者和订阅者通过channel关联
交互方向:
发布者和Redis服务器的交互仍为请求/响应模式
服务器向订阅者发送数据(推送)
时序:推送发送在服务器收到发布者消息之后
两类channel
普通channel:订阅者通过SUBSCRIBE/UNSUBSCRIBE将自己绑定/解绑到某个Channel上;发布者的publish命令指定某个消息发送到哪个channel,再由服务器将消息转发给channel上绑定的订阅者
pattern channel:订阅者通过PSUBSCRIBE/PUNSUBSCRIBE将自己绑定/解绑到某个pattern channel上;发布者的publish命令指定某个消息发送到哪个channel,再由服务器通过channel的名字和pattern channel的名字做匹配,匹配成功则将消息转发给这个pattern channel上绑定的订阅者。
订阅关系的实现
channel的订阅关系,维护在Redis实例级别,独立于redisDb的key-value体系。
pubsub_channels map维护普通channel和订阅者的关系:键是channel的名字,value是它所有订阅者client的指针链表
pubsub_patterns维护pattern channel和订阅者的关系:链表的每个元素包含两部分(pattern channel的名字和订阅它的client指针)
发布者向某个channel publish一条消息时,redis首先会从pubsub_channels中找到对应的value,向它的所有client发送该消息;同时,遍历pubsub_patterns列表,向能够匹配的元素的client也发送该消息。
领取专属 10元无门槛券
私享最新 技术干货