ActiveMQ Artemis SpringBoot集群主题轮询负载均衡异常问题

我完全懂你的困扰——花了大量时间调试配置、尝试各种方案，就为了让集群模式下的Topic发布订阅和本地模式表现一致，结果三个分属不同节点的消费者却在轮询接收消息，而不是各自拿到消息副本。咱们来拆解问题根源，一步步解决它。

问题本质 #

你当前的集群连接配置用了<message-load-balancing>ON_DEMAND</message-load-balancing>，结合Core Bridge的机制，Artemis会把Topic消息当作"按需负载均衡"的消息处理：当生产者在单个节点发送消息后，集群只会把消息转发到有消费者的一个节点，然后在该节点内广播给本地订阅者。这就导致跨节点的消费者变成了轮询接收，而不是所有订阅者都拿到完整消息副本。

分步解决方案 #

要实现集群内真正的发布订阅（每个消费者都收到消息副本），需要调整两个关键配置：

1. 修改集群连接的消息负载均衡策略 #

把message-load-balancing的值从ON_DEMAND改为STRICT，同时指定集群连接仅作用于JMS Topic地址（避免影响Queue的负载均衡逻辑）。修改后的配置如下：

<cluster-connections>
<cluster-connection name="my-cluster">
<address>jms.topic.#</address> <!-- 精准匹配所有JMS Topic地址 -->
<connector-ref>netty-connector</connector-ref>
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<message-load-balancing>STRICT</message-load-balancing> <!-- 切换为STRICT模式 -->
<max-hops>1</max-hops>
<discovery-group-ref discovery-group-name="my-discovery-group"/>
</cluster-connection>
</cluster-connections>

提示：如果你的Topic有特定的命名前缀，可以把address的值改成对应的匹配规则，比如jms.topic.myapp.#，这样只会对指定前缀的Topic生效。

2. 配置Topic地址为广播类型 #

Artemis默认的地址路由类型是ANYCAST（对应Queue的点对点模式），而Topic需要的是MULTICAST（广播模式）。在每个Broker的broker.xml中添加以下地址设置：

<address-settings>
  <!-- 保留原有的其他地址配置 -->
  <address-setting match="jms.topic.#">
    <default-address-routing-type>MULTICAST</default-address-routing-type>
    <multicast-routing-type>MULTICAST</multicast-routing-type>
  </address-setting>
</address-settings>

3. 验证消费者的订阅配置 #

确保你的Spring Boot消费者订阅的是Topic而非Queue，并且如果使用持久化订阅，每个消费者的clientId和subscriptionName都是唯一的。示例配置：

@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(ConnectionFactory connectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setSubscriptionDurable(false); // 非持久化订阅设置
    // 如果是持久化订阅，需保证每个消费者的clientId和订阅名唯一：
    // factory.setClientId("consumer-node-b1");
    return factory;
}

配置生效原理 #

• STRICT负载均衡策略会让消息被转发到所有集群节点（在max-hops范围内），而不是只转发到有消费者的单个节点；
• MULTICAST地址类型确保每个节点收到消息后，会广播给该节点上的所有Topic订阅者；
• 两者结合后，生产者发送的每条消息都会被复制到所有集群节点，每个跨节点的消费者都能收到完整的消息副本，和本地模式的行为完全一致。

重新部署修改后的Broker集群和消费者，你应该就能看到三个消费者各自收到消息副本的预期效果了。

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