Làm thế nào để loại bỏ Redis trên người nghe 'thông báo'

Question

Một Redis điển hình trò chuyện ví dụ sẽ đi một cái gì đó như thế này (xem https://github.com/emrahayanoglu/Socket.io-Redis-RealTime-Chat-Example/blob/master/chatServer.js cho chỉ là một ví dụ như vậy):

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

Tuy nhiên, vấn đề ở đây là khi một client ' ngắt kết nối ', trình nghe redis1.on('message',FUNC(){}) vẫn được đính kèm. Bảng điều khiển sẽ tiếp tục in ra số message. Nếu một người kiểm tra người nghe sự kiện là redis1, họ vẫn sẽ tìm thấy chức năng nghe nặc danh.

Vấn đề là không có hàm redis1.off(...). Vì vậy, làm thế nào để unbind/bỏ đăng ký/xóa/loại bỏ các trình nghe tin nhắn redis?

Lưu ý: Người ta không thể chỉ làm redis1.end(), vì điều đó sẽ phá vỡ kết nối redis đối với người dùng kết nối websocket khác.

Answer 1

Giải pháp duy nhất mà tôi đã tìm thấy bằng cách phát xung quanh trong nút REPL là không sử dụng chức năng redis.on() để đăng ký. Thay vào đó, bạn nên sử dụng các hàm redis.addListener() và redis.removeListener(). Ngoài ra, người ta không được sử dụng các chức năng ẩn danh như gọi lại sự kiện. Người ta có thể làm điều gì đó như thế này:

var callback = function(channel, message){ 

}; 

redis1.addListener('message', callback); 

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