SSE/Redis-如何恢复SSE脱机时发送的消息

Question

在一个网站上，我有一个非常简单的实时聊天设置，它使用SSE/Redis和pub/sub结构。

基本设置（无需详细说明）为：

1. 客户端使用EventSource

打开SSE连接并订阅SSE守护程序发送的实时事件。将消息发送到APIendpoint

connect(hash, eventListener) {

    const url = `${url}?client=$hash=${hash}`;
    sseSource = new EventSource(url);

    sseSource.onopen = function(e) {
      reconnectFrequencySeconds = 1;
    }

    sseSource.onerror = err => {
      this.closeSSEStream();
      this.reconnectSSEStream(hash, eventListener);
    };
    sseSource.addEventListener('messages', event => {
      const messages = JSON.parse(event.data);
      eventListener(messages);
    });
  },

将消息存储在数据库中并将其推送到Redis通道。

保存和服务信息。

将客户端订阅到Redis DB中的频道，并使用SSE流将消息转发给订阅者。

const subscriber = redis.createClient();
subscriber.select(config.redisDatabase);

subscriber.on('message', function (channel, message) {
    log(connectionId, 'Redis: new msg on channel: ' + channel, message);
    let event = {
        event: 'messages',
        data: message
    };
    currentClient.connection.write(event);
  });

整个事情运行得很好，但是，它离完美还有一个微调。在部署期间，我们重新启动我们的工作人员（包括SSE守护程序），当它离线时，用户不会收到实时更新。它重新连接很好，但在停机期间发送的消息会丢失（因为守护程序仅在重新连接时开始监听消息）。

我唯一的解决方法是采用一种过度工程化的解决方案，在重新连接时，使用单独的APIendpoint收集“丢失”的消息，并将其显示给用户。

在订阅频道之前，是否有现成的方式接收已存储到Redis的消息？E、 g.“pop”未处理的消息或类似的东西？

Answer 1

当您重新连接发送请求以检查您是否是带有上次msg时间的新msg，如果您是较新的msg，请将其发送到结果msg以避免新请求