使用socket.io和node.js向特定客户端发送消息
https://stackoverflow.com/questions/4647348
-
09-10-2019 - |
italiano
english
français
española
中国
日本の
العربية
Deutsch
한국어
Português
Russian题
我正在使用 socket.io 和 node.js，到目前为止它看起来相当不错，但我不知道如何从服务器向特定客户端发送消息，如下所示：
client.send(message, receiverSessionId)
但无论是 .send() 也不 .broadcast() 方法似乎满足了我的需要。
我发现一个可能的解决方案是 .broadcast() 方法接受不向其发送消息的 SessionId 数组作为第二个参数，因此我可以传递一个包含当时连接到服务器的所有 SessionId 的数组，除了我希望发送消息的那个，但我觉得必须有更好的解决方案。
有任何想法吗？
解决方案
好吧，你必须抓住客户（惊喜），你可以采用简单的方法：
var io = io.listen(server);
io.clients[sessionID].send()
我怀疑这可能会破坏，但总是有可能 io.clients 可能会发生变化，因此请谨慎使用以上内容
或者您自己跟踪客户，因此将它们添加到您自己的客户中 clients 对象在 connection 侦听器并将它们删除 disconnect 听众。
我会使用后一种，因为根据您的应用程序，您可能希望在客户端上有更多状态，所以类似 clients[id] = {conn: clientConnect, data: {...}} 可能会完成这项工作。
其他提示
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
干杯
最简单、最优雅的解决方案
这很简单：
client.emit("your message");
就是这样。
但如何呢？举个例子
事实上我们所需要的是一个完整的例子，这就是下面的内容。这是使用最新的 socket.io 版本（2.0.3）进行测试的，并且它还使用现代 Javascript（我们现在应该都在使用它）。
该示例由两部分组成：一个服务器和一个客户端。每当客户端连接时，它就会开始从服务器接收周期性序列号。每个新客户端都会启动一个新序列，因此服务器必须单独跟踪它们。那就是 “我需要向特定客户发送消息” 发挥作用。代码非常简单易懂。让我们来看看它。
服务器
server.js
const
io = require("socket.io"),
server = io.listen(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
npm install socket.io-client
运行服务器：
node server
打开其他终端窗口并通过运行以下命令生成任意数量的客户端：
node client
我还准备了带有完整代码的要点 这里.
在 1.0 中你应该使用：
io.sockets.connected[socketid].emit();
您可以使用
//仅向发送方客户端发送消息
socket.emit('message', 'check this');
//或者您可以发送给所有监听者，包括发送者
io.emit('message', 'check this');
//发送给除发送者之外的所有监听者
socket.broadcast.emit('message', 'this is a message');
//或者你可以将它发送到一个房间
socket.broadcast.to('chatroom').emit('message', 'this is the message to all');
无论我们使用什么版本，只要我们只是 console.log() 我们在服务器端 Nodejs 代码中使用的“io”对象，[例如io.on('connection', function(socket) {...});]，我们可以看到“io”只是一个json对象，还有很多子对象，其中存储了socket id和socket对象。
顺便说一句，我正在使用 socket.io 版本 1.3.5。
如果我们查看 io 对象，它包含，
sockets:
{ name: '/',
server: [Circular],
sockets: [ [Object], [Object] ],
connected:
{ B5AC9w0sYmOGWe4fAAAA: [Object],
'hWzf97fmU-TIwwzWAAAB': [Object] },
在这里我们可以看到socketid“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();
所以，我想我们可以通过我上面列出的三种方式中的任何一种来实现我们的目标，
- io.sockets.connected[socketid].emit();或者
- io.eio.clients[socketid].emit();或者
- 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)
})
io.sockets.sockets[socket.id].emit(...) 在 v0.9 中为我工作
从版本 1.4.5 开始，请确保在 io.to() 中提供正确的前缀 socketId。我正在使用客户端记录的socketId进行调试，它没有前缀，所以我最终一直在搜索直到我发现！因此，如果您拥有的 Id 没有前缀，您可能必须这样做：
io.to('/#' + socketId).emit('myevent', {foo: 'bar'});
Socket.IO 允许您对套接字进行“命名空间”，这本质上意味着分配不同的端点或路径。
