redis源码阅读笔记(12)——发布与订阅

苏泽湛

1. 发布/订阅
发布/订阅（Publish/subscribe 或pub/sub）是一种消息范式，消息的发送者（发布者）不是计划发送其消息给特定的接收者（订阅者）。而是发布的消息分为不同的类别，而不需要知道什么样的订阅者订阅。订阅者对一个或多个类别表达兴趣，于是只接收感兴趣的消息，而不需要知道什么样的发布者发布的消息。
这种发布者和订阅者的解耦可以允许更好的可扩展性和更为动态的网络拓扑.
如果对redis的发布订阅功能还不了解的话，可以参考官方文档翻译版
Redis 发布/订阅（Pub/Sub）
2. 数据结构
redis里面发布订阅相对来说是独立的一个模块，代码也比较简单。
先看数据结构定义。

struct redisServer {
dict *pubsub_channels;  //订阅频道哈希表
list *pubsub_patterns;  //订阅模式链表
}；
/*
* 记录订阅模式的结构
*/
typedef struct pubsubPattern {
// 订阅模式的客户端
redisClient *client;
// 被订阅的模式
robj *pattern;
} pubsubPattern;

typedef struct redisClient {
dict *pubsub_channels;  //这个字典记录了客户端所有订阅的频道
list *pubsub_patterns;  //这个链表记录了客户端所有订阅的模式
} redisClient;

可以看到服务端和客户端都记录了订阅的频道、模式。
然后看一下订阅频道和订阅模式的代码
pubsub.c中

int pubsubSubscribeChannel(redisClient *c, robj *channel) {
dictEntry *de;
if (dictAdd(c->pubsub_channels,channel,NULL) == DICT_OK) { //首先加入客户端的哈希表里
de = dictFind(server.pubsub_channels,channel); //找服务端的哈希表
if (de == NULL) {
clients = listCreate();
dictAdd(server.pubsub_channels,channel,clients);
incrRefCount(channel);
} else {
clients = dictGetVal(de);
}
// 将客户端添加到链表的末尾
listAddNodeTail(clients,c);
}
}
int pubsubSubscribePattern(redisClient *c, robj *pattern) {
if (listSearchKey(c->pubsub_patterns,pattern) == NULL) {
pubsubPattern *pat;
// 将 pattern 添加到客户端的链表中
listAddNodeTail(c->pubsub_patterns,pattern);
// 创建并设置新的 pubsubPattern 结构
pat = zmalloc(sizeof(*pat));
pat->pattern = getDecodedObject(pattern);
pat->client = c;

// 将 pattern 添加到服务端的链表中
listAddNodeTail(server.pubsub_patterns,pat);
}
}

代码是自解释的，清晰明了。
3. 性能问题疑惑
3.1 关于退订所有消息，
pubsubUnsubscribeAllChannels
pubsubUnsubscribeAllPatterns
作者用了一个迭代来遍历哈希表，但是迭代里面又重新用key来查哈希表，这个其实有性能问题。这个问题和java里面的iterate map一样，是个经常会犯的错误。
3.2 订阅模式只是用了一个链表，没有用哈希表，如果模式多了性能会有大问题。
可能作者认为订阅模式和订阅频道不会很多，所以这里的编码显得不那么精雕细刻。当然这部分代码改起来也是很简单的，如果发现性能问题了随时可以改。
4. 模式匹配
util.c里面自己实现了一个glob匹配，又不得不惊叹用C语言编程太亲力亲为了。

/* Glob-style pattern matching. */
int stringmatchlen(const char *pattern, int patternLen,
const char *string, int stringLen, int nocase)
{
}