redis的发布订阅

什么是发布订阅

所谓发布订阅，就是消息发布者发布消息及消息订阅者接收消息，二者通过某种媒介关联起来。这类似以前的『订报』，当我们订阅了某种报纸后（比如财经报），每当报纸有新的期刊出版后，就会有邮递员给我们送过来。即，只有定了这种报纸才会收到出版社发布的这种新报纸。

上述的『某种报纸』就抽象为频道channel，客户端订阅了某channel后，当发布者通过此channel发布消息时，所有订阅者就会收到该频道发布的消息。

发布和订阅机制

当一个客户端通过 PUBLISH 命令向订阅者发送信息的时候，我们称这个客户端为发布者(publisher)。

而当一个客户端使用 SUBSCRIBE 或者 PSUBSCRIBE命令接收信息的时候，我们称这个客户端为订阅者(subscriber)。

为了解耦发布者(publisher)和订阅者(subscriber)之间的关系，Redis 使用了 channel (频道)作为两者的中介
—— 发布者将信息直接发布给 channel ，而 channel
负责将信息发送给适当的订阅者，发布者和订阅者之间没有相互关系，也不知道对方的存在。

原理

Redis是使用C实现的，通过分析 Redis 源码里的 pubsub.c 文件，了解发布和订阅机制的底层实现，籍此加深对 Redis 的理解。

Redis 通过 PUBLISH 、SUBSCRIBE 和 PSUBSCRIBE 等命令实现发布和订阅功能。

通过 SUBSCRIBE 命令订阅某频道后，redis-server 里维护了一个字典，字典的键就是一个个 channel ，而字典的值则是一个链表，链表中保存了所有订阅这个 channel 的客户端。SUBSCRIBE 命令的关键，就是将客户端添加到给定 channel 的订阅链表中。

通过 PUBLISH 命令向订阅者发送消息，redis-server 会使用给定的频道作为键，在它所维护的 channel 字典中查找记录了订阅这个频道的所有客户端的链表，遍历这个链表，将消息发布给所有订阅者。

安装

npm install ioredis

测试

'use strict';
const Redis = require('ioredis');
const conf = {
    'max_clients': 10,
    'min_clients': 1,
    'port': 6379,
    'host': '127.0.0.1',
    'password': '123',
};
//
(async () => {
    const sub = new Redis(conf);
    const pub = new Redis(conf);

    // 消息推送
    pub.publish('modules', JSON.stringify({
        'key': 'ShortLink2',
        'message': '測試',
    }));

    // 消息接收
    sub.subscribe([ 'modules' ], function(err, count) {
        sub.on('message', function(channel, message) {
            console.log('channel', channel);
            console.log('message', message);
        });
    });
})();

ioredis