RabbitMQ 消息持久化及内存溢出防御策略

RabbitMQ 可靠性需协同落盘策略与内存管控：三重持久化（交换机、队列、消息均设持久化）、内存阈值用绝对值（如4GB）、配合惰性队列/TTL/手动ACK等机制。

要让 RabbitMQ 既不丢消息，又不爆内存，关键不是只做持久化或只调内存阈值，而是把消息落盘策略和内存管控协同起来。单独开持久化可能压垮磁盘 IO，光调高水位线又可能掩盖真实堆积问题——两者必须配合设计。

三重持久化：缺一不可的底线配置

重启后消息还在，前提是交换机、队列、消息三者全部声明为持久化。漏掉任意一个，数据就会消失。

• Exchange 创建时设 durable=true，否则重启后路由规则丢失，新消息无法投递
• Queue 声明时设 durable=true，这是基础——非持久化队列本身在节点重启后就不存在了
• 发送消息时设置 deliveryMode=2（即 PERSISTENT），仅靠队列持久化不能保证消息落地

内存阈值：用绝对值锁定风险边界

相对值配置（如 0.6）在容器或云环境中容易失准——节点内存动态分配时，阈值跟着漂移。生产环境务必用绝对值，且预留系统空间。

• 8GB 物理内存服务器，建议设 vm_memory_high_watermark.absolute = 4GB
• 同时搭配 vm_memory_calculation_strategy = rss，避免 Erlang VM 统计偏差
• 超过阈值后，RabbitMQ 会阻塞生产者，这是保护机制，不是故障，需配合监控告警及时干预

降低内存压力的持久化优化手段

全量持久化带来性能损耗，尤其在高吞吐场景。可通过以下方式减轻内存与磁盘双重负担：

• 对非核心消息（如日志、通知）启用 TTL，到期自动清理，避免长期驻留
• 启用 惰性队列（lazy queue）：消息直接写磁盘，仅消费时加载进内存，大幅降低常驻内存占用
• 关闭镜像队列冗余同步，除非强依赖高可用；单数据中心场景下，优先用普通持久化+合理备份

配套可靠性增强：确认机制不能少

持久化只是“存得住”，不代表“送得稳”。必须叠加链路级确认，形成闭环保障。

• 开启 Publisher Confirms（异步模式），确保消息真正到达 Broker
• 设置 mandatory=true + returns callback，捕获路由失败消息，防止静默丢弃
• 消费者使用 manual ack，处理完成后再确认，避免宕机导致消息丢失