Node.js WebSocket 广播

Question

我在 Node.js 和 WebSockets 中使用 ws library 我正在从库示例中尝试这个示例：

var sys = require("sys"),
    ws = require("./ws");

  ws.createServer(function (websocket) {
    websocket.addListener("connect", function (resource) { 
      // emitted after handshake
      sys.debug("connect: " + resource);

      // server closes connection after 10s, will also get "close" event
      setTimeout(websocket.end, 10 * 1000); 
    }).addListener("data", function (data) { 
      // handle incoming data
      sys.debug(data);

      // send data to client
      websocket.write("Thanks!");
    }).addListener("close", function () { 
      // emitted when server or client closes connection
      sys.debug("close");
    });
  }).listen(8080);

一切正常。它可以工作，但运行 3 个客户端，例如，并发送“你好！”从一个将使服务器只回复“谢谢！”发送给发送消息的客户端，而不是发送给所有客户端。

如何广播“谢谢！”当有人发送“Hello！”时向所有连接的客户端发送？

谢谢！

Answer 1

如果您想发送给所有客户，您必须跟踪他们。这是一个示例：

var sys = require("sys"),
    ws = require("./ws");

// # Keep track of all our clients
var clients = [];

  ws.createServer(function (websocket) {
    websocket.addListener("connect", function (resource) { 
      // emitted after handshake
      sys.debug("connect: " + resource);

      // # Add to our list of clients
      clients.push(websocket);

      // server closes connection after 10s, will also get "close" event
      // setTimeout(websocket.end, 10 * 1000); 
    }).addListener("data", function (data) { 
      // handle incoming data
      sys.debug(data);

      // send data to client
      // # Write out to all our clients
      for(var i = 0; i < clients.length; i++) {
    clients[i].write("Thanks!");
      }
    }).addListener("close", function () { 
      // emitted when server or client closes connection
      sys.debug("close");
      for(var i = 0; i < clients.length; i++) {
        // # Remove from our connections list so we don't send
        // # to a dead socket
    if(clients[i] == websocket) {
      clients.splice(i);
      break;
    }
      }
    });
  }).listen(8080);

我能够让它向所有客户广播，但它并未针对所有情况进行严格测试。不过，一般概念应该可以帮助您入门。

编辑：顺便说一句，我不确定 10 秒关闭是为了什么，所以我已将其注释掉。如果您尝试向所有客户端广播，这将毫无用处，因为它们只会不断断开连接。

Answer 2

我建议您使用socket.io。它具有开箱即用的示例网络聊天功能，还提供客户端套接字技术的抽象层（Safari、Chrome、Opera 和 Firefox 支持 WebSocket，但由于 ws-protocol 中的安全漏洞，现在在 Firefox 和 Opera 中禁用)。