← 中文资源

简体中文版本

RabbitMQ 消息在消费前 TTL 过期

RabbitMQ 丢弃消息,因为队列或消息 TTL 在消费者处理前过期,高负载下导致静默消息丢失。

阅读英文原文

症状分析

RabbitMQ 丢弃消息,因为队列或消息 TTL 在消费者处理前过期,高负载下导致静默消息丢失。 该错误在生产环境中出现,但可能不会在本地开发中复现,因为触发条件依赖于部署环境或运行时配置。理解完整的症状集合有助于将此问题与类似错误区分开来。

诊断实践

按照前置事项中的诊断步骤定位原因。每个步骤包含命令和输出解读。目标是缩小问题范围:配置、运行时还是应用代码。在最小化环境中复现错误后再应用修复。

根因

The message TTL expires before a consumer picks up the message, so RabbitMQ removes it from the queue and optionally routes it to a dead-letter exchange.

修复

Increase the queue or message TTL, add more consumers, or route expired messages to a dead-letter queue for retry. Monitor consumer lag to detect saturation. 应用修复后,监控系统以确认错误在负载下或不同环境中不再复现。

验证

Publish a message and confirm it is consumed within the TTL; verify expired messages go to the DLQ if configured. 如果验证通过,修复即确认;如果未通过,重新检查诊断步骤中是否遗漏了促成因素。

诊断命令

运行以下命令复现和诊断问题:

rabbitmqctl list_queues name arguments messages
rabbitmqctl list_consumers