Come rimuovere Redis sugli ascoltatori 'messaggio'

Question

Un tipico Redis Chat esempio andrà qualcosa di simile (vedi https://github.com/emrahayanoglu/Socket.io-Redis-RealTime-Chat-Example/blob/master/chatServer.js per solo un esempio):

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

Tuttavia, il problema qui è che quando un client ' disconnect ', il listener redis1.on('message',FUNC(){}) è ancora collegato. La console continuerà a stampare il numero message. Se si dovessero ispezionare i listener di eventi di redis1, troverebbero comunque la funzione anonima in ascolto.

Il problema è che non esiste la funzione redis1.off(...). Quindi, come si fa a non vincolare/annullare l'iscrizione/eliminare/rimuovere l'ascoltatore del messaggio redis?

Nota: non è possibile eseguire semplicemente redis1.end(), poiché ciò interromperà la connessione redis per altri utenti connessi a Websocket.

Answer 1

L'unica soluzione che ho trovato giocando nel nodo REPL è di non utilizzare la funzione redis.on() per iscriversi. Invece, si dovrebbero usare le funzioni redis.addListener() e redis.removeListener(). Inoltre, non è necessario utilizzare le funzioni anonime come callback di eventi. si potrebbe fare qualcosa di simile:

var callback = function(channel, message){ 

}; 

redis1.addListener('message', callback); 

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