Nodejs套接字写入所有连接

Question

我在节点中有一个套接字服务器。当它恢复一条新消息时，它会将其写入套接字。但它已从中恢复，写入相应的套接字，而不是所有连接。

服务器.js

var server = net.createServer(function(sock){

    console.log('new client connected');

    sock.on('data', function(data) {
        console.log('Server received');

        // ** NOT sending to all clients **
        sock.write('broadcasting to others...');

    });

}); 

客户端.js

var client = new net.Socket();

client.connect(PORT, HOST, function() {
    console.log('Client connected to: ' + HOST + ':' + PORT);
    // Write a message to the socket as soon as the client is connected, the server will receive it as message from the client 
    client.write('Client is connected!!');

});

client.on('data', function(data) {    
    console.log('Client received: ' + data);
});

如何向所有其他客户端广播一条客户端消息？

Answer 1

按照我的建议使用Set 来跟踪所有连接的套接字，这是实现它的一种方法。此实现通过监听connect 事件和end 事件来维护Set 作为连接来来去去。

此实现还支持向所有连接的套接字发送所需的功能，触发事件的套接字除外（我认为这是您的情况所需要的）：

// Set of all currently connected sockets
const connectedSockets = new Set();

// broadcast to all connected sockets except one
connectedSockets.broadcast = function(data, except) {
    for (let sock of this) {
        if (sock !== except) {
            sock.write(data);
        }
    }
}

const server = net.createServer(function(sock){
    console.log('new client connected');
    connectedSockets.add(sock);

    sock.on('end', function() {
        connectedSockets.delete(sock);
    });

    sock.on('data', function(data) {
        console.log('Server received');

        connectedSockets.broadcast(data, sock);
    });

}); 

Answer 2

我相信当每个客户端建立与服务器的连接时，您始终可以将它们的套接字引用保存在一个数组中。要广播，只需循环数组并使用执行write()

var clients = [];
var server = net.createServer(function(sock){

   console.log('new client connected');
   clients.push(sock);

   sock.on('data', function(data) {
        console.log('Server received');
        for(var i = 0; i < clients.length; i++) clients[i].write('broadcasting..');
   });

});

或者，如果您对服务器和客户端都有控制权，我认为最好使用websocket 或socket.io，因为它提供广播功能。