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

Moz*_*art 13 javascript sockets offline node.js

环境:

+的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);
    }
});
});
Run Code Online (Sandbox Code Playgroud)

描述

客户端B首先连接到一个地方的服务器.在客户端B离线期间,客户端A向客户端B发送消息.然后客户端B再次连接到另一个地方的服务器,客户端B需要从客户端A接收这些消息.使它工作?

Mat*_*att 12

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

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);
    }
});
Run Code Online (Sandbox Code Playgroud)

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

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');
});
Run Code Online (Sandbox Code Playgroud)