Java 中怎么使用 RabbitMQ 的死信队列（Dead Letter Exchange）处理异常重试与超时消息-java教程-PHP中文网

rabbitmq死信队列通过配置死信交换机与队列、设置业务队列的x-dead-letter-exchange等参数，并结合ttl或消费者拒绝机制，自动将超时或重试失败的消息路由至dlq，实现异常处理与延迟任务。

java 中怎么使用 rabbitmq 的死信队列（dead letter exchange）处理异常重试与超时消息

Java 中使用 RabbitMQ 死信队列（DLQ）处理异常重试与超时消息，核心在于**配置死信路由规则 + 控制消息“死亡”时机 + 分离业务与兜底逻辑**。它不是靠代码主动发送，而是由 RabbitMQ 自动触发转发，关键在队列声明时的参数设置和消费者行为设计。

配置死信交换机与死信队列

死信队列本身是普通队列，需先声明一个专用队列接收“问题消息”，再绑定到一个交换机（通常是 direct 类型）：

声明死信队列：如 dlx.queue，持久化、非排他、非自动删除
声明死信交换机：如 dlx.exchange，类型为 direct
绑定二者：用 routing key（如 dlx.routing.key）完成绑定

这部分可通过 Spring AMQP 的 @Bean 配置类或 RabbitMQ 管理界面完成，无需手动发消息。

让业务队列“产生死信”

业务队列必须显式配置三个关键参数，才能把符合条件的消息转给上面的死信交换机：

x-dead-letter-exchange：填死信交换机名（如 "dlx.exchange"）
x-dead-letter-routing-key：填绑定时用的 routing key（如 "dlx.routing.key"），不填则默认沿用原消息的 routing key
配合触发条件选配：
• x-message-ttl：设毫秒值（如 300000 表示 5 分钟），用于超时场景
• x-max-length：限制队列最大长度，防堆积
• 不设 TTL 时，靠消费者 basic.nack(requeue=false) 或 basic.reject(requeue=false) 主动拒绝来触发

例如用 QueueBuilder 声明带 TTL 和死信的延迟队列：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

Queue delayQueue = QueueBuilder.durable("order.delay.queue")
.withArgument("x-dead-letter-exchange", "dlx.exchange")
.withArgument("x-dead-letter-routing-key", "dlx.routing.key")
.withArgument("x-message-ttl", 300_000)
.build();

异常重试：控制重试次数后进 DLQ

避免无限重试拖垮服务，需在消费者中记录并判断重试次数：

从消息 header 中读取 retry-count（首次为 0）
处理失败时，将该值 +1 后重新发布回原队列（可加短 TTL 实现退避），或直接 nack 并设 requeue=false
当 retry-count ≥ 阈值（如 3），调用 channel.basicNack(deliveryTag, false, false)，消息立刻进 DLQ

注意：Spring Boot 的 @Retryable 是客户端重试，失败后仍需手动 nack 才能进 DLQ；不能只依赖框架重试而不做死信引导。