在该通道中发布新消息时如何将 Redis 消息发送到客户端

Question

我正在尝试实现一个功能，其中当用户查看页面时，他应该自动订阅该用户独有的 Redis 频道。并且所有发布到该 Redis 通道的消息都应该被客户端接收。

下面是客户端代码，

var socket = io.connect('localhost:5000');

socket.on('connect', function(){
  socket.emit("subscribe",$("#app_id").text());
});

socket.on('message', function(message) {
  $("#lst").append("<li>" + message + "</li>")
});

在 nodejs 服务器上，我有以下代码，

var client = redis.createClient();

io.sockets.on('connection', function (socket) {

  socket.on("subscribe",function(channel){
    client.subscribe(channel);
    socket.join(channel);
  });

  client.on("message", function(channel, message){
    socket.broadcast.to(channel).emit('message', message);
  });
});

当我在两个单独的浏览器中打开客户端页面时，它正确订阅了两个通道以及发布到这些 Redis 通道的消息显示在客户端。但是如果我刷新页面，我得到的消息数量是双倍的，如果我再次刷新，它会加起来。我猜听众会在每次刷新时加起来。

我在 socket.io 连接侦听器中编写了 Redis 侦听器，因为我想将消息发送到套接字。这可能是面临问题的原因。 Dono 该怎么做，因为我需要套接字实例将消息发送到客户端。请帮忙。

Answer 1

正如您已经说过的：在断开连接时删除侦听器。

查看how-to-remove-redis-on-message-listeners 和socket-io-handling-disconnect-event 以进一步阅读。

未经测试的样本

var client = redis.createClient();

io.sockets.on('connection', function (socket) {

  var broadcast = function(channel, message){
    socket.broadcast.to(channel).emit('message', message);
  }

  socket.on("subscribe",function(channel){
    client.subscribe(channel);
    socket.join(channel);
  });

  socket.on('disconnect', function() {
    client.unsubscribe(channel);
    client.removeListener(broadcast)
  })

  client.on("message", broadcast);
});