node.js - 使用自定义消息的 Node-Redis psubscribe

Question

我的印象是使用这个库:

https://github.com/mranney/node_redis

可以做这样的事情:

var redis = require('redis');

var pub = redis.createClient();
var sub = redis.createClient();

sub.psubscribe('channel');

sub.on('message from channel', function(){});

pub.publish('channel','a message xyz');

问题是我似乎无法让 sub.on() 接收特定的自定义消息。似乎被解雇的唯一入口点是 sub.on('message') 或 sub.on('pmessage')，但我怎样才能得到 sub.on('my custom message') 被调用？希望这是有道理的。

Answer 1

这就是 Node redis 客户端的工作方式。它保留 message 和 pmessage 发出事件，分别通知您 SUBSCRIBE 和 PSUBSCRIBE 事件。

https://github.com/mranney/node_redis#publish--subscribe

但是，如果您想要一种类似于代码中的语法，您始终可以定义自己的消息格式和 EventEmitter，可能是这样的:

var events = require('events');
var redis = require('redis');
var pub = redis.createClient();
var sub = redis.createClient();

var ee = new events.EventEmitter();

ee.on('aweomseEvent', function() {
    console.log('party!');
});

sub.on('subscribe', function() {
    var message = {
        type: 'aweomseEvent',
        isAwesome: true
    };
    pub.publish('mychannel', JSON.stringify(message));
});

sub.subscribe('mychannel');
sub.on('message', function(channel, message) {
    var deserialized = JSON.parse(message);
    if (deserialized.type) {
        ee.emit(deserialized.type, deserialized);
    }
});