ActiveMQ Artemis：MQTT共享订阅优先分配消息给可用消费者

我部署了ActiveMQ Artemis代理，两个MQTT消费者订阅主题$share/tasks，所有组件都配置为QoS 2。消息用轮询算法分配，完全不考虑消费者是否空闲，出现了以下问题：

• 代理先发1个慢任务，接着发2个快任务
• 消费者#1接收慢任务并开始处理
• 消费者#2接收并完成一个快任务
• 剩下的快任务被分配给消费者#1，导致这个快任务被阻塞，哪怕消费者#2此时完全空闲

我原本以为手动确认（等慢任务处理完再确认消息）能解决问题，但就算消费者#1没确认之前的消息，新消息还是会分配给它。

问题根源 #

ActiveMQ Artemis的MQTT共享订阅默认轮询策略是只按订阅者列表顺序分配，不会跟踪消费者的未确认消息数或负载状态。QoS 2的手动确认只是保证单条消息的交付可靠性，和负载均衡逻辑完全无关——代理不会因为消费者有未确认的消息就停止给它发新消息。

解决办法 #

1. 切换为带限制的轮询策略

修改Artemis的broker.xml配置，启用ROUND_ROBIN_WITH_LIMIT共享订阅策略，同时限制每个消费者的未确认消息上限：

<address-settings>
  <address-setting match="tasks">
    <default-address-routing-type>ANYCAST</default-address-routing-type>
    <!-- 启用带负载限制的轮询策略 -->
    <shared-subscription-policy>ROUND_ROBIN_WITH_LIMIT</shared-subscription-policy>
    <!-- 每个消费者最多保留1条未确认消息 -->
    <max-unacknowledged-messages-per-consumer>1</max-unacknowledged-messages-per-consumer>
  </address-setting>
</address-settings>

这个策略会自动跳过未确认消息达到上限的消费者，把新消息分给空闲的节点。

2. 升级到MQTT 5.0（若兼容）

如果你的消费者和Artemis版本支持MQTT 5.0，订阅时可以利用相关属性配合代理配置，让它更精准地跟踪消费者负载。不过需要先确认版本兼容性。

3. 自定义负载均衡策略

如果内置策略不够用，可以自己实现SharedSubscriptionPolicy接口，根据消费者的实时负载（比如未处理任务数、系统负载）动态分配消息。把自定义类打包后放到Artemis的类路径，再在broker.xml里指定使用这个策略即可。

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