其他人在其他答案和评论中暗示了这一点，但根本问题是Socket.IO只是一种传递机制，你不能单独依靠它来实现可靠的交付 . 唯一确定消息已成功传递给客户端的人 is the client itself . 对于这种系统，我建议做出以下断言：

消息不会直接发送给客户端;相反，它们被发送到服务器并存储在某种数据存储中 .

客户端负责在重新连接时询问"what did I miss"，并将查询数据存储中存储的消息以更新其状态 .

如果在连接收件人客户端时将消息发送到服务器，则该消息将实时发送到客户端 .

当然，根据您的应用程序的需要，您可以调整其中的一部分 - 例如，您可以使用Redis列表或消息的排序集，如果您知道客户端已启用，请将其清除至今 .

以下是几个例子：

Happy path ：

U1和U2都连接到系统 .

U2向服务器发送U1应该接收的消息 .

服务器将消息存储在某种持久性存储中，使用某种时间戳或顺序ID将其标记为U1 .

服务器通过Socket.IO将消息发送到U1 .

U1的客户端确认(可能是通过Socket.IO回调)它收到了消息 .

服务器从数据存储中删除持久消息 .

Offline path ：

U1失去了互联网连接 .

U2向服务器发送U1应该接收的消息 .

服务器将消息存储在某种持久性存储中，使用某种时间戳或顺序ID将其标记为U1 .

服务器通过Socket.IO将消息发送到U1 .

U1的客户 does not 确认收货，因为它们处于离线状态 .

也许U2向U1发送了一些消息;它们都以相同的方式存储在数据存储中 .

当U1重新连接时，它会询问服务器"The last message I saw was X / I have state X, what did I miss."

服务器根据U1的请求向U1发送它从数据存储中丢失的所有消息

U1的客户端确认收到，服务器从数据存储中删除这些消息 .

如果你绝对想要保证交付，那么它真的很重要，而实时交付只是一个 bonus ;这几乎总是涉及某种数据存储 . 正如评论中提到的user568109，有消息传递系统抽象出所述消息的存储和传递，并且可能值得研究这样的预构建解决方案 . (您可能仍需要自己编写Socket.IO集成 . )

如果您对将消息存储在数据库中不感兴趣，则可以将它们存储在本地阵列中;服务器尝试向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

});

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