ActiveMQ Artemis集群消费者连接异常及连接策略咨询

核心误解：消息负载均衡 vs 客户端连接负载均衡 #

你当前的配置混淆了两个完全独立的机制：

• cluster-connection中的message-load-balancing: ON_DEMAND是broker集群间的消息负载均衡策略，作用是当某节点队列消息堆积时，将消息转发到集群内其他有消费者的节点，和客户端会话的分配逻辑无关。
• 客户端会话的节点分配由客户端连接工厂的负载均衡策略控制，与集群连接配置无直接关联。

为什么部分会话留在Master1 #

1. 你的Spring Boot应用仅配置了指向Master1的单节点spring.artemis.broker-url，客户端连接工厂会优先尝试连接该节点，只有当Master1不可用时才会切换到其他节点——这就是停止Master1后所有会话都能连接Master2的原因。
2. 客户端会话默认具备粘性：一旦与Master1建立会话，只要连接正常，就不会主动切换到其他broker。已建立的22个会话会持续留在Master1，只有新创建或断开重连的会话才会在Master1可用时继续连接它。

解决方案：让所有会话优先连接Master2 #

1. 配置多节点broker-url #

将spring.artemis.broker-url改为包含Master2和Master1的节点列表，把Master2放在首位：

spring.artemis.broker-url=tcp://master2:61626,tcp://master1:61616

这样客户端连接工厂会从列表中选择节点建立连接。

2. 指定客户端连接负载均衡策略 #

通过配置优先选择列表首位节点的策略，确保客户端优先连接Master2：

spring.artemis.connection-load-balancing-policy-class-name=org.apache.activemq.artemis.api.core.client.loadbalance.FirstElementConnectionLoadBalancingPolicy

该策略会让客户端始终尝试连接列表第一个节点（Master2），仅当Master2不可用时才会 fallback 到Master1，完全匹配你“所有会话连接到Master2”的需求。

3. 迁移已有会话（可选） #

对于已连接到Master1的22个会话，需主动断开重连才能切换到Master2，可通过两种方式实现：

• 重启Spring Boot应用，让所有会话重新建立；
• 配置客户端连接失效检测参数（如client-failure-check-period），当Master1出现异常时自动断开重连，但Master1正常运行时，现有会话不会主动迁移。

为什么之前的尝试无效 #

• 调整static-connectors顺序：这是broker之间集群通信的节点列表，用于控制broker间的消息转发和状态同步，与客户端连接的分配逻辑无关。
• 单节点broker-url下设置负载均衡策略：负载均衡策略仅在broker-url包含多个节点时生效，单节点场景下策略不会触发。

内容的提问来源于stack exchange，提问作者Eric