在 node.js 中监听通道 redis

Question

有这么简单的密码窃听频道萝卜。

redisClient = redis.createClient();
redisDummyPublishClient = redis.createClient();
//redisClient.auth("25c9721b4e579fc5af961f944e23f46f");


//look for connection errors and log
redisClient.on("error", function (err) {
    console.log("error event - " + redisClient.host + ":" + redisClient.port + " - " + err);
});


var channels_active = [];
io.sockets.on('connection', function (socket) {
    redisClient.on('ready', function() {
    redisClient.psubscribe('*');
  });


  function CreateSocketsAccept (eventNameListen, channel, message){
    var obj = { channel : channel, message : message}
      for (i in eventNameListen) {
          io.sockets.in(channel).emit(eventNameListen[i], obj);
       } 
    }

  redisClient.on('pmessage', function(pattern, channel, message) {
    console.log(channel);
    CreateSocketsAccept(channels_active, channel, message);
  });     

});

setInterval(function() {
  var no = Math.floor(Math.random() * 100);
  redisDummyPublishClient.publish('478669c7fa549970e36eac591cdca62e', 'Generated random no ' + no);
}, 5000);

从 PHP 发送数据：

$this->load->library( 'rediska_connector' );
// Other way to publish
$rediska = new Rediska();
$rediska->publish('realtime', 'PHP SENDING');

问题是，为什么不向控制台输出可用频道的名称？

Answer 1

据我所知，您无法在所有频道上收听...

如果你想订阅一个模式，你需要使用psubscribe：

redisClient.psubscribe('*');

而不是监听message 事件，而是监听pmessage 事件：

redisClient.on('pmessage', function(pattern, channel, message) {
  console.log(channel);
});

（感谢@DidierSpezia 纠正我：）

编辑：你不能像这样混合socket.io和Redis客户端，你需要将Redis代码移到socket.io处理程序之外：

// No need for this because it's doing nothing:
// io.sockets.on('connection', function(socket) { ... });

redisClient.on('ready', function() {
  redisClient.psubscribe('*');
});

function CreateSocketsAccept (eventNameListen, channel, message){
  var obj = { channel : channel, message : message}
  for (i in eventNameListen) {
    io.sockets.in(channel).emit(eventNameListen[i], obj);
  }
}

redisClient.on('pmessage', function(pattern, channel, message) {
  console.log(channel);
  CreateSocketsAccept(channels_active, channel, message);
});