症状分析
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