我有一个集群应用程序，它监听来自 tge 订阅的消息
所以我有 1 个主题和 1 个订阅。以下架构用作负载均衡器，因此集群中的每个节点都接受唯一的消息。像这样
生产者生产A、B、C、D、E
假设集群包含 2 个节点。可能的情况是 node_1 接受 A 和 D 但 node_2 接受 B，C abd E
如果我知道集群中有多少个节点，我可以为每个节点创建订阅。它将允许监听每个集群节点上的每条消息。但是如果我的节点数不时变化怎么办？(可能会增加或减少)。如何才能接受集群中每个节点上发布者的每条消息？
最佳答案
正如评论中已经提到的，您需要使用 SDK 从客户端动态创建订阅，并在客户端离线后删除订阅。
认为没有比这更好的方法了，因为客户数量可能会增加或减少。
关于java - 如何实现集群中的每个节点都接受来自 Google pub/sub 主题的消息？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59494234/