Jak usunąć Redis na słuchaczy „komunikat”

Question

Typowe Redis przykład czat pójdzie coś takiego (patrz https://github.com/emrahayanoglu/Socket.io-Redis-RealTime-Chat-Example/blob/master/chatServer.js tylko dla jednego takiego przykładu):

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(); 
    }); 
}); 

Jednak problem jest to, że gdy client ' disconnect ", słuchacz redis1.on('message',FUNC(){}) jest nadal podłączony. Konsola będzie kontynuować drukowanie message. Jeśli ktoś miałby przejrzeć listę uczestników wydarzenia pod numerem redis1, nadal mogliby znaleźć anonimową funkcję nasłuchującą.

Problem polega na tym, że nie ma funkcji redis1.off(...). A więc, w jaki sposób jeden odzwyczaić/wypisać/usunąć/usunąć słuchacza wiadomości redis?

Uwaga: Nie można po prostu wykonać polecenia redis1.end(), ponieważ spowoduje to przerwanie połączenia redis dla innych użytkowników połączonych z siecią.

Answer 1

Jedyne rozwiązanie, które znalazłem podczas odtwarzania w węźle REPL, to nie używać funkcji subskrypcji redis.on(). Zamiast tego należy użyć funkcji redis.addListener() i redis.removeListener(). Ponadto nie można używać funkcji anonimowych jako wywołań zwrotnych zdarzeń. Jeden mógłby zrobić coś takiego:

var callback = function(channel, message){ 

}; 

redis1.addListener('message', callback); 

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