RabbitMQ集群内存持续耗尽问题排查及Quorum队列表疑问

一、Quorum队列表是什么？ #

Quorum队列是RabbitMQ专为分布式高可用场景设计的队列类型，基于Raft共识协议实现。它会将队列数据复制到集群中的多个节点（默认3个，匹配你的3节点集群），所有副本通过Raft协议同步日志，确保任意节点故障时数据不丢失、服务不中断。和传统镜像队列相比，它的一致性更强、脑裂风险更低，是RabbitMQ推荐用于关键业务场景的队列类型。

二、Quorum队列表大小每日增长的常见原因 #

• 未确认消息持续堆积：如果消费者没有对已接收的消息发送确认（ack），Quorum队列会一直保留这些未确认的消息（包括已投递但未完成ack流程的消息）。哪怕流量和队列总数看起来稳定，只要未ack消息不断累积，队列的内存占用就会持续上升。
• 死信消息无人处理：如果你的Quorum队列配置了死信交换（DLX），但对应的死信队列没有消费者处理消息，死信会持续堆积，间接导致原队列的元数据或未清理的关联日志占用内存。
• Raft日志无法正常截断：Quorum队列的Raft复制日志本应在消息被所有副本确认且消费者ack后自动截断，但如果集群中某个节点长期处于不可用状态（哪怕是短暂网络波动后恢复缓慢），日志截断逻辑会被阻塞，旧日志会一直留在内存里。
• 磁盘IO瓶颈导致持久化滞后：Quorum队列的消息默认是持久化的，如果节点磁盘IO性能差，消息写入磁盘的速度跟不上生产速度，内存中会暂存大量未完成持久化的消息数据，导致内存占用攀升。
• 版本bug导致内存泄漏：部分早期版本的RabbitMQ（比如3.8.x的某些旧版本）存在Quorum队列的内存泄漏问题，即使业务流量稳定，内存也会缓慢增长。

三、具体排查步骤 #

• 检查未确认消息数：执行命令 rabbitmqctl list_queues name messages_unacknowledged，查看每个Quorum队列的未确认消息数量，确认是否有持续增长的队列。
• 核查死信队列状态：用 rabbitmqctl list_queues name messages 查看所有死信队列的消息堆积情况，若有大量死信，需及时添加消费者处理或调整死信策略。
• 查看Raft日志截断状态：通过RabbitMQ管理界面的队列详情页，或执行 rabbitmqctl quorum_queue_status <队列名称>，检查队列的Raft日志是否正常截断，是否存在大量未清理的旧日志。
• 监控磁盘IO性能：查看集群节点的磁盘写入延迟、IO使用率，确认是否因为磁盘性能不足导致持久化操作滞后。
• 检查RabbitMQ版本：如果使用的是3.8.x早期版本或更旧的版本，建议升级到最新稳定版，修复已知的内存泄漏bug。
• 分析内存占用明细：执行 rabbitmqctl status，查看输出中memory字段的细分项，或通过管理界面的内存监控面板，确认内存是被队列消息、Raft日志，还是连接/信道等其他组件占用。

内容的提问来源于stack exchange，提问作者horak90