使用 socket.io 和节点向特定客户端发送消息.js

javascript node.js server-side websocket socket.io

2022-08-30 00:50:24

我正在使用 socket.io 和node.js到目前为止，它似乎还不错，但我不知道如何将消息从服务器发送到特定的客户端，如下所示：

client.send(message, receiverSessionId)

但是，这些方法似乎都不能满足我的需求。.send().broadcast()

我发现作为一个可能的解决方案是，该方法接受一个不向其发送消息的SessionId数组作为第二个参数，因此我可以将一个数组与当时连接的所有SessionIds传递给服务器，除了我希望发送消息的数组，但我觉得一定有更好的解决方案。.broadcast()

有什么想法吗？

答案 1

Ivo Wetzel的答案似乎在0.9 Socket.io 中不再有效。

简而言之，您现在必须保存并用于向其发送消息。socket.idio.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

答案 2

每个插座都使用插座 ID 加入一个房间，以便您只需

io.to('socket#id').emit('hey')

文档： http://socket.io/docs/rooms-and-namespaces/#default-room

干杯