首页 > 数据库> 文章详细

redis独立功能模块

2021-12-21 13:01:33 阅读：204 来源： 互联网

标签：订阅频道 redis 独立链表功能模块 channels channel pubsub

发布订阅

订阅频道，如果该频道中有新的消息，那么订阅该频道的客户端都可以收到消息。主要涉及的命令：PUBLISH、SUBSCRIBE、PSUBSCRIBE。

频道的订阅与退订

订阅频道

操作

订阅某个频道使用SUBSCRIBE命令，如果想订阅多个频道，直接追加即可。

SUBSCRIBE "news.sport" "news.movie"

原理

在redisServer结构中，保存了所有频道的订阅关系：

struct redisServer {
 // ...
 // 保存所有频道的订阅关系
 dict *pubsub_channels;
 // ...
};

这个字典的键是某个被订阅的频道，而键的值则是一个链表，链表里面记录了所有订阅这个频道的客户端。举例：如果客户端要订阅一个test频道，如果pubsub_channels字典中有这个频道，就添加在这个频道的链表中。否则就在pubsub_channels字典中添加一个key为test的键，值是一个链表，链表中保存客户端的信息。

伪代码：

def subscribe(*all_input_channels):
 # 遍历输入的所有频道
 for channel in all_input_channels:
 # 如果channel不存在于pubsub_channels字典（没有任何订阅者）
 # 那么在字典中添加channel键，并设置它的值为空链表
 if channel not in server.pubsub_channels:
 server.pubsub_channels[channel] = []
 # 将订阅者添加到频道所对应的链表的末尾
 server.pubsub_channels[channel].append(client)

退订频道

操作

退订和订阅相反，使用的是UNSUBSCRIBE命令。

UNSUBSCRIBE "news.sport" "news.movie"

原理

退订操作就是将该客户端从pubsub_channels中对应频道中的链表中移除。

伪代码：

def unsubscribe(*all_input_channels):
 # 遍历要退订的所有频道
 for channel in all_input_channels:
 # 在订阅者链表中删除退订的客户端
 server.pubsub_channels[channel].remove(client)
 # 如果频道已经没有任何订阅者了（订阅者链表为空）
 # 那么将频道从字典中删除
 if len(server.pubsub_channels[channel]) == 0:
 server.pubsub_channels.remove(channel)

模式的订阅与退订

订阅模式是什么呢？其实就是通过正在表达式匹配多个频道。new.[ie]t可以匹配上new.it和new.et两个频道，这两个频道的消息，订阅模式的客户端都可以收到。
在这里插入图片描述

操作

命令：PSUBSCRIBE。

PSUBSCRIBE "news.*"

原理

服务器也将所有模式的订阅关系都保存在服务器状态的pubsub_patterns属性里面：

struct redisServer {
 // ...
 // 保存所有模式订阅关系
 list *pubsub_patterns;
 // ...
};

pubsub_patterns属性是一个链表，链表中的每个节点都包含着一个pubsub Pattern结构，这个结构的pattern属性记录了被订阅的模式，而client属性则记录了订阅模式的客户端：

typedef struct pubsubPattern {
 // 订阅模式的客户端
 redisClient *client;
 // 被订阅的模式
 robj *pattern;
} pubsubPattern;

在这里插入图片描述
订阅模式就是添加一个节点，退订模式就是删除对应的节点。

发送消息

了解了底层结构，向频道中发消息可以很容易理解了。
当向一个频道发消息时，直接遍历该频道的链表，将消息发送给链表中的所有客户端。之后再遍历模式的链表，找到与频道匹配的节点，将消息发送给该客户端。
给订阅频道的客户端发送消息，伪代码：

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)

给订阅模式的客户端发送消息，伪代码：

def pattern_publish(channel, message):
 # 遍历所有模式订阅消息
 for pubsubPattern in server.pubsub_patterns:
 # 如果频道和模式相匹配
 if match(channel, pubsubPattern.pattern):
 # 那么将消息发送给订阅该模式的客户端
 send_message(pubsubPattern.client, message)

发送消息的伪代码：

def publish(channel, message):
 # 将消息发送给channel频道的所有订阅者
 channel_publish(channel, message)
 # 将消息发送给所有和channel频道相匹配的模式的订阅者
 pattern_publish(channel, message)

查看订阅消息

主要涉及几个命令：

PUBSUB CHANNELS[pattern]

查看所有频道的名称，如果指定到了pattern，返回的将是与模式匹配的频道名称：

redis> PUBSUB CHANNELS
1) "news.it"
2) "news.sport"
3) "news.business"

redis> PUBSUB CHANNELS "news.[is]*"
1) "news.it"
2) "news.sport"

返回这些频道的订阅者数量

PUBSUB NUMSUB[channel-1 channel-2...channel-n]

redis> PUBSUB NUMSUB news.it news.sport news.business news.movie
1) "news.it"
2) "3"
3) "news.sport"
4) "2"
5) "news.business"
6) "2"
7) "news.movie"
8) "1"

PUBSUB NUMPAT子命令用于返回服务器当前被订阅模式的数量：

redis> PUBSUB NUMPAT
(integer) 3

总结

服务器状态在pubsub_channels字典保存了所有频道的订阅关系：SUBSCRIBE命令负责将客户端和被订阅的频道关联到这个字典里面，而UNSUBSCRIBE命令则负责解除客户端和被退订频道之间的关联。
服务器状态在pubsub_patterns链表保存了所有模式的订阅关系：PSUBSCRIBE命令负责将客户端和被订阅的模式记录到这个链表中，而PUNSUBSCRIBE命令则负责移除客户端和被退订模式在链表中的记录。
PUBLISH命令通过访问pubsub_channels字典来向频道的所有订阅者发送消息，通过访问pubsub_patterns链表来向所有匹配频道的模式的订阅者发送消息。
PUBSUB命令的三个子命令都是通过读取pubsub_channels字典和pubsub_patterns链表中的信息来实现的。

标签：订阅,频道,redis,独立,链表,功能模块,channels,channel,pubsub
来源： https://blog.csdn.net/qq_34501351/article/details/122059185

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9