node.js - 如何在 'message'侦听器上删除Redis

一个典型的Redis聊天示例将如下所示(仅一个示例参见https://github.com/emrahayanoglu/Socket.io-Redis-RealTime-Chat-Example/blob/master/chatServer.js):

io.sockets.on('connection', function (client) { //websocket connection

  redis1.subscribe("chat");

  redis1.on("message", function(channel, message) {
      console.log(message);
      client.send(message);
  });

  client.on('message', function(msg) {
    redis2.publish("chat",msg.message);
  });

  client.on('disconnect', function() {
      redis1.quit();
  });
});

但是，这里的问题是，当client'disconnect'断开连接时，redis1.on('message',FUNC(){})侦听器仍然处于连接状态。控制台将继续打印出message。如果要检查redis1的事件列表，他们仍然会发现匿名函数正在侦听。

问题是没有redis1.off(...)函数。因此，如何取消绑定(bind)/取消订阅/删除/删除Redis消息侦听器？

注意:一个人不能只做redis1.end()，因为这样会断开其他websocket连接的用户的redis连接。

最佳答案

通过在节点REPL中玩耍找到的唯一解决方案是不使用redis.on()函数进行订阅。相反，应该使用redis.addListener()和redis.removeListener()函数。另外，一定不能将匿名函数用作事件回调。
一个人可以做这样的事情:

var callback = function(channel, message){

};

redis1.addListener('message', callback);

client.on('disconnect', function(){
  redis1.removeListener('message', callback);
})