ActiveMQ Artemis消费者连接分配问题及消息滞留咨询

此情况是否正常？ #

这种情况是正常的。默认情况下，Artemis客户端连接集群节点时采用轮询或随机负载均衡策略，仅依据节点连接负载选择目标，不会主动感知队列的消息积压状态。因此消费者重启后可能连接到无消息的节点，导致其他节点消息滞留。

消费者连接是否应感知集群中目标队列的消息状态？ #

默认情况下不会。客户端的连接选择逻辑与队列消息状态是分离的，这是Artemis默认设计的一部分。若需要消费者感知队列消息状态，需手动配置特定负载均衡策略或调整集群参数。

避免问题的建议 #

• 正确配置消息重分发机制：
  修改broker.xml中的全局重分发参数，示例配置：

  <cluster-connections>
    <cluster-connection name="my-cluster">
      ...
      <redistribution-delay>1000</redistribution-delay> <!-- 延迟1秒触发重分发 -->
      <redistribution-failure-wait>5000</redistribution-failure-wait>
      <max-redistribution-delay>30000</max-redistribution-delay>
      ...
    </cluster-connection>
  </cluster-connections>
  

  同时检查队列级配置，确保未单独设置redistribution-delay="-1"（关闭重分发）覆盖全局配置。

• 使用消息感知的负载均衡策略：
  在客户端连接串中添加消息感知策略，让消费者优先连接到消息积压多的节点：

  (tcp://artemis1:61616,tcp://artemis2:61616,tcp://artemis3:61616,tcp://artemis4:61616)?type=XA_CF&ha=true&retryInterval=1000&retryIntervalMultiplier=2&maxRetryInterval=32000&reconnectAttempts=-1&loadBalancingPolicy=org.apache.activemq.artemis.api.core.client.loadbalance.MessageLoadBalancingPolicy
  

• 确保集群转发配置正确：
  确认cluster-connection中的forward-when-no-consumers参数为true（默认值），当节点无消费者时，生产者消息会转发到有消费者的节点；若所有节点都无消费者，消息暂存本地，待消费者上线后通过重分发机制流转。

• 应急手动重分发：
  遇到消息滞留时，可通过Artemis CLI手动触发：

  artemis queue redistribute --name=your-queue-name --server=artemis3
  

• 定制化消费者连接逻辑（可选）：
  通过Artemis管理API查询各节点队列消息数量，在客户端启动时优先连接到消息积压的节点。此方式需额外开发，适合有特殊消费逻辑需求的场景。

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