如何清除ActiveMQ Artemis中48小时未处理的过期队列消息？

方法一：通过地址配置自动清理 #

这是最常用的自动化方案，可通过broker的配置文件（如broker.xml）设置针对过期队列的自动清理规则：

在<address-settings>节点下添加对应过期队列的配置，示例如下：

<address-settings>
   <!-- 匹配你的实际过期队列地址，比如"expiryQueue" -->
   <address-setting match="expiryQueue">
      <!-- 每30分钟扫描一次过期消息，可根据性能调整 -->
      <message-expiry-scan-period>1800000</message-expiry-scan-period>
      <!-- 设置消息最大存活时间为48小时，超过则自动清除 -->
      <max-age>48h</max-age>
      <!-- 开启自动删除过期消息 -->
      <auto-delete-expired-messages>true</auto-delete-expired-messages>
   </address-setting>
</address-settings>

• match字段需精准匹配你的过期队列地址；
• max-age支持h（小时）、m（分钟）、s（秒）作为时间单位；
• message-expiry-scan-period控制扫描频率，避免过于频繁影响broker性能。

方法二：使用CLI命令手动清理 #

如果需要临时执行清理操作，可借助ActiveMQ Artemis的CLI工具：

# 先查看目标队列的消息状态（可选）
./artemis queue stat --url tcp://localhost:61616 --user admin --password admin --name expiryQueue

# 删除队列中存活时间超过48小时的消息
./artemis queue purge --url tcp://localhost:61616 --user admin --password admin --name expiryQueue --age 48h

执行purge命令时，--age参数指定要清除的消息的最小存活时长，符合条件的消息会被直接删除。

方法三：自定义过期处理器（灵活扩展） #

如果需要更复杂的业务逻辑（比如根据消息内容判断是否清除），可实现ExpiryHandler接口自定义处理逻辑：

import org.apache.activemq.artemis.core.server.Queue;
import org.apache.activemq.artemis.core.server.ServerMessage;
import org.apache.activemq.artemis.core.server.expiry.ExpiryHandler;

public class CustomExpiryHandler implements ExpiryHandler {
    @Override
    public void handleMessage(ServerMessage message, Queue queue) throws Exception {
        long createTime = message.getCreationTime();
        long currentTime = System.currentTimeMillis();
        // 判断消息是否已存在超过48小时
        if (currentTime - createTime > 48 * 60 * 60 * 1000) {
            queue.deleteMessage(message.getMessageID());
        } else {
            // 未满足时间条件则保留或转发到其他地址
            queue.route(message, null, false);
        }
    }
}

之后在broker.xml中配置该处理器：

<core>
   <expiry-handler-class-name>com.yourpackage.CustomExpiryHandler</expiry-handler-class-name>
</core>

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