ActiveMQ 5.x非JMS的AMQP 1.0消息重发延迟如何实现

我使用的是ActiveMQ 5.15.15（非Artemis引擎），采用AMQP 1.0协议且未使用官方JMS库，具体为AmazonMQ发行版，该版本近期将升级到5.16.2，必要时我可以强制触发升级。

我当前使用兼容AMQP 1.0的rhea库对接，该库此前运行稳定，但我找不到让ActiveMQ redelivery插件适配该库的相关文档，库的维护方也不清楚该功能在ActiveMQ上的暴露方式。

我已经在服务端broker配置中开启了schedulerSupport="true"，但尝试添加各类header、投递注解、消息注解、应用属性后，仍然无法让重发插件生效。

我尝试过的键名如下，取值均为数字，比如30000代表设置30秒延迟后才允许消费者/订阅者看到队列中的消息，这些键名来自各类文档，均测试无效：

• AMQ_SCHEDULED_DELAY
• x-opt-delivery-delay
• _AMQ_SCHED_DELIVERY

我也在客户端对消息执行了release操作，标识投递失败（同时向broker传递失败标识、增加投递尝试次数），但仅投递次数正常递增，broker侧的延迟、指数退避逻辑完全未生效。

我了解STOMP协议在发布消息时支持设置header，可以更清晰地配置相关参数，但除非必要我不想切换协议栈。
我也看到过通过REST API向主题发送延迟消息的方案，但不确定该方案是否适合生产环境使用。

目前我考虑的备选方案有两个：

1. 在客户端内存中暂存消息，延迟一段时间后再重新发布或release
2. 调研STOMP协议，确认重发插件是否可在该协议下正常工作

希望有了解相关实现逻辑的开发者提供解决方案。

<!--
The Redelivery plugin extends the capabilities of destination policies with respect to message redelivery.
-->
<redeliveryPlugin fallbackToDeadLetter="true" sendToDlqIfMaxRetriesExceeded="true">
  <redeliveryPolicyMap>
    <redeliveryPolicyMap>
      <redeliveryPolicyEntries>
        <!--<redeliveryPolicy maximumRedeliveries="4" queue="SpecialQueue" redeliveryDelay="10000"/>-->
      </redeliveryPolicyEntries>
      <defaultEntry>
        <!-- 5s -> 15s -> 45s -> 135s -> 405s -->
        <redeliveryPolicy backOffMultiplier="3" initialRedeliveryDelay="5000" maximumRedeliveries="5"/>
      </defaultEntry>
    </redeliveryPolicyMap>
  </redeliveryPolicyMap>
</redeliveryPlugin>

我同时使用了auth插件，配置中有一条疑似内置进程的权限条目，我认为是示例/默认配置自带的，快速检索未找到相关文档，我可以尝试给其他用户开放权限，但当前环境每次更新/重启需要耗时最多15分钟。

<authorizationEntry admin="administrators" queue="SchedulingProcessor.>" write="scheduling-processor"/>

• 我的核心需求是实现重发延迟，即投递失败放回队列的消息，需要等待n秒后才会对消费者可见
• 最初我未添加任何特殊header/属性/注解，仅配置了重发插件，也无法生效

1. 优先调整调度内部队列权限 #

你配置中的SchedulingProcessor.>是ActiveMQ调度器的内部专用队列，所有延迟重发的消息都会临时写入该队列。当前配置仅开放了scheduling-processor角色的写权限，你需要为AMQP连接使用的账号所属角色追加该队列的读写权限，修改后的配置如下：

<authorizationEntry admin="administrators" queue="SchedulingProcessor.>" read="你的AMQP账号所属角色" write="scheduling-processor,你的AMQP账号所属角色"/>

修改后重启broker即可验证，这是非JMS客户端调度功能失效的最常见原因。

2. 调整消息投递失败的状态上报方式 #

ActiveMQ 5.x的redeliveryPlugin默认不会为AMQP 1.0协议的release操作触发延迟重发逻辑，你需要改用modified投递状态，同时携带指定参数即可触发服务端的重发策略，rhea库的调用示例如下：

// 消息处理失败时调用
delivery.modified({
  delivery_failed: true,
  undeliverable_here: false
})

无需额外添加任何消息header，服务端配置的指数退避规则会自动生效。

3. 版本升级适配 #

如果上述配置在5.15.15版本下未生效，可以强制触发升级到5.16.2，该版本修复了3个AMQP 1.0协议与redeliveryPlugin适配的已知bug，无需调整其他配置即可正常运行。

备选方案风险提示 #

客户端内存暂存消息的方案不建议生产使用，存在进程崩溃丢失消息的风险；STOMP协议虽原生支持调度功能，但无需切换协议栈，上述方案已可解决AMQP 1.0下的重发延迟需求。

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