如何使用socket.io向特定客户端发送消息

Question

我从socket.io + node.js开始,我知道如何在本地发送消息和广播socket.broadcast.emit()功能: - 所有连接的客户端都收到相同的消息.

现在,我想知道如何向特定客户端发送私人消息,我的意思是一个套接字用于2人之间的私人聊天(客户端到客户端流).谢谢.

Answer 1

您可以使用socket.io房间.从客户端发出一个事件(在这种情况下,"加入",可以是任何东西)与任何唯一标识符(电子邮件,id).

客户端:

var socket = io.connect('http://localhost');
socket.emit('join', {email: user1@example.com});

现在,从服务器端使用该信息为该用户创建一个独特的空间

服务器端:

var io = require('socket.io').listen(80);

io.sockets.on('connection', function (socket) {
  socket.on('join', function (data) {
    socket.join(data.email); // We are using room of socket io
  });
});

所以,现在每个用户都加入了以用户电子邮件命名的房间.因此,如果您想向特定用户发送您必须发送的消息

服务器端:

io.sockets.in('user1@example.com').emit('new_msg', {msg: 'hello'});

客户端最后要做的就是收听"new_msg"事件.

客户端:

socket.on("new_msg", function(data) {
    alert(data.msg);
}

我希望你明白这个主意.

Answer 2

当用户连接时,它应该使用必须唯一的用户名(例如电子邮件)向服务器发送消息.

一对用户名和套接字应该存储在这样的对象中:

var users = {
    'userA@example.com': [socket object],
    'userB@example.com': [socket object],
    'userC@example.com': [socket object]
}

在客户端上,使用以下数据向服务器发出一个对象:

{
    to:[the other receiver's username as a string],
    from:[the person who sent the message as string],
    message:[the message to be sent as string]
}

在服务器上,侦听消息.收到消息后,将数据发送给接收方.

users[data.to].emit('receivedMessage', data)

在客户端上,侦听来自名为"receivedMessage"的服务器的发出,并通过读取数据来处理它来自何处以及发送的消息.

Answer 3

当然: 简单地说,

这就是你需要的:

io.to(socket.id).emit("event", data);

每当用户加入服务器时,将生成包括ID的套接字详细信息.这个ID确实有助于向特定的人发送消息.

首先我们需要将所有socket.id存储在数组中,

var people={};

people[name] =  socket.id;

这里的名字是接收者名称.例:

people["ccccc"]=2387423cjhgfwerwer23;

所以,现在我们可以在发送消息时使用接收者名称获取socket.id:

为此我们需要知道receivername.您需要向服务器发出接收者名称.

最后一件事是:

 socket.on('chat message', function(data){
io.to(people[data.receiver]).emit('chat message', data.msg);
});

希望这对你有用.

祝好运!!

Answer 4

你可以参考socket.io 房间.当你握手套接字时 - 你可以将他加入到命名的房间,例如"user.#{userid}".

之后,您可以通过方便的名称向任何客户端发送私人消息,例如:

io.sockets.in('user.125').emit('new_message',{text:"Hello world"})

在上面的操作中,我们将"new_message"发送给用户"125".

谢谢.

Answer 5

正如az7ar 的回答说得很漂亮，但让我用 socket.io 房间让它更简单。请求具有唯一标识符的服务器加入服务器。在这里，我们使用电子邮件作为唯一标识符。

客户端Socket.io

socket.on('connect', function () {
  socket.emit('join', {email: user@example.com});
});

当用户加入服务器时，为该用户创建一个房间

服务器Socket.io

io.on('connection', function (socket) {
   socket.on('join', function (data) {    
    socket.join(data.email);
  });
});

现在我们都准备好加入了。让从服务器to机房发出一些东西，以便用户可以收听。

服务器Socket.io

io.to('user@example.com').emit('message', {msg: 'hello world.'});

让我们message通过向客户端收听事件来完成主题

socket.on("message", function(data) {
  alert(data.msg);
});

来自Socket.io 房间的参考

Answer 6

在我们公司的一个项目中，我们使用“房间”方法，它的名称是对话中所有用户的用户 ID 的组合作为唯一标识符（我们的实现更像是 Facebook 信使），例如：

|身份证 | 姓名 |1 | 斯科特 |2 | 苏珊

“房间”名称将是“1-2”（ID 以升序排列）并且在断开连接时 socket.io 会自动清理房间

通过这种方式，您只向那个房间发送消息，并且只向在线（连接）用户发送消息（整个服务器发送的包较少）。