我有集群应用程序,它监听来自 tge 订阅的消息
所以我有 1 个主题和 1 个订阅。以下模式用作负载平衡器,因此集群中的每个节点都接受唯一的消息。像这样
生产者生产A
, B
, C
, D
,E
假设集群包含 2 个节点。可能的情况是node_1
接受A
,D
但node_2
接受B
,C
abdE
如果我知道集群中有多少个节点,我可以为每个节点创建订阅。它将允许监听每个集群节点上的每条消息。但是,如果我的节点数不时变化怎么办?(它可能会增加或减少)。我怎样才能在集群的每个节点上接受来自发布者的每条消息?