第二个物理发布者如何收到新订阅者的通知？

Question

与this question相关： 据我了解，两个物理发布者代表一个逻辑发布者，每个发布者都必须有自己的订阅队列。使用 DBSubscriptionStorage 可以让他们拥有一个共同的订阅者列表，但是当一个新的订阅者弹出并订阅时会发生什么？订阅消息将进入订阅队列之一，然后进入数据库。除了重新启动其他发布者之外，有什么方法可以让他们知道新的订阅者？

Answer 1

2 家拥有众多订阅者的实体出版商

配置

• 每个端点（发布者或订阅者）都有自己的输入队列。
• 每个发布者都将被配置为指向同一个共享订阅数据库
• 每个订阅者将被配置为指向一个发布者输入队列（这是他们将丢弃订阅消息的地方）

处理

1. 订阅者 1 将订阅消息 (M1) 放入发布者 1 的输入队列中
2. Publisher1 将该订阅保存到数据库中
3. 订阅者 2 将订阅消息 (M2) 放入发布者 2 的输入队列中
4. Publisher2 将该订阅保存到数据库中
5. Publisher1 发布者 M1 被放入 Subscriber1 的输入队列中
6. Publisher2 和 M1 也是如此

您必须决定是否所有订阅者都对相同的消息感兴趣。可以让两个发布者发布相同的消息，因为每个订阅者只会订阅一次（在 P1 或 P2 处）。您可以完全控制如何“负载平衡”工作。更多信息可以在here找到，如果你还没有看过的话

Answer 2

您有几个选择。最简单的方法之一是让每个单独的物理发布者指向一个物理订阅者/订阅数据库。

另一个很好的处理方法是使用数据库复制。复制的唯一问题是它本质上是“一种方式”。尽管如此，有一个非常有趣的 MySQL 项目，名为“MySQL MMM”，似乎非常适合这种情况。

最后，您可以使用 Membase 之类的东西拥有自己的订阅存储，它是一个持久的、复制的键/值存储。

底线：您可以拥有一个最简单的订阅数据库，但您有一个故障点。或者，您可以拥有一个复制的订阅存储。复制的存储将确保所有节点都有一个所有订阅者的列表。