1

我正在使用 Node.js 编程的 Websocket 服务器,我计划向超过 20,000 个用户发送多播消息。该消息将每隔一秒发送一次,但是我担心 Node.js 服务器的性能。

我了解 Node.js 异步工作并根据需要创建和销毁线程,但我不确定它的效率。理想情况下,我希望以 5 毫秒的平均延迟发送消息。

目前,我通过运行所有已连接客户端的 for 循环向所有用户发送消息,如下所示:

function StartBroadcastMessage()
{
  console.log("broadcasting socket data to client...!");

  for(var i=0;i < clientsWithEvents.length;i++){ //Runs through all the clients

      client = clientsWithEvents[i];
      if(client.eventid.toLowerCase() == serverEventName.toLowerCase()) //Checks to see if the Client Event names and server names are the same
        client.connection.sendUTF(GetEventSocketFeed(client.eventid)); //Sends out event data to that particular client
    }

  timeoutId = setTimeout(StartBroadcastMessage,2*1000);
}

这是以低延迟发送多播消息的有效方法,还是有更好的方法?

此外,是否有一种有效的方法可以在模拟连接到 Websocket 服务器的许多设备的服务器上执行负载测试?(到目前为止,我已经找到了这个 Node 应用程序https://github.com/qarea/websockets-stress-test

4

1 回答 1

1

您可以使用 socket.io 来广播消息。

var io = require('socket.io').listen(80);

io.sockets.on('connection', function (socket) {
  socket.broadcast.emit('user connected');
});

这将避免向客户端发送单个消息时的延迟(迭代所有套接字对象和格式化消息)。

于 2013-06-15T19:45:49.227 回答