0

我有集群应用程序,它监听来自 tge 订阅的消息

所以我有 1 个主题和 1 个订阅。以下模式用作负载平衡器,因此集群中的每个节点都接受唯一的消息。像这样

生产者生产A, B, C, D,E

假设集群包含 2 个节点。可能的情况是node_1接受ADnode_2接受BCabdE

如果我知道集群中有多少个节点,我可以为每个节点创建订阅。它将允许监听每个集群节点上的每条消息。但是,如果我的节点数不时变化怎么办?(它可能会增加或减少)。我怎样才能在集群的每个节点上接受来自发布者的每条消息?

4

1 回答 1

0

正如评论中已经提到的,您需要使用 SDK 从客户端即时创建订阅,并在客户端离线后删除订阅。

不要认为有比这更好的方法,因为客户数量可能会上升或下降。

于 2020-01-03T23:22:17.043 回答