详解 RabbitMQ 高级特性之死信队列 | 极客日志

Javajava

详解 RabbitMQ 高级特性之死信队列

RabbitMQ 死信队列概念、成因及配置。死信源于消息过期、被拒绝重投关闭或队列满。通过配置死信交换机 DLX 将异常消息路由至死信队列。提供 Spring AMQP 代码示例，涵盖队列声明、TTL 设置、最大长度限制及消费异常处理，支持重试、丢弃或日志收集场景。

DotNetGuy发布于 2026/3/24更新于 2026/4/185 浏览

死信队列

死信（Dead Letter）是消息队列中的一种特殊消息，它指的是那些无法被正常消费或处理的消息。在消息队列系统中，如 RabbitMQ，死信队列用于存储这些死信消息。

文章配图

消息变成死信一般是由于以下几种情况：

消息被拒绝（Basic.Reject/Basic.Nack），并且设置 requeue 参数为 false。

消息过期。

队列达到最大长度。

添加配置

spring:
  application:
    name: rabbit-extensions-demo
  rabbitmq:
    addresses: amqp://study:[email protected]:5672/extension

常量类

public class Constants {
    // 死信相关常量
    public static final String NORMAL_QUEUE = "normal.queue";
    public static final String NORMAL_EXCHANGE = "normal.exchange";
    public static final String DL_QUEUE = "dl.queue";
    public static final String DL_EXCHANGE  ;
}

相关免费在线工具

Keycode 信息
查找任何按下的键的javascript键代码、代码、位置和修饰符。在线工具，Keycode 信息在线工具，online
Escape 与 Native 编解码
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。在线工具，Escape 与 Native 编解码在线工具，online
JavaScript / HTML 格式化
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。在线工具，JavaScript / HTML 格式化在线工具，online
JavaScript 压缩与混淆
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。在线工具，JavaScript 压缩与混淆在线工具，online
Base64 字符串编码/解码
将字符串编码和解码为其 Base64 格式表示形式即可。在线工具，Base64 字符串编码/解码在线工具，online
Base64 文件转换器
将字符串、文件或图像转换为其 Base64 表示形式。在线工具，Base64 文件转换器在线工具，online

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import rabbitextensionsdemo.constant.Constants;

@Configuration
public class DLConfig {
    // 正常的交换机和队列
    @Bean("normalQueue")
    public Queue normalQueue() {
        return QueueBuilder.durable(Constants.NORMAL_QUEUE)
                .deadLetterExchange(Constants.DL_EXCHANGE)
                .deadLetterRoutingKey("dlx")
                .build();
    }

    @Bean("normalExchange")
    public DirectExchange normalExchange() {
        return ExchangeBuilder.directExchange(Constants.NORMAL_EXCHANGE).build();
    }

    @Bean("normalBinding")
    public Binding normalBinding(@Qualifier("normalQueue") Queue queue, @Qualifier("normalExchange") Exchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("normal").noargs();
    }

    // 死信交换机和队列
    @Bean("dlQueue")
    public Queue dlQueue() {
        return QueueBuilder.durable(Constants.DL_QUEUE).build();
    }

    @Bean("dlExchange")
    public DirectExchange dlExchange() {
        return ExchangeBuilder.directExchange(Constants.DL_EXCHANGE).build();
    }

    @Bean("dlBinding")
    public Binding dlBinding(@Qualifier("dlQueue") Queue queue, @Qualifier("dlExchange") Exchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("dlx").noargs();
    }
}

@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 rabbitextensionsdemo.constant.Constants;
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());
    }
}

@RequestMapping("/dl")
public String dl() {
    // 测试队列长度
    for (int i = 0; i < 20; i++) {
        rabbitTemplate.convertAndSend(Constants.NORMAL_EXCHANGE, "normal", "dl test..." + i);
    }
    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 rabbitextensionsdemo.constant.Constants;
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());
    }
}

@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 rabbitextensionsdemo.constant.Constants;

@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"), message.getMessageProperties().getDeliveryTag());
            // 进行业务逻辑处理
            System.out.println("业务逻辑处理");
            int num = 3 / 0;
            System.out.println("业务处理完成");
            // 肯定确认
            channel.basicAck(deliveryTag, false);
        } catch (Exception e) {
            // 否定确认
            channel.basicNack(deliveryTag, false, false);
            // requeue 为 false, 该消息成为死信
        }
    }
}

详解 RabbitMQ 高级特性之死信队列

死信队列

添加配置

常量类

更多推荐文章

相关免费在线工具

声明队列和交换机并绑定二者关系

死信--消息过期

给队列设置 TTL

编写生产消息代码

编写消费消息代码

观察现象

死信--消息超过队列最大长度

设置队列的最大长度

编写生产消息代码

编写消费消息代码

观察现象

死信--消息被拒绝

编写生产消息代码

编写消费消息代码

观察现象

面试题

详解 RabbitMQ 高级特性之死信队列

死信队列

添加配置

常量类

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具

声明队列和交换机并绑定二者关系

死信--消息过期

给队列设置 TTL

编写生产消息代码

编写消费消息代码

观察现象

死信--消息超过队列最大长度

设置队列的最大长度

编写生产消息代码

编写消费消息代码

观察现象

死信--消息被拒绝

编写生产消息代码

编写消费消息代码

观察现象

面试题