Socket.IO 客户端在回来时接收离线消息

Question

环境：

Nodejs+Socketio

问题：

1. 客户端 A 和客户端 B 都连接到服务器；
2. 客户端 B 离线；
3. 客户端A向客户端B发送消息（客户端B仍然离线）；
4. 客户端 B 再次连接服务器；
5. [问题]客户端B收不到A的消息；

服务器代码

var clients = {};
io.sockets.on('connection', function (socket) {
socket.on('online', function (data) {
    if (!clients[data.username]) {
        clients[data.username] = socket;
    }
    io.sockets.emit('message',  data.user + 'online now');
});
socket.on('say', function (data) {
    if (data.to == 'all') {
        io.sockets.emit('message', data.message);
    } else { //to specific client
        clients[data.to].emit('message', data.message);
    }
});
});

说明

客户端B首先连接到一个地方的服务器。在客户端B离线期间，客户端A向客户端B发送消息。然后客户端B再次连接到另一个地方的服务器，客户端B需要接收来自客户端的消息A. 如何让它发挥作用？

Answer 1

如果我考虑哪个数据库及其配置和客户端，我必须编写的代码量将相当大，以创建解决方案。您基本上必须将消息保存在数据库中。当消息进入时，您必须写入您的对话对象（或代表客户端之间聊天消息的任何内容）。

socket.on('say', function (data) {
    // pseudo code to save conversation
    // var conversation = db.getConversation();
    // conversation.addMessage(data.message);
    // conversation.save();
    if (data.to == 'all') {
        io.sockets.emit('message', data.message);
    } else { //to specific client
        clients[data.to].emit('message', data.message);
    }
});

然后，当客户端加入时，您必须从数据库中获取所有消息。

socket.on('online', function (data) {
    if (!clients[data.username]) {
        clients[data.username] = socket;
    }
    // pseudo code to get messages and display to user on first load
    // var conversation = db.getConversation();
    // var messages = conversation.getLast10Messages();
    // messages.forEach(function(message) { 
    //     clients[data.username].emit('message', message);
    // });
    io.sockets.emit('message',  data.user + 'online now');
});

Answer 2

使用像 RabbitMQ 这样的消息队列。每当消息来自套接字写入接收者的队列时，当接收者加入时，他将从队列中选择它。

Answer 3

您可以为每个用户指定一个唯一的 id 作为用户名，将其保存在服务器端，或者使用用户名，您还有客户端 id（套接字 id），然后将它们保存在一个对象中，现在对于每个用户，您都有一个包含（用户名或唯一 ID）和套接字 ID 的对象，现在可以在用户离线时轻松保存消息，然后将其发送给用户。 在发出每个事件之前，您可以在socket的已连接sockets对象中搜索socket id。如果socket id存在，则可以发出，否则，您仍然有用户名，您可以通过用户名将消息保存到数据库中。

请记住，您必须在客户端的每次发射中发送接收者对象信息（用户名或唯一 id 和套接字 id）