我正在尝试在node.js中使用sockets，我成功了，但我不知道如何在我的代码中区分客户端。与sockets相关的部分是这样的：
var WebSocketServer = require('ws').Server,
wss = new WebSocketServer({port: 8080});
wss.on('connection', function(ws) {
ws.on('message', function(message) {
console.log('received: %s', message);
ws.send(message);
});
ws.send('something');
});
这段代码在我的客户端js上能正常运行。
但我想向特定用户或所有在我的服务器上打开套接字的用户发送消息。
在我的情况下，我作为客户端发送一条消息并收到响应，但其他用户则什么都没有看到。
例如，我希望用户1通过WebSocket向服务器发送一条消息，并向其打开套接字的用户2发送通知。
ws客户端并为每个客户端单独添加自定义属性。此外，您还有一个全局变量wss.clients，可在任何地方使用。请尝试使用至少两个已连接的客户端运行以下代码：var WebSocketServer = require('ws').Server;
var wss = new WebSocketServer({
server: httpsServer
});
wss.getUniqueID = function () {
function s4() {
return Math.floor((1 + Math.random()) * 0x10000).toString(16).substring(1);
}
return s4() + s4() + '-' + s4();
};
wss.on('connection', function connection(ws, req) {
ws.id = wss.getUniqueID();
wss.clients.forEach(function each(client) {
console.log('Client.ID: ' + client.id);
});
});
您还可以直接在客户端连接的 URL 中传递参数：
https://myhost:8080?myCustomParam=1111&myCustomID=2222
在连接函数中，您可以获取这些参数并将它们直接分配给您的 ws 客户端：
wss.on('connection', function connection(ws, req) {
const parameters = url.parse(req.url, true);
ws.uid = wss.getUniqueID();
ws.chatRoom = {uid: parameters.query.myCustomID};
ws.hereMyCustomParameter = parameters.query.myCustomParam;
}
ws 的情况下完成这个操作？当执行 ws.clients.values() 时，有没有一种方法可以从该列表中获取请求？ - Kevin Ghadyanireq.resourceURL。这包括对象的解析查询字符串，因此您只需使用req.resourceURL.query.myCustomParam即可。 - Chris Broskiurl.parse() 中的 url 是一个内置的 Nodejs 模块。为了让这行代码正常工作，请在你的脚本中添加 const url = require('url')。 - A__您可以将用户ID分配给一个名为CLIENTS[]的数组，其中将包含所有用户。您可以按照以下方式直接向所有用户发送消息：
您可以简单地将用户ID分配给一个名为CLIENTS[]的数组，其中将包含所有用户。您可以按照以下方式直接向所有用户发送消息：
var WebSocketServer = require('ws').Server,
wss = new WebSocketServer({port: 8080}),
CLIENTS=[];
wss.on('connection', function(ws) {
CLIENTS.push(ws);
ws.on('message', function(message) {
console.log('received: %s', message);
sendAll(message);
});
ws.send("NEW USER JOINED");
});
function sendAll (message) {
for (var i=0; i<CLIENTS.length; i++) {
CLIENTS[i].send("Message: " + message);
}
}
您可以使用请求头 'sec-websocket-key'
wss.on('connection', (ws, req) => {
ws.id = req.headers['sec-websocket-key'];
//statements...
});
这个 Worlize 服务器的代码片段真的对我帮助很大。即使你正在使用 ws，这段代码也应该很容易适应。我在这里选择了重要的部分：
// initialization
var connections = {};
var connectionIDCounter = 0;
// when handling a new connection
connection.id = connectionIDCounter ++;
connections[connection.id] = connection;
// in your case you would rewrite these 2 lines as
ws.id = connectionIDCounter ++;
connections[ws.id] = ws;
// when a connection is closed
delete connections[connection.id];
// in your case you would rewrite this line as
delete connections[ws.id];
for in循环来广播，而不是标准的for循环，因为（关联）数组中存在“空洞”。 - Tobiqvar WebSocketServer = require('ws').Server,
wss = new WebSocketServer({host:'xxxx',port:xxxx}),
users = [];
wss.broadcast = function broadcast(data) {
wss.clients.forEach(function each(client) {
client.send(data);
});
};
稍后在您的代码中，您可以使用wss.broadcast(message)向所有人发送消息。要向个人用户发送私信，我执行以下操作：
(1) 在我发送到服务器的消息中包含用户名 (2) 然后，在onMessage中，我将带有该用户名的WebSocket保存在数组中，稍后通过用户名检索它：
wss.on('connection', function(ws) {
ws.on('message', function(message) {
users[message.userName] = ws;
(3) 要发送给特定的用户，您可以执行users[userName].send(message);。
var clientID = ws._socket._handle.fd;
当我打开一个新的浏览器选项卡时，我得到了不同的数字。
第一个选项卡显示11，下一个则显示12。
您可以检查连接对象。每个连接的客户端都有内置的标识; 您可以在此处找到：
let id=ws._ultron.id;
console.log(id);
ultron已被移除作为websockets/ws的依赖项。当使用这些（或更高版本）时，ws._ultron将不再存在。 - Jochem Schulenklopper这里的一个可能的解决方案是，在用户ID前附加设备ID，这样我们就可以区分在不同设备上使用相同用户ID的多个用户。
ws://xxxxxxx:9000/userID/<<deviceId>>
使用全局计数变量，并为每个新连接分配其值：
const wss = new WebSocket.Server({server});
let count_clients = 0;
wss.on('connection', function connection(ws){
ws.id=count_clients++;
console.log(`new connection, ws.id=${ws.id}, ${ws._socket.remoteAddress}:${ws._socket.remotePort} #clients=${wss.clients.size}`);
ws.on('close', req => {console.log(`disconnected, ws.id=${ws.id}, ${ws._socket.remoteAddress}:${ws._socket.remotePort} #clients=${wss.clients.size}`);});
...
* on connect, server generate an unique id (e.g uuid) for the connection,
* save it in memory, (e.g as key of map),
* send back to client in response,
*
*
* client save the id, on each request will also send the id as part of request data,
* then server identify the client by id, on receive further request,
*
* server maintain client, e.g cleanup on close/error,
*
我已经实现了这个想法，它可以很好地识别客户端。
而且，我还基于这个想法实现了组/主题广播，这需要服务器维护额外的信息。
connections[username] = ws），然后在其他地方，您可以执行类似于connections[username].send(message)的操作。 - lanzzjoin()和broadcast()方法。在这里查看一些讨论：https://dev59.com/nGw15IYBdhLWcg3wFHpZ - meetamit