我正在使用 socket.io 和 node.js ，直到现在看起来还不错，但我不知道如何从服务器向特定客户端发送消息，如下所示：
client.send(message, receiverSessionId)
但是无论是方法.send()还是.broadcast()方法似乎都不能满足我的需要。
我发现的一个可能的解决方案是，该.broadcast()方法接受一个不向其发送消息的 SessionIds 数组作为第二个参数，因此我可以将一个包含当时连接的所有 SessionIds 的数组传递给服务器，除了一个我希望发送消息，但我觉得必须有更好的解决方案。
有任何想法吗？
Ivo Wetzel 的回答在 Socket.io 0.9 中似乎不再有效。
简而言之，您现在必须保存socket.id并用于io.sockets.socket(savedSocketId).emit(...) 向其发送消息。
这就是我在集群 Node.js 服务器中工作的方式：
首先，您需要将 Redis 存储设置为存储，以便消息可以跨进程：
var express = require("express");
var redis = require("redis");
var sio = require("socket.io");
var client = redis.createClient()
var app = express.createServer();
var io = sio.listen(app);
io.set("store", new sio.RedisStore);
// In this example we have one master client socket
// that receives messages from others.
io.sockets.on('connection', function(socket) {
// Promote this socket as master
socket.on("I'm the master", function() {
// Save the socket id to Redis so that all processes can access it.
client.set("mastersocket", socket.id, function(err) {
if (err) throw err;
console.log("Master socket is now" + socket.id);
});
});
socket.on("message to master", function(msg) {
// Fetch the socket id from Redis
client.get("mastersocket", function(err, socketId) {
if (err) throw err;
io.sockets.socket(socketId).emit(msg);
});
});
});
我在这里省略了聚类代码，因为它使这更混乱，但添加起来很简单。只需将所有内容添加到工作代码中。更多文档在这里http://nodejs.org/api/cluster.html
每个套接字加入一个带有套接字 ID 作为名称的房间，因此您可以
io.to('socket#id').emit('hey')
文档：http : //socket.io/docs/rooms-and-namespaces/#default-room
干杯
已验证与 socket.io v3.1.1 一起使用
这很简单：
client.emit("your message");
就是这样。好的，但它是如何工作的？
下面是一个简单的客户端-服务器交互示例，其中每个客户端都会定期收到一条包含序列号的消息。每个客户端都有一个独特的序列，这就是“我需要向特定客户端发送消息”的地方。
server.js
const
{Server} = require("socket.io"),
server = new Server(8000);
let
sequenceNumberByClient = new Map();
// event fired every time a new client connects:
server.on("connection", (socket) => {
console.info(`Client connected [id=${socket.id}]`);
// initialize this client's sequence number
sequenceNumberByClient.set(socket, 1);
// when socket disconnects, remove it from the list:
socket.on("disconnect", () => {
sequenceNumberByClient.delete(socket);
console.info(`Client gone [id=${socket.id}]`);
});
});
// sends each client its current sequence number
setInterval(() => {
for (const [client, sequenceNumber] of sequenceNumberByClient.entries()) {
client.emit("seq-num", sequenceNumber);
sequenceNumberByClient.set(client, sequenceNumber + 1);
}
}, 1000);
服务器开始在端口 8000 上侦听传入连接。一旦建立了新的连接，该客户端就会被添加到一个记录其序列号的映射中。disconnect当客户端离开时，服务器还会监听从地图中移除客户端的事件。
每一秒，都会触发一个计时器。当它发生时，服务器遍历映射并向每个客户端发送带有当前序列号的消息，然后立即增加它。这就是它的全部内容。十分简单。
客户端部分甚至更简单。它只是连接到服务器并侦听seq-num消息，每次到达时将其打印到控制台。
client.js
const
io = require("socket.io-client"),
ioClient = io.connect("http://localhost:8000");
ioClient.on("seq-num", (msg) => console.info(msg));
安装所需的库：
npm install socket.io@3.1.1 socket.io-client@3.1.1
运行服务器：
node server
通过运行以下命令打开其他终端窗口并生成任意数量的客户端：
node client
我也准备与全电码梗概这里。
好吧，您必须为此抓住客户（惊喜），您可以采用简单的方法：
var io = io.listen(server);
io.clients[sessionID].send()
这可能会中断，我对此表示怀疑，但总是有可能io.clients会发生变化，因此请谨慎使用上述内容
或者您自己跟踪客户端，因此您将它们添加到您自己clients的connection侦听器对象中并在侦听器中删除它们disconnect。
我会使用后一个，因为根据您的应用程序，无论如何您可能希望在客户端上拥有更多状态，因此类似的事情clients[id] = {conn: clientConnect, data: {...}}可能会完成这项工作。
在 1.0 中，您应该使用：
io.sockets.connected[socketid].emit();