如何避免只连接到 ActiveMQ 中的一个代理？

Question

我们已经部署了一个使用 P2P 模型的代理集群。数据分布在整个集群中。我们的许多消费者使用相同的地址“failover:(tcp://ip1:61616,tcp://ip2:61616,tcp: //ip3:61616,tcp://ip4:61616,tcp:/ip5:61616)?nested.wireFormat.maxInactivityDuration=1000" .但是最后，我们发现很多消费者会连接同一个broker，使得数据不在broker上，从其他broker传输过来。这种传输占用带宽很大。 我该如何解决平衡问题？消费者如何决定使用哪个代理？

例如，我们有 3 个代理，所有代理都配置了以下 sn-p：

<transportConnectors>       
     <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximum
Connections=1000&amp;wireFormat.maxFrameSize=104857600" updateClusterClients="true" rebalanceClusterClients="true" updateClusterClientsOnRemove="true" discoveryUri="multicast://default" />
</transportConnectors>

<networkConnectors>  
    <networkConnector  uri="multicast://default"/>  
</networkConnectors>

在消费者程序中，我使用“failover:(tcp://broker1:61616,tcp://broker2:61616)?nested.wireFormat.maxInactivityDuration=1000”作为代理地址。 我运行了三个消费者进程，但发现所有三个进程最终都连接到broker1IP，这导致broker2中的数据，broker3被传输到broker1进行消费。 这会导致巨大的网络负担。

Answer 1

我假设您正在寻找代理中消息的负载平衡，您可以使用代理网络来解决问题，查看此链接以获取更多信息http://activemq.apache.org/networks-of-brokers.html