如何用Spring的DefaultMessageListenerContainer对接ActiveMQ Artemis集群所有节点

核心问题在于DefaultMessageListenerContainer默认会缓存连接、会话，导致所有消费者复用同一个连接，而ActiveMQ Artemis的单个连接只会绑定到集群中的一个broker节点，因此所有消费者都集中在同一节点上。以下是两种可行的解决思路：

方案一：优化原生连接工厂+调整容器缓存级别 #

通过配置Artemis连接工厂的负载均衡策略，结合合适的容器缓存级别，既实现消费者跨broker分布，又避免连接频繁重建的开销：

1. 修改连接工厂配置，添加轮询负载均衡策略，确保新连接能分配到不同集群节点：

ConnectionFactory connectionFactory() {
    ActiveMQJMSConnectionFactory connectionFactory = new ActiveMQJMSConnectionFactory(
        config.getUrl(), config.getUser(), config.getPassword());
    // 启用轮询负载均衡，新连接依次分配到集群各节点
    connectionFactory.setConnectionLoadBalancingPolicy(new RoundRobinConnectionLoadBalancingPolicy());
    // 配置合理的重连参数，减少不必要的连接重建
    connectionFactory.setReconnectAttempts(-1); // 无限重试，可根据业务调整
    connectionFactory.setReconnectInterval(1000);
    return connectionFactory;
}

2. 调整容器缓存级别，替换CACHE_NONE为CACHE_CONSUMER：

// 原代码的CACHE_NONE替换为以下配置
factory.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONSUMER);

这个级别会缓存消费者对象，同时每个消费者会使用独立的连接/会话，既避免了频繁创建连接的开销，又能让不同消费者连接到不同的broker节点。

方案二：正确配置连接池（JmsPoolConnectionFactory） #

如果想用连接池优化连接复用，需确保池的最大连接数匹配并发消费者数量，让每个消费者能获取独立连接：

ConnectionFactory connectionFactory() {
    ActiveMQJMSConnectionFactory artemisConnFactory = new ActiveMQJMSConnectionFactory(
        config.getUrl(), config.getUser(), config.getPassword());
    artemisConnFactory.setConnectionLoadBalancingPolicy(new RoundRobinConnectionLoadBalancingPolicy());
    
    JmsPoolConnectionFactory poolConnFactory = new JmsPoolConnectionFactory();
    poolConnFactory.setConnectionFactory(artemisConnFactory);
    
    // 最大连接数设置为并发数的上限，比如concurrency配置为"5-10"则设为10
    String concurrency = config.getConcurrency();
    int maxConcurrency = Integer.parseInt(concurrency.split("-")[1]);
    poolConnFactory.setMaxConnections(maxConcurrency);
    // 每个连接仅允许1个会话，确保消费者使用独立会话
    poolConnFactory.setMaxSessionsPerConnection(1);
    
    return poolConnFactory;
}

同时容器工厂的缓存级别保持CACHE_CONSUMER，这样连接池中的连接会被合理复用，且不同消费者的连接会被分配到不同的broker节点。

额外注意事项 #

• 确认连接URL中的useTopologyForLoadBalancing=true参数生效，Artemis集群节点之间能正常同步拓扑信息
• 队列消费场景下，Artemis本身会将消息分发到不同节点的消费者，前提是消费者连接到了不同节点，因此核心是让消费者的连接分布到集群各节点

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