1

ioredis (v3.2.2) 似乎没有在听我的 Redis 发布/订阅事件，我不知道为什么

我正在启动一个侦听传入消息的服务器，如下所示：

var Redis = require('ioredis');

redis.monitor(function (err, monitor) {
  monitor.on('monitor', function (time, args, source, database) {
    console.log(time + ": " + util.inspect(args));
  });
});

redis.psubscribe('*', function(err, count) {
  console.log("Listening to " + count + " channels.");
  if(err){
    console.log(err);
  }
});

// republish any data received
redis.on('pmessage', function(subscribed, channel, message) {
  console.log("pmessage: " + message);
});

当我运行上述内容时，日志输出显示：

Listening to 1 channels.

当我将消息发布到 redis 服务器的队列中时，日志输出显示：

1531403083.031496: [ 'SELECT', '0' ]
1531403083.036594: [ 'RPUSH',
  'queues:myqueuename',
  '{## JSON message body ##}' ]

所以：我清楚地连接到服务器并接收数据，但我不明白：

  1. 为什么monitor回调没有记录 PSUBSCRIBE 或 PUBLISH 事件，这可能是为什么：
  2. pmessage回调函数没有被触发

有什么建议么？

4

1 回答 1

0

解决了。我忘记启动队列侦听器服务，如此处所述：https ://laravel.com/docs/5.1/events#broadcasting-events

于 2018-07-12T14:41:27.320 回答