Cómo eliminar Redis en los oyentes 'mensaje'

Question

A Redis típicos, como charla será algo parecido a esto (ver https://github.com/emrahayanoglu/Socket.io-Redis-RealTime-Chat-Example/blob/master/chatServer.js por sólo un ejemplo de ello):

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

Sin embargo, el problema aquí es que cuando un client ' desconectar ', el oyente redis1.on('message',FUNC(){}) aún está conectado. La consola continuará imprimiendo el message. Si uno fuera a inspeccionar los listados de eventos de redis1, todavía encontrarían la función anónima escuchando.

El problema es que no hay función redis1.off(...). Entonces, ¿cómo se desenlaza/desuscribe/elimina/elimina el oyente de mensajes redis?

Nota: No se puede hacer simplemente redis1.end(), ya que eso romperá la conexión redis para otros usuarios conectados a la websocket.

Answer 1

La única solución que he encontrado jugando en el nodo REPL es no usar la función redis.on() para suscribirme. En cambio, uno debe usar las funciones redis.addListener() y redis.removeListener(). Además, no se deben usar funciones anónimas como devoluciones de eventos. Se podría hacer algo como esto:

var callback = function(channel, message){ 

}; 

redis1.addListener('message', callback); 

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