Node.js Websocket 传输可靠性(重新连接期间的 Socket.io 数据丢失)

其他人在其他回答和 comments 中也暗示了这一点，但根本问题在于插座.IO只是一种传递机制，你需要依靠它来可靠地传递信息.唯一确定消息已成功交付给客户端is the client itself的人.对于这种系统，我建议您做出以下断言:

1. 消息不会直接发送到客户端；相反，它们被发送到服务器并存储在某种数据存储中.
2. 客户端负责在重新连接时询问"我错过了什么"，并将查询数据存储中存储的消息以更新其状态.
3. 如果消息被发送到服务器while the recipient client is connected,，则该消息将被实时发送到客户端.

当然，根据应用程序的需要，您可以调整其中的一些部分——例如，您可以使用Redis列表或消息排序集，如果您知道客户机是最新的，则可以清除它们.

以下是几个例子:

Happy path:

• U1和U2都连接到系统.
• U2向服务器发送U1应该接收的消息.
• 服务器将消息存储在某种持久性存储中，用某种时间戳或顺序ID将其标记为U1.
• 服务器通过套接字将消息发送到U1.伊奥.
• U1的客户端确认(可能通过Socket.IO回调)它收到了消息.
• 服务器从数据存储中删除保留的消息.

Offline path:

• U1失go 了互联网连接.
• U2向服务器发送U1应该接收的消息.
• 服务器将消息存储在某种持久性存储中，用某种时间戳或顺序ID将其标记为U1.
• 服务器通过套接字将消息发送到U1.伊奥.
• U1的客户端does not确认接收，因为它们处于脱机状态.
• 也许U2会向U1发送更多信息；它们都以相同的方式存储在数据存储中.
• 当U1重新连接时，它会询问服务器"我看到的最后一条消息是X/I have state X，我错过了什么."
• 服务器根据U1的请求向U1发送它从数据存储中丢失的所有消息
• U1的客户端确认接收，服务器从数据存储中删除这些消息.

如果你绝对想要有保证的交付，那么重要的是设计你的系统，让连接实际上并不重要，而实时交付只是一个bonus；这几乎总是涉及某种类型的数据存储.正如user568109在一篇 comments 中提到的，有一些消息传递系统可以抽象出所述消息的存储和传递，这可能值得研究这种预构建的解决方案.(您可能仍然需要自己编写Socket.IO集成.)

如果您对将消息存储在数据库中不感兴趣，那么可以将它们存储在本地数组中；服务器try 向U1发送消息，并将其存储在"待定消息"列表中，直到U1的客户端确认收到消息.如果客户机处于脱机状态，那么当它返回时，它可以告诉服务器"嘿，我断开了连接，请给我发送我错过的任何信息"，服务器可以遍历这些消息.

幸运的是，Socket.IO提供了一种机制，允许客户端"响应"看起来像本机JS回调的消息.以下是一些伪代码:

// server
pendingMessagesForSocket = [];

function sendMessage(message) {
  pendingMessagesForSocket.push(message);
  socket.emit('message', message, function() {
    pendingMessagesForSocket.remove(message);
  }
};

socket.on('reconnection', function(lastKnownMessage) {
  // you may want to make sure you resend them in order, or one at a time, etc.
  for (message in pendingMessagesForSocket since lastKnownMessage) {
    socket.emit('message', message, function() {
      pendingMessagesForSocket.remove(message);
    }
  }
});

// client
socket.on('connection', function() {
  if (previouslyConnected) {
    socket.emit('reconnection', lastKnownMessage);
  } else {
    // first connection; any further connections means we disconnected
    previouslyConnected = true;
  }
});

socket.on('message', function(data, callback) {
  // Do something with `data`
  lastKnownMessage = data;
  callback(); // confirm we received the message
});

这与上一个建议非常相似，只是没有持久数据存储.

你也可能对event sourcing的概念感兴趣.