文章详情

短信预约信息系统项目管理师 报名、考试、查分时间动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Redis学习笔记(二十) 发布订阅(下)

2022-03-29 00:21

关注

Redis学习笔记(二十) 发布订阅(下)

当一个客户端执行SUBSCRIBE命令订阅某个或某些频道时,这个客户端与被订阅频道之间就建立起了一种订阅关系。

Redis将所有频道的订阅关系保存在服务器状态的pubsub_channels字典里面,这个字典的键是某个被订阅的频道,而键的值是一个链表,链表里面记录了所有订阅这个频道的客户端:

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

如果频道已经有其他的订阅者,那么他在pubsub_channels字典中必然有相应的订阅者链表,程序唯一要做的就是将客户端添加到订阅者链表的末尾,反之程序首先要在pubsub_channels字典中为频道创建一个键,并将这个键的值设置为空链表,然后将客户端添加到链表,成为链表的第一个元素。

UNSUBSCRIBE命令的行为与SUBSCRIBE命令相反,当一个客户端推定某个或某些频道的时候,服务器将从pubsub_channels中接触客户端与被订阅频道之间的关联:程序会根据被推定频道的名字,在publish_channels字典中找到频道对应的订阅链表,而后从订阅者链表中删除退订客户端的信息;如果删除推定客户端之后,频道的订阅者链表变成空链表,那么说明频道已经没有了订阅者了,程序将从pubsub_channels字典中删除频道对应的键。

服务器将所有频道的订阅关系都保存在服务器状态的pubsub_channels属性里面,与之相似,服务器也将所有模式的订阅关系都保存在服务器状态的pubsub_patterns属性里面:

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

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

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

订阅模式

每当客户端执行PSUBSCRIBE命令订阅某个或某些模式的时候,服务器会对某个被订阅的模式执行:新建一个pubsubPattern结构,将结构的pattern属性设置为被订阅的模式,client属性设置为订阅模式的客户端;将pubsubPattern结构添加到pubsub_patterns链表的表尾。

发送消息

当一个Redis客户端执行PUBLISH < channel > < message > 命令将消息message发送给频道channel的时候,服务器需要执行以下两个动作:将消息message发送给channel频道的所有订阅者;如果有一个或多个模式pattern与频道channel相匹配,那么将消息message发送给pattern模式的订阅者。

因为服务器状态中pubsub_channels字典记录了所有频道的订阅关系,所以为了将消息发送给channel频道的所有订阅者,PUBLISH命令要做的就是在subsub_channels字典里找到频道channel的订阅者名单(链表),然后将消息发送给名单上的所有客户端。

将消息发送欸模式订阅者,因为服务器状态中的pubsub_patterns链表记录了所有模式的订阅关系,所以为了将消息发送给所有与channel频道相匹配的模式的订阅者,PUBLISH命令要做的就是遍历整个pubsub_patterns链表,查找那些与channel频道相匹配的模式,并将消息发送给订阅了谢谢模式的客户端。

PUBSUB CHANNELS 【pattern】子命令用于返回服务器当前被订阅的频道,如果【pattern】参数不给定,那么命令返回服务器当前被订阅的所有频道。

PUBSUB NUMSUB 子命令接收任意多个频道作为输入参数,并返回这些频道的订阅者数量。

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

 


 

每天学一点,总会有收获。

 

说明:尊重作者知识产权,文中内容参考《Redis设计与实现》,仅在此做学习与大家分享。

 


 

 

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-数据库
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯