rabbitmq-queue-backlog

RabbitMQ 队列堆积

现象

队列消息数持续增长，消费者数量为 0 或消费速度低于生产速度；内存和磁盘告警，严重时触发流控，生产者被阻塞。

快速定位

rabbitmqctl list_queues name messages consumers message_stats.publish_details.rate message_stats.deliver_get_details.rate
rabbitmqctl list_connections
rabbitmqctl list_channels
rabbitmq-diagnostics status

查看告警：

rabbitmq-diagnostics alarms
rabbitmqctl list_queues name messages_ready messages_unacknowledged

常见根因

• 消费者宕机、卡死或没有订阅队列。
• 消费逻辑异常，消息不断重试。
• 生产者突增，消费能力不足。
• 消息属性错误，路由到错误队列。
• prefetch 设置过大或过小。
• 磁盘/内存达到高水位，触发流控。

修复

• 恢复消费者，检查连接和 channel。
• 增加消费者实例，提高并发。
• 配置死信队列和重试上限，避免无限重试。
• 调整 prefetch_count，平衡吞吐和公平性。
• 清理或扩容磁盘，解除流控。
• 对积压消息做限流消费或临时转储。

相关命令

• rabbitmqctl — 队列、连接、channel
• rabbitmq-diagnostics — 状态和告警
• rabbitmqadmin — HTTP API 管理
• kafka-consumer-groups — 对比消费模型