我正在使用socket.io和node.js进行开发，目前看起来还不错。但我不知道如何从服务器发送消息到一个特定的客户端，类似于这样：
client.send(message, receiverSessionId)
但是，.send()和.broadcast()方法似乎都不能满足我的需求。
我找到的一个可能的解决方案是，.broadcast()方法接受第二个参数作为不发送消息的SessionIds数组，因此我可以传递一个包含连接到服务器的所有SessionIds的数组，但不包括我希望发送消息的SessionId，但我感觉还必须有更好的解决方案。
有什么想法吗？
在Socket.io 0.9中，Ivo Wetzel的答案似乎不再有效。
简而言之，现在您必须保存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
每个 socket 都会加入一个以其 socket id 为名称的房间，因此您只需
io.to('socket#id').emit('hey')
io.sockets.connected [socketid] .emit();。在1.4.6版上进行了测试。 - butcarudev已验证可与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);
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
通过运行以下命令，打开其他终端窗口并生成任意数量的客户端：
Open other terminal windows and spawn as many clients as you want by running:
node client
我还准备了一个包含完整代码的 gist，在这里。
好吧，你需要获取客户端（惊喜），你可以采取简单的方式：
var io = io.listen(server);
io.clients[sessionID].send()
io.clients可能会被更改，因此请小心使用上述方法。connection监听器中将它们添加到自己的clients对象中，并在disconnect监听器中将它们删除。clients[id] = {conn: clientConnect, data: {...}}这样的代码可能会完成任务。您可以使用以下代码向客户端发送消息：
//仅向发送者客户端发送消息
socket.emit('message', '请查看此信息');
//或将消息发送给所有监听器，包括发送者
io.emit('message', '请查看此信息');
//将消息发送给除发送者之外的所有监听器
socket.broadcast.emit('message', '这是一条消息');
//或者您可以将消息发送到聊天室
socket.broadcast.to('chatroom').emit('message', '这是发给所有人的消息');
在1.0中，您应该使用：
io.sockets.connected[socketid].emit();
io.sockets.connected["something"] 对象及其 emit 方法已经不存在了。 - sçuçu无论我们使用哪个版本，如果我们在服务器端的nodejs代码中使用了“io”对象（例如：io.on('connection', function(socket) {...});），只需console.log()一下该对象，就可以看到“io”只是一个json对象，其中有许多子对象存储着socket id和socket对象。
顺便说一下，我使用的是socket.io 1.3.5 版本。
如果我们查看io对象，它包含：
sockets:
{ name: '/',
server: [Circular],
sockets: [ [Object], [Object] ],
connected:
{ B5AC9w0sYmOGWe4fAAAA: [Object],
'hWzf97fmU-TIwwzWAAAB': [Object] },
在这里，我们可以看到socketids“B5AC9w0sYmOGWe4fAAAA”等。那么，我们可以执行以下操作：
io.sockets.connected[socketid].emit();
再次仔细检查，我们可以看到类似以下的片段：
eio:
{ clients:
{ B5AC9w0sYmOGWe4fAAAA: [Object],
'hWzf97fmU-TIwwzWAAAB': [Object] },
那么，我们可以通过执行以下操作从这里检索套接字
io.eio.clients[socketid].emit();
此外，在引擎下我们还有：
engine:
{ clients:
{ B5AC9w0sYmOGWe4fAAAA: [Object],
'hWzf97fmU-TIwwzWAAAB': [Object] },
所以，我们也可以写成：
io.engine.clients[socketid].emit();
所以，我猜我们可以通过上述三种方式中的任何一种来实现我们的目标：
global.io=require("socket.io")(server);
io.on("connection",function(client){
console.log("client is ",client.id);
//This is handle by current connected client
client.emit('messages',{hello:'world'})
//This is handle by every client
io.sockets.emit("data",{data:"This is handle by every client"})
app1.saveSession(client.id)
client.on("disconnect",function(){
app1.deleteSession(client.id)
console.log("client disconnected",client.id);
})
})
//And this is handle by particular client
var socketId=req.query.id
if(io.sockets.connected[socketId]!=null) {
io.sockets.connected[socketId].emit('particular User', {data: "Event response by particular user "});
}
在客户端上，处理起来非常容易。
var socket=io.connect("http://localhost:8080/")
socket.on("messages",function(data){
console.log("message is ",data);
//alert(data)
})
socket.on("data",function(data){
console.log("data is ",data);
//alert(data)
})
socket.on("particular User",function(data){
console.log("data from server ",data);
//alert(data)
})
从版本1.4.5开始，在使用io.to()时，请确保您提供一个正确的带前缀的socketId。
我曾经用客户端登录的socketId进行调试，但由于没有前缀，所以我一直在搜索，直到最终找到解决方法！因此，如果您拥有的ID没有前缀，您可能需要这样做：
io.to('/#' + socketId).emit('myevent', {foo: 'bar'});
io.of('/mynamespace').sockets[socketID].emit(...)（不知道是不是因为我在使用命名空间）。 - Adrien Schuler^类型错误：未定义的函数 在 Object.<anonymous> (C:\Users\Dev\Desktop\nouty-server\server.js:108:14) 在 Module._compile (module.js:460:26) 在 Object.Module._extensions..js (module.js:478:10) 在 Module.load (module.js:355:32) 在 Function.Module._load (module.js:310:12) 在 Function.Module.runMain (module.js:501:10) 在 startup (node.js:129:16) 在 node.js:814:3 - Lucas Bertolloio.sockets.socket(socket_id)已被移除。详情请参见https://github.com/socketio/socket.io/issues/1618#issuecomment-46151246。 - ImMathan