我在ActiveMQ中设置了两个节点的代理网络。除了所有连接到一个代理的客户机和第二个代理没有任何连接之外,其他一切都正常工作。我已经启用了updateClusterClients
和rebalanceClusterClients
。我认为启用这些选项可以让客户重新平衡自己
conn = stomp.Connection11([(localhost,61613),(remotehost,61613)], heartbeats=
(10000,20000),encoding="utf-8",heart_beat_receive_scale=2.0)
conn.start()
updateClusterClients
和rebalanceClusterClients
设置仅适用于OpenWire客户端。STOMP是一个非常简单的协议(顾名思义)。对于代理来说,没有标准的方法来通知STOMP客户机集群拓扑更新或者告诉它连接到不同的代理。它只是不属于规范的一部分。您需要手动平衡客户端,或者使用外部负载平衡器相关问题 更多 >
编程相关推荐