RabbitMQ 死信队列原理与配置实战

场景一：消息过期

设置 TTL

在队列配置中设置消息生存时间（TTL），超过时间的消息将变为死信。

生产者代码

@RequestMapping("/dl")
public String dl() {
    System.out.println("dl...");
    rabbitTemplate.convertAndSend(Constants.NORMAL_EXCHANGE, "normal", "dl test...");
    System.out.printf("%tc 消息发送成功 \n", new Date());
    return "消息发送成功";
}

消费者代码

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import java.util.Date;

@Component
public class DLListener {
    @RabbitListener(queues = Constants.DL_QUEUE)
    public void dlHandMessage(Message message, Channel channel) throws Exception {
        System.out.printf("[dl.queue] %tc 接收到消息：%s, deliveryTag: %d \n", 
                new Date(), new String(message.getBody(), "UTF-8"), 
                message.getMessageProperties().getDeliveryTag());
    }
}

运行结果

消息在 10 秒后过期，从 normal 队列进入到了死信队列，并被死信消费者消费。

场景二：消息超过队列最大长度

设置队列的最大长度

配置队列的最大消息数，超出部分将被视为死信。

生产者代码

@RequestMapping("/dl")
public String dl() {
    for (int i = 0; i < 20; i++) {
        rabbitTemplate.convertAndSend(Constants.NORMAL_EXCHANGE, "normal", "dl test..." + i);
    }
    return "消息发送成功";
}

消费者代码

同场景一。

运行结果

给队列设置了最大长度为 10，但接收了 20 条消息，导致前 10 条消息变成死信。

场景三：消息被拒绝

生产者代码

同场景一。

消费者代码

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class DLListener {
    @RabbitListener(queues = Constants.NORMAL_QUEUE)
    public void handMessage(Message message, Channel channel) throws Exception {
        long deliveryTag = message.getMessageProperties().getDeliveryTag();
        try {
            System.out.printf("[normal.queue] 接收到消息：%s, deliveryTag: %d \n", 
                    new String(message.getBody(), "UTF-8"), deliveryTag);
            int num = 3 / 0; // 模拟异常
            channel.basicAck(deliveryTag, false);
        } catch (Exception e) {
            // 否定确认，requeue 为 false，该消息成为死信
            channel.basicNack(deliveryTag, false, false);
        }
    }
}

运行结果

normal 队列中的消息因业务逻辑异常被拒绝，且未重新入队，消息变为死信并进入死信队列。

常见问题

1. 死信队列的概念 死信是消息队列中的一种特殊消息，指那些无法被正常消费或处理的消息。RabbitMQ 的死信队列用于存储这些消息。

2. 死信的来源

   • 消息过期：存活时间超过设定的 TTL。
   • 消息被拒绝：消费者拒绝处理且指定不重新入队（requeue=false）。
   • 队列满了：达到最大长度，新消息被处理为死信。

3. 死信的应用场景

   • 异常分析：应用程序通过消费死信队列内容分析异常情况。
   • 订单支付：保证支付信息不丢失，异常时投入死信队列由人工或其他服务处理。
   • 消息重试：将死信消息重新发送到原队列或另一队列进行重试。
   • 日志收集：将死信消息作为日志收集，用于后续问题定位。