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设计与实现》，仅在此作学习与你们分享。

 

---