node.js - Socket.io + Redis - 客户端正在加入彼此的 "private"房间

Question

我刚刚开始使用 Socket.io 和 Redis 进行发布/订阅消息传递，它非常棒。我的应用程序的一个重要特性是服务器需要能够向一个房间的所有订阅者广播消息，并且还需要选择该房间中的 1 个订阅者并向他们窄播一条消息。目前，该订阅者是随机选择的。根据阅读 socket.io 的文档，我认为我可以做到这一点。

但是，我遇到了一些我不明白的事情。在 Socket.io 的默认房间文档 ( https://socket.io/docs/rooms-and-namespaces/#default-room ) 中，他们说每个套接字会自动加入一个以其套接字 ID 命名的房间。这看起来可以解决我的窄播需求——查看连接到我的“大”房间的客户端 ID 列表，随机选择一个，然后向与所选 ID 同名的房间发送一条消息。

但是，它不起作用，因为出于某种原因，所有客户端都加入了彼此的默认房间。我在我的代码中没有看到任何异常，但我的“窄播”消息将发送给所有客户端。

这是我的服务器端代码:

var io = require('socket.io');
var redisAdapter = require('socket.io-redis');
var server = io();

server.adapter(redisAdapter({ host: 'localhost', port: 6379 }))

server.on('connect', (socket) => {
  console.log(`${socket.id} connected!`);
  socket.join('new');
  server.emit('welcome', `Please give a warm welcome to ${socket.id}!`);
  server.to(socket.id).emit('private', 'Just between you and me, I think you are going to like it here');
});

server.listen(3000);

setInterval(whisperAtRandom, 2000);

function whisperAtRandom() {
  server.in('new').adapter.clients((err, clients) => {
    if (err) throw err;

    console.log('Clients on channel "new": ', clients);
    chosenOne = clients[Math.floor(Math.random()*clients.length)];
    console.log(`Whispering to ${chosenOne}`);
    server.to(chosenOne).emit('private', { message: `Psssst... hey there ${chosenOne}`});
    server.in(chosenOne).adapter.clients((err, clients) => {
      console.log(`Clients in ${chosenOne}: ${clients}`)
    })
  });
}

它启动服务器，监听端口 3000，然后每 2 秒向"new"房间中的随机客户端发送一条消息。它还会注销连接到"new"房间和“”房间的客户端列表。

这是客户端代码:

var sock = require('socket.io-client')('http://localhost:3000');

sock.connect();

sock.on('update', (data) => {
  console.log('Updating...');
  console.log(data);
});

sock.on('new', (data) => {
  console.log(`${sock.id} accepting request for new`);
  console.log(data.message);
});

sock.on('welcome', (data) => {
  console.log('A new challenger enters the ring');
  console.log(data);
});

sock.on('private', (data) => {
  console.log(`A private message for me, ${sock.id}???`);
  console.log(data);
});

我的问题是我所有的客户都连接到彼此的“”房间。这是我的日志中的示例:

0|socket-s | Clients on channel "new":  [ 'dJaoZd6amTfdQy5NAAAA', 'bwG1yTT46dr5R_G6AAAB' ]
0|socket-s | Whispering to bwG1yTT46dr5R_G6AAAB
2|socket-c | A private message for me, dJaoZd6amTfdQy5NAAAA???
2|socket-c | Psssst... hey there bwG1yTT46dr5R_G6AAAB
1|socket-c | A private message for me, bwG1yTT46dr5R_G6AAAB???
1|socket-c | Psssst... hey there bwG1yTT46dr5R_G6AAAB
0|socket-s | Clients in bwG1yTT46dr5R_G6AAAB: dJaoZd6amTfdQy5NAAAA,bwG1yTT46dr5R_G6AAAB

您可以看到“私有(private)”消息被两个客户端接收，dJaoZ... 和 bwG1y...，并且两个客户端都连接到bwG1y... 的默认房间。

这是为什么？这与我的两个客户端都在同一台机器上运行(具有不同的 Node 进程)这一事实有关吗？我在 Socket.io 的文档中遗漏了什么吗？感谢您的帮助!

PS -- 更让人困惑的是，发生在 server.on('connect', ... 中的私有(private)消息传递有效!每个客户端都收到“就在你我之间...... ."仅在他们连接到服务器后立即发送一次消息。

Answer 1

您的主要问题可能是由 whisperAtRandom 函数中的 server.to 引起的，使用套接字而不是服务器来发送私有(private)消息:

socket.to(chosenOne).emit('private', { message: `Psssst... hey there ${chosenOne}`});

要回答您的其他问题，请尝试更改这些:

server.emit('welcome', `Please give a warm welcome to ${socket.id}!`);
server.to(socket.id).emit('private', 'Just between you and me, I think you are going to like it here');

收件人:

socket.broadcast.emit('welcome', `Please give a warm welcome to ${socket.id}!`);
socket.emit('private', 'Just between you and me, I think you are going to like it here');

查看我的 Socket.IO 备忘单:

// Socket.IO Cheatsheet

// Add socket to room
socket.join('some room');

// Remove socket from room
socket.leave('some room');

// Send to current client
socket.emit('message', 'this is a test');

// Send to all clients include sender
io.sockets.emit('message', 'this is a test');

// Send to all clients except sender
socket.broadcast.emit('message', 'this is a test');

// Send to all clients in 'game' room(channel) except sender
socket.broadcast.to('game').emit('message', 'this is a test');

// Send to all clients in 'game' room(channel) include sender
io.sockets.in('game').emit('message', 'this is a test');

// sending to individual socket id
socket.to(socketId).emit('hey', 'I just met you');