如何用ActiveMQ Artemis实现公平队列？Queue-Selector负载异常

针对你遇到的Selector方案在高负载下的延迟问题，以下是几种基于ActiveMQ Artemis原生功能的解决方案，从根源上避免日志扫描开销，保证公平调度：

方案1：消息分组（Message Grouping）+ 共享消费者 #

这是最贴合你需求的方案，无需Selector，利用Artemis的分组路由机制实现不同公司消息的并行处理：

• 发送消息时为每个公司设置唯一的JMSXGroupID属性（比如company-A、company-B）
• 为队列配置多个共享消费者（使用相同的消费组名称）

Artemis会自动将同一公司的消息路由到固定的消费者，但不同公司的消息会分配给空闲的消费者处理。这样：

• A公司的大量消息会被一个或多个消费者持续处理
• B公司的消息进入队列后，会立即被分配给空闲的消费者，无需等待A的消息全部处理完毕
• 完全避免了Selector带来的日志扫描开销，高负载下性能更稳定

代码示例 #

发送消息时设置分组ID：

Message message = session.createTextMessage("A公司业务消息");
message.setStringProperty("JMSXGroupID", "company-A");
producer.send(message);

创建共享消费者：

// 多个消费者使用同一个消费组名称"order-consumers"，即共享消费者
MessageConsumer consumerA = session.createSharedConsumer(queue, "order-consumers");
MessageConsumer consumerB = session.createSharedConsumer(queue, "order-consumers");

方案2：优化Selector方案的性能（保留原有架构） #

如果必须保留Selector机制，可以通过配置优化减少日志扫描的开销：

• 为消息属性创建索引：在broker.xml中为company属性添加索引，让Broker快速定位匹配Selector的消息：

  <address name="your-address">
    <multicast>
      <queue name="your-queue">
        <indexed-properties>
          <property name="company"/> <!-- 为company属性创建索引 -->
        </indexed-properties>
      </queue>
    </multicast>
  </address>
  

• 减小日志分段大小：缩小单个日志文件的体积，降低扫描范围，默认100MB可调整为50MB：

  <journal-file-size>52428800</journal-file-size> <!-- 50MB -->
  

• 开启异步分发：让Broker异步分发消息，避免阻塞：

  <queue name="your-queue" async-dispatch="true"/>
  

方案3：优先级队列（可选） #

如果需要优先保障B公司消息的处理速度（非严格公平，但能解决延迟），可以配置队列的优先级层级：

• 在broker.xml中设置队列的最大优先级：

  <address name="your-address">
    <multicast>
      <queue name="your-queue" max-priority="10"/>
    </multicast>
  </address>
  

• 发送消息时为B公司设置更高的优先级：

  // A公司消息用优先级5，B公司用优先级8
  message.setJMSPriority(8);
  

推荐方案 #

优先选择方案1，它从根源上避免了Selector的日志扫描问题，完美满足单队列下多公司消息公平并行处理的需求，且配置简单，高负载下稳定性更强。

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