Надежность транспорта Websocket (Socket.io потеря данных при повторном подключении)

другие намекали на это в других ответах и комментариях, но основная проблема заключается в том, что Socket.IO это просто механизм доставки, а вы не может зависите от его самостоятельно для надежной поставки. Единственный человек, который точно знает, что сообщение было успешно доставлено клиенту сам клиент. Для такого рода системы я бы рекомендовал сделать следующие утверждения:

1. сообщения не отправляются непосредственно клиентам; вместо этого, они отправляются на сервер и хранится в каком-то хранилище данных.
2. клиенты отвечают за запрос "что я пропустил" при повторном подключении и будут запрашивать сохраненные сообщения в хранилище данных для обновления их состояния.
3. если сообщение отправлено на сервер пока клиент получателя подключен, это сообщение будет отправлено в режиме реального времени клиенту.

конечно, в зависимости от потребностей вашего приложения, вы можете настроить кусочки например, вы можете использовать, скажем, список Redis или сортированный набор для сообщений и очистить их, если вы знаете, что клиент обновлен.

---

вот несколько примеров:

счастливого пути:

• U1 и U2 оба подключены к системе.
• U2 отправляет сообщение на сервер, который должен получить U1.
• сервер хранит сообщение в каком-то постоянном хранилище, помечая его для U1 с помощью какая-то временная метка или последовательный идентификатор.
• сервер отправляет сообщение на U1 через Socket.IO.
• клиент U1 подтверждает (возможно, через a Socket.IO обратный вызов), чтобы он получил сообщение.
• сервер удаляет сохраненное сообщение из хранилища данных.

автономный путь:

• U1 теряет подключение к интернету.
• U2 отправляет сообщение на сервер, который должен получить U1.
• в сервер хранит сообщение в каком-то постоянном хранилище, помечая его для U1 какой-то временной меткой или последовательным идентификатором.
• сервер отправляет сообщение на U1 через Socket.IO.
• клиент U1 не подтвердите получение, потому что они находятся в автономном режиме.
• возможно, U2 отправляет U1 еще несколько сообщений; все они хранятся в хранилище данных таким же образом.
• когда U1 снова подключается, он спрашивает сервер "последнее сообщение, которое я видел, было X / у меня состояние X, что я пропустил."
• сервер отправляет U1 все сообщения, которые он пропустил из хранилища данных на основе запроса U1
• клиент U1 подтверждает получение, и сервер удаляет эти сообщения из хранилища данных.

---

Если вы абсолютно хотите гарантированную доставку, то важно спроектировать свою систему таким образом, что подключение на самом деле не имеет значения, и что доставка в реальном времени-это просто бонус; это почти всегда включает в себя хранилище данных какой-то. Как упоминалось в комментарии 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
});

Это очень похоже на последнее предложение, просто без постоянного хранилища данных.

---

вас также может заинтересовать понятие событие поиска.