ActiveMQ Artemis：首个初始连接器故障时FirstElementConnectionLoadBalancingPolicy无法连接

核心原因 #

你遇到的问题是FirstElementConnectionLoadBalancingPolicy的设计特性导致的：该策略的select方法固定返回索引0，无论当前选择的是拓扑节点还是初始连接器。当客户端启动时还未获取到集群拓扑，会进入初始连接器选择分支，此时策略只会返回第一个初始连接器的索引。如果该节点不可用，客户端不会自动尝试其他初始连接器——因为负载均衡策略仅负责选择节点位置，不处理连接失败后的重试逻辑。

为什么这不是"预期行为"？ #

FirstElementConnectionLoadBalancingPolicy的定位是在可用的节点列表中始终优先选择第一个元素，但这个逻辑没有区分"初始连接器列表"和"集群拓扑列表"：

• 当客户端已获取拓扑时，集群会维护可用节点列表，策略选第一个可用节点，故障时自动切换到下一个，这符合你的预期；
• 但在初始阶段，客户端没有可用节点的状态信息，策略依然硬选第一个初始连接器，导致无法 fallback 到其他正常节点获取拓扑。

解决方案 #

1. 自定义负载均衡策略 #

实现一个结合初始轮询、拓扑优先选第一个的自定义策略，示例逻辑：

public class HybridConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy {
    private final ConnectionLoadBalancingPolicy topologyPolicy = new FirstElementConnectionLoadBalancingPolicy();
    private final ConnectionLoadBalancingPolicy initialPolicy = new RoundRobinConnectionLoadBalancingPolicy();
    private boolean hasTopology = false;

    @Override
    public int select(int max) {
        if (hasTopology) {
            return topologyPolicy.select(max);
        } else {
            return initialPolicy.select(max);
        }
    }

    @Override
    public void reset() {
        topologyPolicy.reset();
        initialPolicy.reset();
    }

    public void setHasTopology(boolean hasTopology) {
        this.hasTopology = hasTopology;
    }
}

使用时，在ServerLocator初始化后，通过TopologyListener监听拓扑获取事件，调用策略的setHasTopology(true)切换到FirstElement逻辑。

2. 调整客户端重试与初始连接器策略 #

结合客户端重试参数，搭配一个支持故障切换的初始选择策略：

• 配置客户端无限重试：serverLocator.setReconnectAttempts(-1)，并设置合理的重试间隔serverLocator.setRetryInterval(1000)；
• 使用自定义策略，连接失败后自动尝试下一个初始连接器：

public class FailoverFirstElementPolicy implements ConnectionLoadBalancingPolicy {
    private int lastIndex = 0;

    @Override
    public int select(int max) {
        int current = lastIndex;
        lastIndex = (lastIndex + 1) % max;
        return current;
    }

    @Override
    public void reset() {
        lastIndex = 0;
    }
}

当客户端成功连接并获取拓扑后，该策略会自动针对拓扑列表优先选择第一个节点，满足你的性能需求。

总结 #

FirstElementConnectionLoadBalancingPolicy的设计未考虑初始连接器的故障 fallback 场景，这是策略的局限性而非bug。通过自定义策略结合重试配置，就能实现"初始阶段轮询初始连接器获取拓扑，拓扑可用后优先连接第一个节点"的需求。

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