io.of('namespace').emit('event', message) 不适用于 socket.io 中的命名空间

Question

我有一个这样的应用程序：

io.of('/hello').on('connection', function(socket) {
    socket.emit('world', {});
});

app.post('/', function *(next) {
    console.log("At here......");
    var pushMessage = (yield parse.json(this));
    console.log(pushMessage);
    if(flag !== 0) {
//        io.of('/hello/').emit('world', pushMessage);
        io.sockets.emit('world', pushMessage);
    } else {
        console.log("Do Nothing");
    }
});

它接收一个 http 请求并发出一个事件。当我使用 io.sockets.emit 时它运行良好，但是当我使用 'io.of('hello').emit' 指定命名空间时它不起作用，为什么？

我的客户端是这样的：

var socket = io.connect('http://localhost:3000', {
  'reconnection delay': 100,
  'reconnection limit': 100,
  'max reconnection attempts': 10
});
//server side use io.sockets.emit
socket.on('world', function(data) {
  alert(data.a);
});

//if server side use io.of('/hello/').emit
//socket.of('/hello/').on('world', function(data) {
//  alert(data.a);
//});

Answer 1

您的代码或多或少都很好，但您位于不同的命名空间。

io.sockets.emit() 向当前通过套接字连接到您的服务器的每个人广播。这就是它起作用的原因。从技术上讲，这是因为这是 io.of('').emit() 的“快捷方式”（'' 是命名空间）。

假设您要使用 /hello 命名空间，这就是您必须在客户端上执行的操作：

var socket = io.connect('http://localhost:3000/hello'); // your namespace is /hello

在服务器上，您首先必须侦听该命名空间上的连接：

io.of('/hello').on('connection', function(socket) {
  socket.emit('world', { a: 'hi world' });
});

然后：

io.of('/hello').emit('something');

您可能想看看这些：socket.io: How to use 和 socket.io rooms on GitHub

### 更新###

我做了一个小测试：

客户：

$('document').ready(function() {
  var socket = io.connect("localhost:3000/hello");

  socket.on('hello', function() {
    console.log('hello received');
  });

  var data = {};
  data.title = "title";
  data.message = "message";

  setTimeout(function() {
    $.ajax({
      type: 'POST',
      data: JSON.stringify(data),
      contentType: 'application/json',
      url: 'http://localhost:3000/hello',
      success: function(data) {
        console.log('success');
        console.log(JSON.stringify(data));
      }
    });
   }, 2000);
});

服务器：

io.of('/hello').on('connection', function() {
  console.log("client connected");
});

app.post('/hello', function(req, res) {
  io.of('/hello').emit('hello');
});

... 它奏效了。我从here 复制了jquery-ajax 代码。