当前位置：首页 > news >正文

RabbitMQ的死信队列的产生与处理

news 来源：原创 2025/5/17 19:29:08

在 RabbitMQ 中，消息会变成死信（Dead Letter）的常见情况有以下几种：

消息被拒绝（Rejection） 且 未被重新入队（requeue = false）
- 当消费者使用 basic.reject 或 basic.nack 拒绝消息，并且 requeue 参数设置为 false 时，RabbitMQ 不会重新投递这条消息，而是将其送入死信队列。
消息过期（TTL 过期）
- 如果队列或消息本身设置了 TTL（Time-To-Live），当消息存活时间超过 TTL 限制时，消息会被认为是死信。
队列达到最大长度（队列满了）
- 如果队列设置了 最大长度（x-max-length）或 最大字节数（x-max-length-bytes），当队列达到这个限制时，新来的消息会导致旧消息变成死信。

（1）使用死信交换机（DLX, Dead Letter Exchange）
RabbitMQ 允许我们给队列绑定一个死信交换机（DLX），当消息变成死信时，会被自动转发到 死信交换机，然后路由到 死信队列（DLQ）。

配置示例：

# 创建一个普通队列，并绑定死信交换机
rabbitmqctl set_policy DLX "my-queue" '{"dead-letter-exchange":"dlx-exchange"}' --apply-to queues

这样，my-queue 里的死信消息会被转发到 dlx-exchange 处理。

（2）监控 & 处理死信队列

（3）调整 RabbitMQ 配置，减少死信

延时队列场景举例：
预定一个会议室，两个小时后开始，要求提前十分钟通知参会人员进行开会。
如果不使用延时队列，那么就需要不断轮询，查看是否到达需要通知的时间，进行消息通知。

延时队列的实现方式：
死信队列+消息有效期
预定时间到提前十分钟通知中间有110分钟，那么创建一条通知消息，设置有效期110分钟丢入队列，不用消费者去监听，等待消息过期后路由到指定的死信队列，再去消费死信队列中的消息即可。
所以延时队列实际上是一种实现方案，而不是一种特定的队列类型。

死信消息（Dead Letter）通常是由于消息被拒绝、过期、队列满了等情况产生的。合理的处理方式是 绑定死信交换机（DLX）+ 监控死信队列，这样可以对死信进行 重试、日志分析，甚至用于 延迟消息 的场景。