《Redis设计与实现》读书笔记(三十二) ——Redis集发布订阅设计与实现

《Redis设计与实现》读书笔记(三十二) ——Redis集发布订阅设计与实现

(原创内容,转载请注明来源,谢谢)

一、概述

redis的发布订阅由publish、subscribe、psubscribe等命令组成。客户端通过subscribe订阅频道,发布端通过publish进行发布。

例如,a、b、c三个客户端都执行了命令subscribe“new.it”,则表示这三个客户端都监听该频道的信息。此时,如果某个客户端执行publish “new.it” “hello”,则a、b、c三个客户端都会收到该消息。

每个客户端都可以订阅多个频道,每个频道也可以给多个客户端订阅,属于多对多关系。

如上图所示,当消息发到news.it频道,则a、c、d三个客户端都会收到消息。

二、频道订阅与退订

1、订阅

当客户端执行subscribe命令,客户端和频道之间就形成订阅的关系,redis将所有频道的订阅关系放在redisServer结构体的pubsub_channels字典中,这个字典的键是被订阅的频道,值是链表,链表里面记录了所有订阅这个频道的客户端。

每当有客户端订阅频道,服务器都会将字典中的频道与客户端关联。如果频道已经有其他订阅者,则该客户端加到链表的末尾;如果频道还没有订阅者,则不存在于pubsub_channels字典,则会新创建一个键值对。

2、退订

unsubscribe命令是退订的命令,客户端执行此命令退订某个频道,则服务器会将键对应的链表的节点删除。另外,如果删除链表的节点后,该频道的键对应的链表是空,表示此时没有客户端定义该频道,则该键也会被删除。

三、模式的订阅与退订

1、订阅模式

模式的订阅与退订保存在redisServer结构体的列表pubsub_patterns中,该list是一个链表,每个节点包含一个pubsub_pattern结构,如下:

         typedef struct pubsubPattern{
                  redisClient *client;
                  robj *pattern;
         }pubsubPattern;

这个结构的pattern记录了订阅的模式,而client记录了定阅该模式的客户端。

当客户端执行psubscribe命令,即订阅某个模式,redis服务器会新建一个pubsubPattern节点,并且将client信息进行记录。

2、退订模式

punsubscribe命令是退订模式的命令。当退订模式,服务器会将客户端的信息从模式对应的pubsubPattern结构体删除。

四、发送消息

redis任一客户端执行publish <channel><message>,表示其发送消息,其会将消息发送给频道订阅者与模式订阅者。

1、发送给频道订阅者

由于pubsub_channels字典记录所有频道的订阅关系,则redis服务器会从频道的字典中,找到channel订阅者的名单,即一个链表,并将消息发送给其中的所有的订阅者。

2、发送给模式订阅者

由于pubsub_patterns是一个链表形式,记录所有的模式订阅者的信息,因此redis会遍历该链表,找到所有与当前channel匹配的模式,并将消息发送给这些模式的客户端。

五、查看订阅信息

pubsub命令可以用于查看频道的订阅情况,其共有三个子命令。

1、pubsubchannels

pubsub channels [pattern]命令用于返回服务器当前被订阅的频道,pattern参数可选,不给定参数,返回当前所有频道;给定参数,返回当前频道中与pattern模式匹配的频道。

该命令是通过遍历pubsub_channels字典,查看所有匹配的频道。

2、pubsubnumsub

pubsub numsub [channel-1 channel-2 …]子命令接收多个频道作为参数,返回这些频道订阅者的数量。

该命令是通过遍历pattern_channels字典,找到需要查阅的频道,并且返回频道对应的链表的长度。如果频道没有被订阅,则返回0。

3、pubsubnumpat

pubsub numpat返回服务器当前被订阅的模式的数量。

该命令是通过返回pubsub_patterns链表的长度来实现的。

六、总结

1、订阅分为频道订阅和模式订阅。服务器在redisServer结构体的字典pubsub_channels中,以键作为频道名称,值是所有订阅该频道的链表;在链表pubsub_patterns中,记录所有被订阅的模式以及对应的客户端信息。

2、频道订阅与退订命令分别是subscribe、unsubscribe,模式订阅与退订命令分别是psubscribe、punsubscribe,发布命令是publish。

3、publish命令通过访问pubsub_channel来找到频道订阅者,通过pubsub_patterns找到模式订阅者,并且发送消息。

——written by linhxx 2017.09.26

原文发布于微信公众号 - 决胜机器学习(phpthinker)

原文发表时间:2017-09-26

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏北京马哥教育

用Python+MySQL实现2017年web日志分析报告

日志分析在web系统中故障排查、性能分析方面有着非常重要的作用。目前,开源的ELK系统是成熟且功能强大的选择。但是部署及学习成本亦然不低,这里我实现了一个方法上...

3197
来自专栏蓝天

linux的free命令详解-内存是拿来用的不是拿来看的

我告诉有朋友我一直用linux.他问我了一下我为什么linux使用的内存这么高.他讲他1G的内在free才232M.讲win xp才用200M的样子.

561
来自专栏磨磨谈

Ceph部署mon出现0.0.0.0地址问题定位

最近在群里两次看到出现mon地址不对的问题,都是显示0.0.0.0:0地址,如下所示:

651
来自专栏程序人生

再谈 API 的撰写 - 架构

在 再谈 API 的撰写 - 总览 里我们谈到了做一个 API 系统的基本思路和一些组件的选型,今天谈谈架构。 部署 首先要考虑的架构是部署的架构。部署的方案往...

3507
来自专栏腾讯技术工程官方号的专栏

高并发性能调试经验分享(上)

4月份的时候看到一道面试题,据说是腾讯校招面试官提的:在多线程和高并发环境下,如果有一个平均运行一百万次才出现一次的bug,你如何调试这个bug?遗憾的是知乎很...

6312
来自专栏java一日一条

服务端 I/O 性能大比拼:Node、PHP、Java 和 Go

理解应用程序的输入/输出(I/O)模型,意味着其在计划处理负载与残酷的实际使用场景之间的差异。若应用程序比较小,也没有服务于很高的负载,也许它影响甚微。但随着应...

474
来自专栏微信终端开发团队的专栏

基于TLS1.3的微信安全通信协议mmtls介绍

编者的话:近年来网络安全事件层出不穷,确保亿万用户的安全隐私是我们微信义不容辞的责任。当然,我们更要保证用户稳定、快速的聊天体验,所以我们有了mmtls。文章干...

53210
来自专栏编程

前端性能优化指南——网络篇

网络,在我们开发的页面的访问过程中,是最开始的一个环节,同时,也是一个非常重要的环节。 当我们在提及网络优化的时候,我们都会说些什么呢。 事实上来讲,如果可以话...

1899
来自专栏Golang语言社区

为Go语言GC正名-2秒到1毫秒的演变史

下面我们会介绍https://www.twitch.tv视频直播网站在使用Go过程中的GC耗时演变史。 我们是视频直播系统且拥有数百万的在线用户,消息和聊天...

3175
来自专栏blackheart的专栏

[解读REST] 6.REST的应用经验以及教训

衔接上文[解读REST] 5.Web的需求 & 推导REST,上文根据Web的需求推导出了REST架构风格,以及REST的详细描述和解释。自从1994年以来,R...

22010

扫描关注云+社区