Node.js - Socket.io io.emit() 什么都不做

Question

我的 socket.io 应用程序有问题，io.emit() 和 io.sockets.emit() 直接不起作用，它们什么也不做，也没有返回错误。

我在这里提供了我可以在这里制作的代码的最简化版本。

服务器：

var server = require('http').createServer();
var io = require('socket.io')(server);
var port = 8080;

io.use(function(socket, next){
  next();
});

io.of('/projects/test_cases').on('connection', function(socket){
  io.sockets.emit("test_case_changed", "test1"); // Doesn't do anything
  io.emit("test_case_changed", "test2"); // Doesn't do anything
  socket.emit("test_case_changed", "test3"); // Works
  io.to(socket.id).emit("test_case_changed", "test4"); // doesn't work

});

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

  });
});

server.listen(port, function(){
  console.log('listening on *:' + port);
  setTimeout(function(){
    io.sockets.emit("test_case_changed", "test"); // does nothing
    io.emit("test_case_changed", "test"); // does nothing
  }, 3000);
});

客户：

<script>
    var socket = io('http://localhost:8080/projects/test_cases');
    socket.on('error', function (reason){
      console.error('Unable to connect Socket.IO', reason);
    });
    socket.on('connect', function (){
      console.info('Connected');
    });
    socket.on("test_case_changed", function (data){
      console.log(data);
    });
</script>

如您所见，在客户端 test1、test2、test3 和 test4 都应该在客户端打印，但只有 test3 打印。

此外，如果在 on('connection') 方法中添加以下内容

  console.log("Pre join: ", socket.rooms); 
  socket.join("room1"); // Doesn't work
  console.log("After join: ", socket.rooms); 

那也行不通。IE 你不能用那种方法让套接字加入一个房间。

Answer 1

套接字属于某个命名空间。

通过编写，io.of('/projects/test_cases').on('connection', function(socket){});您将所有连接的套接字都放入“/projects/test_cases”命名空间。

通过写作

 io.sockets.emit("test_case_changed", "test1");
 io.emit("test_case_changed", "test2");

你发送到一个不同于“/projects/test_cases”的默认命名空间“/”

你可以很容易地看到使用的命名空间：

console.log(io.sockets.name) // '/'
console.log(io.of('/projects/test_cases').name) // '/projects/test_cases'

您可能需要明确指定套接字的命名空间以向其发出消息

io.of('/projects/test_cases').emit("test_case_changed", "test1");

UPD： 至于问题的第二部分，您可能想知道这join是一个异步操作。这就是为什么room1不socket.rooms正确的下一行代码。当插座在房间内时，您可能会使用以下几行收到通知：

socket.join("room1", function(err){
    console.log("After join: ", socket.rooms);
});