apache-pulsar - 在 Pulsar 中排除发件人的主题消费者

Question

简介

我们正在开发一个系统来支持多个实时消息(聊天)和更新(事件通知)。

也就是说，用户 A 可以通过 Web Socket 接收消息:

1. 接收新的聊天消息
2. 接收某些事件的更新，例如，如果有人喜欢他们的照片。
3. 等等。

我们使用一个 WebSocket 连接将所有这些不同的消息发送到客户端。

不过，我们也支持用户同时打开多个应用/客户端。(即 - 用户 A 在他们的网络浏览器上连接，同时也从他们的移动应用程序连接)。

架构

我们有一个“Hub”，用于存储 UserId 到事件 websocket session 列表的映射。
(user:123 -> listOf(session#1, session#2))

每个客户端，一旦建立了 websocket 连接，就会有自己的消费者订阅一个 pulsar 主题“userId”(例如 - user:123 主题)。
如果用户 A 在移动设备和 Web 上都连接，则每个客户端都有自己的消费者主题 user:A。

当用户 A 从 session #1 向用户 B 发送一条新消息时，流程是:

1. 用户发出 REST POST 请求以发送消息。
2. 服务将新消息存储到数据库。
3. 服务向主题 user:B 和 user:A 发送 Pulsar 消息。
4. 返回200状态码+创建消息响应。

问题

如果用户 A 打开了两个 session (两个客户端/websockets)，并且他们从 session #1 发送消息，我们如何确保只有 session #2 收到消息？

由于用户 A 已经在 session #1 中收到带有创建消息的 200 响应，因此无需通过向他的消费者发送消息来再次向他发送消息。

我不确定这是 Pulsar 配置问题，还是我们的架构有误。

Answer 1

how can we make sure only session #2 gets the message ?

我将在应用级别解决这个问题。

---

为每条发送的消息添加一个唯一的随机数(例如 guid)。维护最近发送的随机数的简短列表，将它们老化，这样我们就不会超过，比如说，六个。

收到消息后，查看我们是否发送了它。也就是说，检查它的随机数是否在列表中。如果是这样，默默地丢弃它。

---

同样，为每个连接命名。

当一个新的 websocket 打开时，你可以只滚动一次 guid。或者你可以合并一些 websocket 的寻址位到名称中。

在每个出站消息前加上连接名称。丢弃任何收到的“发件人”为“自己”的消息。

---

通过这种重复数据删除方法仍然有一些浪费的网络带宽。如果你愿意，我们可以争论不休。当创建第 K 个 websocket 时，我们可以创建K个主题，每个都不包括不同的端点。听起来工作多得不值得!