使用 node.js 和 socket.io 在密钥之间创建私人聊天

IT技术 javascript node.js socket.io chat
2021-03-20 12:52:11

如何使用 node.js 和 socket.io 在私人聊天中向所有用户发送一条消息，共享一个 session_id？

var express = require('express'),
app = express(),
server = require('http').createServer(app),
io = require('socket.io').listen(server);
conversations = {};

app.get('/', function(req, res) {
res.sendfile('/');
});

io.sockets.on('connection', function (socket) {

socket.on('send message', function (data) {

    var conversation_id = data.conversation_id;

    if (conversation_id in conversations) {

        console.log (conversation_id + ' is already in the conversations object');

        // emit the message [data.message] to all connected users in the conversation

    } else {
        socket.conversation_id = data;
        conversations[socket.conversation_id] = socket;

        conversations[conversation_id] = data.conversation_id;

        console.log ('adding '  + conversation_id + ' to conversations.');

        // emit the message [data.message] to all connected users in the conversation

    }
})
});

server.listen(8080);
2个回答

您必须创建一个房间conversation_id并让用户订阅该房间，以便您可以通过以下方式向该房间发送私人消息，

客户

var socket = io.connect('http://ip:port');

socket.emit('subscribe', conversation_id);

socket.emit('send message', {
    room: conversation_id,
    message: "Some message"
});

socket.on('conversation private post', function(data) {
    //display data.message
});

服务器

socket.on('subscribe', function(room) {
    console.log('joining room', room);
    socket.join(room);
});

socket.on('send message', function(data) {
    console.log('sending room post', data.room);
    socket.broadcast.to(data.room).emit('conversation private post', {
        message: data.message
    });
});

这是创建房间、订阅房间和向房间发送消息的文档和示例：

  1. Socket.io 房间
  2. Socket.IO 订阅多个频道
  3. Socket.io 房间之间的区别 broadcast.to 和 sockets.in
这对我有很大帮助divillysausages.com/2015/07/12/an-intro-to-socket-io，请参阅向其他用户发送消息
2021-05-01 12:52:11
太好了，谢谢，它完美地工作。我改变socket.broadcast.to()到 io.sockets.in()使得其包括发射sockets。
2021-05-07 12:52:11

当然：简单地说，

这是你需要的：

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

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

首先我们需要将所有的 socket.ids 存储在数组中，

   var people={};

   people[name] =  socket.id;

这里的名字是接收者的名字。例子：

  people["ccccc"]=2387423cjhgfwerwer23;

所以，现在我们可以在发送消息时获取带有接收者名称的 socket.id：

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

最后的事情是：

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

希望这对你有用。！祝你好运

其它你可能感兴趣的问题
上一篇替代 DOMNodeInserted 下一篇检查字符串是否有空格