Apache Artemis联邦priority-adjustment优先级调整工作机制详解

核心基础定义 #

首先明确：该参数是队列联邦（Federation）的专属配置，仅作用于联邦建立时、由对端集群consumer触发本地生成的「上游联邦consumer」，不影响普通本地队列的消费逻辑，也和消息本身的优先级属性完全无关。
默认工作逻辑：当远端consumer接入联邦时，本地broker会在本地队列生成对应的临时上游consumer，其优先级 = 对端consumer的原始优先级 + priority-adjustment。官方默认配置为-1，目的是让该上游consumer优先级比本地同队列的consumer低1，保障本地消费优先。

纠正初始认知误区：开发者提到的“调整值为-1时优先转发远端”是错误推导，默认-1的实际效果是本地consumer优先于联邦上游consumer被调度。

常见疑问逐一解答 #

疑问1：priority-adjustment设置为≥0的整数时，远端consumer上线后是否优先投递到远端？ #

• 是的，具体逻辑分两种情况：
  • 设为0：联邦上游consumer的优先级和本地同队列consumer的基础优先级完全相等，此时broker会对两类consumer做轮询负载均衡，不会偏向某一端。
  • 设为正整数（如1、2）：联邦上游consumer的优先级比本地consumer高对应数值，broker会优先调度优先级更高的联邦上游consumer，也就是消息会优先投递给远端集群的consumer，只有当远端联邦consumer全部下线、无可用上游consumer时，才会回退到本地consumer消费。

疑问2：双集群场景下priority-adjustment为负值时的消息转发逻辑 #

• 该场景下联邦上游consumer的优先级会被降低对应数值（如设为-1则低1，-2则低2），调度逻辑为：
  1. 只要本地有同队列的活跃consumer，且消费能力可以承接队列流量，所有消息都会优先投递给本地consumer，联邦上游consumer不会被调度。
  2. 只有当本地consumer全部下线、或本地consumer消费能力不足导致队列积压，低优先级的联邦上游consumer才会被触发调度，承接剩余积压消息。
  3. 由于Artemis的负载均衡规则是同一时间只会把消息投递给一个选中的consumer，因此该场景下不会出现重复消费，完全适配双集群迁移时“老集群consumer未迁完就继续用老集群，迁完自动转新集群”的需求。

疑问3：设置为非-1、非0的其他数值的作用逻辑 #

这类配置本质是通过调整优先级差值，实现更细粒度的流量控制权，常见用法分两类：

• 更低的负值（如-2、-3）：进一步压低联邦上游consumer的优先级，只有当本地consumer的消费能力出现大面积缺口（如大部分本地consumer下线、本地积压量超过阈值）时才会触发远端转发，适合“尽量保留本地消费、仅用远端做兜底”的灰度场景，比如双集群迁移初期，希望老集群尽量承接全部流量，仅在老集群consumer故障时才将流量切到新集群。
• 正整数（如+1、+2）：抬高联邦上游consumer的优先级，优先把流量切到远端集群，仅用本地consumer做兜底，适合蓝绿部署、金丝雀发布的全量切流场景，比如新集群验证通过后，设为+2让消息优先投给新集群的consumer，仅当新集群consumer全部故障时才回退到老集群消费，避免消息丢失。
• 多层联邦场景下还可通过不同层级的调整值组合，指定跨多集群的消息流转优先级，比如三层联邦中设置中间层向上层联邦的调整值为+1，即可让消息优先跨两级流转到最远端的consumer。

疑问4：为什么ActiveMQ普通优先级规则不适用于该参数？ #

两者属于完全不同层面的配置，无任何关联：

• ActiveMQ Classic的普通消息优先级是消息本身的属性，作用于队列内部的消息排序：优先级高的消息会被排在队头，优先投递给所有可用consumer。
• Artemis的priority-adjustment是联邦consumer的权重配置：仅用来调整「本地consumer」和「联邦生成的上游consumer」之间的负载均衡调度优先级，不修改任何消息的属性，也不影响队列内消息的排序逻辑，和消息本身的优先级没有任何绑定关系。

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