Redis中的订阅发布(三)
订阅发布
发送消息
当一个Redis客户端执行PUBLISH 命令将消息message发送给频道channel的时候，服务器需要执行以下
两个动作:
- 1.将消息message发送给channel频道的所有订阅者
- 2.如果一个或多个模式pattern与频道channel相匹配，那么将消息message发送给pattern模式的订阅者
将消息发送给频道订阅者
因为服务器状态中的pubsub_channels字典记录了所有频道的订阅关系，所以为了将消息发送给channel频道的所有订阅者，PUBLISH命令要做的就是在pubsub_channels字典里找到频道channel的订阅者名单(一个链表),
然后将消息发送给名单上的所有客户端
例子
- 举个例子。假设服务器pubsub_channels字典当前的状态如图所示,
如果这时某个客户端执行命令
PUBLISH "news.it" "hello"
那么PUBLISH命令将在pubsub_channels字典中查找键"news.it"对应的链表值，并通过遍历链表将消息"hello"发送给"news.it"频道的三个订阅者:client-1、client-2、client-3
PUBLISH命令实现
将消息发送给频道订阅者的方法可以用以下伪代码来描述:
def channel_publish(channel, message):
# 如果channel键不存在于pubsub_channels字典中
# 那么说明channel频道没有任何订阅者
# 程序不做发送动作，直接返回
if channel not in server.pubsub_channels:
return
# 运行到这里，说明channel频道至少有一个订阅者
# 程序遍历channel频道的订阅者链表
# 将消息发送给所有订阅者
for subscriber in server.pubsub_channels[channel]:
send_message(subscriber, message)
将消息发送给模式订阅者
因为服务器状态中的pubsub_patterns链表记录了所有模式的订阅关系，所以为了将消息发送给所有与channel频道相匹配的模式的订阅者，PUBLISH命令要做的就是遍历整个pubsub_patterns链表，查找那些与channel频道相匹配的模式，并将消息发送给订阅了这些模式的客户端。
例子
- 举个例子。假设pubsub_patterns链表的当前状态如图所示。
如果这时客户端执行命令
PUBLISH "news.it" "hello"
那么PUBLISH命令会首先将消息"hello"发送给"news.it"频道的所有订阅者，然后开始在pubsub_patterns链表中查找是否有被订阅的模式与"news.it"频道相匹配，结果发现"news.it"频道和客户端client-9订阅的"news.*"频道匹配，于是命令将消息"hello"发送给客户端client-9
PUBLISH命令
将消息发送给模式订阅者的方法可以用以下伪代码来描述:
def pattern_publish(channel, message):
# 遍历所有模式订阅消息
for pubsubPattern in server.pubsub_patterns:
# 如果频道和模式相匹配
if match(channel, pubsubPattern.pattern):
# 那么将消息发送给订阅该模式的客户端
send_message(pubsubPattern.client, message)
最后，PUBLISH命令的实现可以用以下伪代码来描述:
def publish(channel, message):
# 将消息发送给channel频道的所有订阅者
channel_publish(channel, message)
# 将消息发送给所有和channel频道相匹配的模式的订阅者
pattern_publish(channel, message)
查看订阅信息
PUBSUB命令是Redis2.8新增加的命令之一，客户端可以通过这个命令来查看频道或者模式的相关信息，比如某个频道目前有多少订阅者，
又或者某个模式目前有多少订阅者，诸如此类
PUBSUB CHANNELS
PUBSUB CHANNELS [pattern]子命令用于返回服务器当前被订阅的频道，其中pattern参数是可选的:
- 1.如果不给顶patter参数，那么命令返回服务器当前被订阅的所有频道
- 2.如果给定pattern参数，那么命令返回服务器当前被订阅的频道中那些与pattern模式相匹配的频道这个子命令是通过遍历服务器pubsub_channels字典的所有键(每个键都是一个被订阅的频道),然后记录
并返回所有符合条件的频道来实现额，这个过程可以用以下伪代码来描述
def pubsub_channels(pattern=None):
# 一个列表，用于记录所有符合条件的频道
channel_list = []
# 遍历服务器中的所有频道
# (也即是pubsub_channels字典的所有键)
for channel in server.pubsub_channels:
# 当以下两个条件的任意一个满足时，将频道添加到链表里面
# 1.用户没有指定pattern参数
# 2.用户指定了pattern参数，并且channel和pattern匹配
if (patter is None) or match (channel, pattern):
channel_list.append(channel)
# 向客户端返回频道列表
return channel_list
例子
- 举个例子。对于图中所示的pubsub_channels字典来说，执行PUBSUB CHANNELS命令将返回服务器目前订阅的四个频道:
1."news.it"
2."news.sport"
3."news.business"
4."news.movie"
另一方面，执行PUBSUB CHANNELS "news.[is]"命令将返回"news.it"和"news.sport"两个频道,因为只有这两个频道和"news[is]"模式相匹配
1."news.it"
2."news.sport"
原文地址：https://blog.csdn.net/Cover_sky/article/details/137798834
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！