ActiveMQ Artemis 2.31.2 DLQ队列分配异常问题咨询

核心问题原因 #

你遇到的死信消息随机分配到DLQ的问题，本质是手动创建DLQ队列时未设置匹配原队列的过滤规则。

当auto-create-dead-letter-resources=true时，Artemis会自动为每个原队列创建对应的DLQ队列，并添加过滤条件_AMQ_ORIG_QUEUE_NAME = '原队列名'，确保死信消息只会路由到对应原队列的DLQ。但你通过session.createQueue("DLA::" + queueName + ".DLQ")手动创建DLQ时，并未设置这个过滤规则，导致所有DLQ队列都绑定在DLA地址下且无过滤条件，Artemis会采用轮询方式将死信消息随机分配到任意DLQ队列。

另外，你使用同一个事务会话处理原队列和DLQ消息的做法也存在风险：原队列消息处理失败回滚时，会同时回滚DLQ会话中未提交的操作，导致DLQ消息重复投递。

具体解决步骤 #

1. 为DLQ队列添加正确的过滤规则 #

使用Artemis专属的JMS API创建DLQ队列时，显式指定过滤条件，确保只有对应原队列的死信消息能进入该DLQ：

import org.apache.activemq.artemis.jms.client.ActiveMQJMSClient;

// 遍历创建每个DLQ的监听器
for (String queueName : Arrays.asList("queue1", "queue2", ..., "queue8")) {
    // 创建带过滤规则的DLQ队列
    Queue dlqQueue = ActiveMQJMSClient.createQueue(
        "DLA", 
        queueName + ".DLQ", 
        "_AMQ_ORIG_QUEUE_NAME = '" + queueName + "'"
    );
    
    // 创建DLQ消费者并设置监听器（注意使用独立会话，见步骤2）
    Session dlqSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    dlqSession.createConsumer(dlqQueue).setMessageListener(message -> {
        try {
            LOGGER.info("DLQ msg in queue: {}", queueName);
            message.acknowledge();
        } catch (JMSException e) {
            LOGGER.info("JMSException acknowledging a DLQ message: {}", e.getMessage());
        }
    });
}

2. 使用独立会话处理DLQ消息 #

将原队列处理会话与DLQ监听会话分离，避免事务操作互相干扰：

• 原队列使用事务会话（Session.SESSION_TRANSACTED）处理消息
• DLQ使用非事务会话（Session.AUTO_ACKNOWLEDGE或Session.CLIENT_ACKNOWLEDGE）独立处理死信

3. 清理现有无效DLQ队列 #

在应用重启前，删除Broker中已创建的无过滤规则的DLQ队列（如queue1.DLQ、queue2.DLQ等），避免残留队列影响路由逻辑。

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