同步来自 REST 和 Websocket 的数据

Question

我们正在构建类似于 Messenger 的聊天应用程序。有必需的行为：

• 用户登录
• 用户应该看到最后 N 条消息，并且他应该能够加载较旧的消息
• 还应附加新消息

我的解决方案：

• 我想结合 REST 使用 websockets 来实现此目的。我的想法是客户端应用程序通过消息 ID 来决定哪些消息需要。因此，REST 将用于初始消息获取和旧消息获取。
• Websocket 将接收新消息

我应该处理的可能问题：

• 应用程序开始订阅新消息的 websocket 通道并发送没有初始消息 id 的旧消息请求
• 调用 GET 请求后有可能出现新消息，并将其存储在 DB 中
• 客户端应用程序开始订阅 websocket 通道，因此消息将由 websocket 接收。
• GET 请求不知道此消息并获取最后 N 条消息，其中将出现此新消息，并且客户端应用程序将具有重复记录并且必须过滤此消息

如果有一些优雅的方法来处理这种情况，你能给我建议吗？谢谢。

Answer 1

我会在解决您的任务时考虑以下几点：

客户端应用程序应该只知道要侦听的主题。而不是从其开始侦听的消息的 ID。

由服务器决定返回什么（即使时间也应该始终在服务器端进行跟踪）。

WebSocket 用作 STOMP 的传输（只是为了不重新发明轮子）。WebSocket 连接可以在客户端应用程序加载后打开，而不是在进入“侦听消息”状态时打开。但需要时应进行主题订阅。

您始终可以同时发送 GET 请求并启动 STOMP 订阅（几乎同时，延迟 1-2 纳秒）。这些总是应该在不同的承诺中进行处理。但我会按以下方式调整它们：首先，启动 STOMP 订阅，并传递带有订阅开始的初始时间戳的特定订阅消息；其次，执行 REST 请求以获取特定时间戳（从 STOMP 接收）之前的 TOPIC 的前 10-100 条消息。

获取最后 10 条消息（在订阅时刻之前）可以通过 REST 或 STOMP 方法传递：您始终可以对服务器端的订阅事件做出反应，并传递客户端特定的消息。

关于来自不同“数据通道”的多个相同消息的问题，很容易解决：您的客户端（希望不是 jquery，而是 Angular 或 React 或 Vue 或其他任何东西）将把所有数据存储在单个集合中一个控制器，通过消息 ID 进行过滤和检查以仅存储唯一的条目是很容易的。

但是，如果您的系统每秒生成数十万条消息：我想在这种情况下，基于 HTTP 的协议不是您的选择。