Websocket客户端覆盖彼此的连接

Question

我正在尝试用Nodejs express服务器和LitComponent客户端实现一个服务器客户端示例。当运行1:1配置时，服务器和客户端之间的通信可以完美地工作。当启动第二个客户端时，数据传输停止工作，只有新客户端接收数据。

所有客户端都在localhost:3001上运行，服务器在localhost:3000上运行。

如何向多个客户端连续发送数据？

客户端

import short from 'short-uuid';
import { io } from 'socket.io-client';
...
constructor() {
super();
//Generate app id
this.app_id = short.generate();
console.log('# App-ID: ' + this.app_id);
this.socket = io('ws://localhost:3000', { forceNew: true });
this.socket.on('connect', () => {
this.socket.emit('log', 'App-ID: ' + this.app_id);
});
this.socket.on('data', message => {
this.receiveData(message);
});
this.socket.on('disconnect', function () {
console.log('# Socket disconnected');
});
}
...

服务器

var app = require("express")();
const express = require("express");
var http = require("http").createServer(app);
var io = require("socket.io")(http, {
cors: {
origin: "http://localhost:3001",
methods: ["GET", "POST"],
},
});
let connectCounter = 0;
let sock;
io.on("connect", (socket) => {
sock = socket;
console.log("# " + socket.id + " | ■ App connected");
connectCounter++;
console.log("# New connection - now have " + connectCounter);
socket.on("disconnect", () => {
connectCounter--;
console.log("# Lost connection - now have " + connectCounter);
});
socket.on("log", (message) => {
console.log("# " + socket.id + " | " + message);
});
});
function sendData(msg) {
sock.emit("data", msg);
}
...
http.listen(3000, () => {
console.log("# HTTP: listening on *:3000");
});

Answer 1

在服务器端有：

let sock;
io.on("connect", (socket) => {
sock = socket;
...
});
function sendData(msg) {
sock.emit("data", msg);
}

你能看到这里有问题吗？每次新用户连接时，您都会将其设置为全局sock，然后只发送到该套接字。相反，您需要的是将所有套接字保存在某个集合中，类似于以下内容：

let sockets = {};
io.on("connect", (socket) => {
sockets[socket.id] = socket;
...
socket.on("disconnect", () => {
...
delete sockets[socket.id];
});
});
function sendData(msg) {
for (var socket_id in sockets) {
sockets[socket_id].emit("data", msg);
}
}

AFAIK socket.io已经为您做到了这一点，但我不记得具体的属性(我已经有一段时间没有处理socket.io了(，所以您必须阅读api。