综述
redis的消息是靠发布订阅实现的。
但这个消息和消息中间件不太一样，比消息中间件简易得多。没有队列，生产者消费者再启动的时候，会把消息注册到频道这个数据结构中，消息发送后，根据这个数据结构找到订阅该消息的订阅者，直接就给订阅者发送过去。
事就是这么个事，下面看细节。
频道的订阅与退订
当客户端执行subcribe命令订阅某个或某些频道的时候，这个客户端与被订阅频道之间就建立起了一种订阅关系。
redis将这个关系保存在服务器状态这个数据结构中。
struct redisServer {
// ...
// 保存所有频道的订阅关系，是一个字典
// key 为 频道名
// value 为 链表 链表里记录所有订阅这个频道的客户端
dict *pubsub_channels;
// ...
}
频道.png
订阅频道
subscribe <channel>
退订频道
unsbscribe <channel>
订阅与退订都是对 pubsub_channels 这个字典和链表的增删操作。
模式的订阅与退订
什么是模式。简单理解就是带正则表达式的频道，比如
news.* --> news.it、news.sport 都可以订阅到
news.[ie]t --> news.it、news.et 都可以订阅到
模式的订阅与退订也在redisServer中
struct redisServer {
// ...
// 保存所有模式的订阅关系，是一个链表
// 链表的每一项为pubsubPattern结构体
list *pubsub_patterns;
// ...
}
typedef struct pubsubPattern {
// 订阅模式的客户端
redisClient *client;
// 被订阅的模式
robj *pattern;
} pubsubPattern;
模式.png
订阅模式
psubscribe <pattern>
退订模式
punsbscribe <pattern>
订阅与退订都是对 pubsub_patterns 这个链表的增删操作。
发送消息
当redis客户端执行
publis <channel> <message>
publis "news.it" "hello"
将消息发送给频道的所有订阅者。用channel这个key到pubsub_channels这个字典中查询所有订阅的list，遍历list发送message。
如果有一个或多个模式pattern与频道相匹配，那么将消息发送给pattern模式的订阅者。遍历pubsub_patterns这个链表，匹配规则，发送message。
