ActiveMQ Artemis灾场景下未路由消息的日志恢复问题

场景回顾 #

broker1正常运行，通过JMS与application1、application2通信，消息从application2经broker1路由至application1。运行期间application1意外宕机，broker1持续接收application2发送的消息，导致大量未路由消息堆积。随后broker1宕机重启，application1也已重启，application2全程正常运行。重启broker1后，需恢复未路由消息并重发给application1，但恢复失败。

已尝试操作 #

• 配置AMQP broker连接的存储转发镜像功能，但重放时未路由消息未被重放，方案无效。
• 确保消息头设置persistence="true"，期望未路由消息镜像后被记录到journal中。
• 通过日志及控制台确认broker1与其镜像已成功建立连接。

疑问澄清 #

你假设消息在broker与镜像间传输时会被记录到journal，进而通过重放功能重新路由，这个假设存在偏差：

• 镜像功能的核心是同步消息到备用broker，而非为本地重放存储消息；
• 正常情况下，broker重启后，持久化的未消费消息会自动投递给重新上线的consumer（application1），无需手动重放。

问题原因分析 #

1. 镜像配置不完整：当前<mirror>标签为空，ActiveMQ Artemis不会自动镜像所有地址/队列，必须明确指定要镜像的资源，否则镜像broker不会同步任何消息。
2. 自动投递未触发的可能原因：队列持久化配置错误、consumer ack模式异常、消息被误标记为已消费，或者broker加载journal时出现异常。
3. 重放功能误用：journal重放主要用于broker故障后重建自身状态，不是未消费消息的常规投递方式。

解决步骤 #

1. 完善镜像配置 #

在原broker和镜像broker的<mirror>标签内添加需要同步的地址或队列，例如：

原broker镜像配置

<broker-connections>
   <amqp-connection uri="tcp://artemis-mirror:5674" name="mirror" retry-interval="1000" user="myuser" password="mypassword">
      <mirror>
         <!-- 镜像所有地址 -->
         <include address="*"/>
      </mirror>
   </amqp-connection>
</broker-connections>

镜像broker反向配置

<broker-connections>
   <amqp-connection uri="tcp://artemis-broker:5672" name="original" retry-interval="1000" user="myuser" password="mypassword">
      <mirror>
         <include address="*"/>
      </mirror>
   </amqp-connection>
</broker-connections>

2. 验证消息自动投递机制 #

• 检查目标队列的持久化配置（默认开启，可确认）：

  <address name="your-target-address">
     <anycast>
        <queue name="your-target-queue" persistence-enabled="true"/>
     </anycast>
  </address>
  

• 确认application1的consumer使用正确的ack模式（如AUTO_ACKNOWLEDGE或CLIENT_ACKNOWLEDGE），避免消息被误标记为已消费。
• 通过Artemis控制台查看队列的Messages Pending统计，确认未消费消息的数量是否符合预期。

3. 正确使用journal重放（仅当自动投递失效时） #

若需手动重放journal中的消息，使用Artemis自带的journal-replay工具：

# 替换为实际的journal目录和输出目录
./artemis journal-replay --directory ./data/journal --output-directory ./data/replay

将重放后的journal文件替换到broker的journal目录，重启broker即可。

4. 排查日志异常 #

查看broker启动日志，重点关注以下内容：

• journal加载时的错误提示
• 队列初始化异常
• consumer连接与消息投递的相关日志

使用版本：ActiveMQ Artemis 2.33.0

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