Spring Boot中RabbitMQ消费端抛异常默认不进死信队列，需手动配置：队列声明x-dead-letter-exchange参数、消费者设manual ack并在catch中调用channel.basicNack(deliveryTag, false, false)。
Java中RabbitMQ消费端抛出自定义异常时，默认行为是触发Nack（即拒绝消息），但是否重入队列、是否进入死信交换机（DLX），取决于channel.basicNack()的参数配置以及队列是否声明了DLX相关参数。关键不是“抛异常本身”，而是你如何配置消费者和队列，让异常最终导向DLX。
确保队列已绑定死信交换机（DLX）
死信路由的前提是队列必须声明死信相关参数，否则即使消息被拒绝也不会进入DLX。
- 设置
x-dead-letter-exchange：指定死信转发的目标交换机 - 设置
x-dead-letter-routing-key（可选）：指定死信投递时的routing key；若不设，则沿用原消息的routing key - 可配合
x-message-ttl或x-max-length等触发死信，但本场景主要靠手动reject
示例（Spring AMQP中声明带DLX的队列）：
@Bean
public Queue myQueue() {
return QueueBuilder.durable("my.queue")
.withArgument("x-dead-letter-exchange", "dlx.exchange")
.withArgument("x-dead-letter-routing-key", "dlq.routing.key")
.build();
}
消费端正确配置手动ACK并捕获异常后显式reject
Spring Boot默认开启自动ACK（spring.rabbitmq.listener.simple.acknowledge-mode=auto），此时抛异常会触发Nack+requeue=true（即重回队列），无法进DLX。必须切换为手动ACK，并在catch块中调用channel.basicNack()且requeue=false。
立即学习“Java免费学习笔记（深入）”；
- 配置
acknowledge-mode: manual（Spring Boot） - 在@RabbitListener方法中注入
Channel和Message - 业务逻辑外层try-catch自定义异常，捕获后调用
channel.basicNack(deliveryTag, false, false) - 注意：第二个
false表示不重入队列，这是进DLX的关键
示例代码：
@RabbitListener(queues = "my.queue")
public void handleMessage(Message message, Channel channel, @Header Long deliveryTag) throws IOException {
try {
String body = new String(message.getBody());
// 业务处理，可能抛出MyBusinessException
process(body);
} catch (MyBusinessException e) {
// 记录日志
log.error("业务异常，拒绝消息并投递DLX", e);
channel.basicNack(deliveryTag, false, false); // ← 关键：requeue=false
}
}
避免因未关闭channel或重复nack导致异常
basicNack需保证deliveryTag有效、channel未关闭，且不能对同一消息多次nack（会报错）。
- 确保
channel来自当前消费上下文（Spring会自动注入正确channel） - 不要在finally里无条件nack，防止成功处理后又reject
- 若使用异步处理，务必保证nack发生在同一个channel线程上下文中
- 建议在catch中nack前校验channel.isOpen()
验证DLX是否生效
可通过RabbitMQ管理界面观察：
- 原队列的“Messages unacked”应为0（说明没卡住）
- DLX绑定的死信队列（如
dlq.queue）中出现对应消息 - 查看死信消息的headers，应包含
x-death字段，记录拒收原因、队列、时间等
也可在消费死信队列时打印message.getMessageProperties().getHeaders().get("x-death")确认来源。
