在 CentOS 上避免 RabbitMQ 消息丢失的实用方案
一 核心原则
- 从链路入手，分别在生产者、Broker、消费者三端建立确认与持久化闭环，才能显著降低消息丢失概率。
- 持久化包含Exchange、Queue、Message三处，通常需同时开启；持久化会带来一定性能开销，需在可靠性与吞吐量间权衡。
- 确认机制包含生产者确认 Publisher Confirms与消费者确认 Manual Ack；未确认消息会占用内存，应配合预取限制 prefetch与重试/死信策略共同使用。
二 生产者侧保障
- 开启发布确认 Publisher Confirms：将信道置为 confirm 模式，监听 ack/nack；为每条消息设置唯一 ID（如 CorrelationData），收到 nack 或超时进行可靠重发；如需捕获“到达交换机但未路由到队列”的情况，开启Return 回调并将发送设为mandatory。注意 confirm 与事务是互斥的，优先使用 confirm。示例（Java 原生）：channel.confirmSelect()；发送后通过 addConfirmListener 处理 ack/nack；开启 ReturnCallback 处理路由失败。示例（Spring AMQP）：spring.rabbitmq.publisher-confirm-type=correlated、publisher-returns=true、template.mandatory=true，并在 RabbitTemplate 中设置 ConfirmCallback/ReturnCallback。
- 路由失败兜底：对 mandatory=true 的消息，若无法路由到队列，会触发 ReturnCallback，可在此记录并转入重试队列或人工处理。
三 Broker 侧保障
- 持久化三要素：创建durable=true 的 Exchange 与 Queue，发送消息时将deliveryMode 设为 2（PERSISTENT_TEXT_PLAIN）；注意非持久化对象在重启后会丢失，且“队列持久化≠消息自动持久化”。为降低重启前未落盘消息的小概率丢失风险，持久化应与Publisher Confirms配合（只有落盘后才会 ack）。
- 高可用与容灾：单机宕机仍可能丢数据，建议基于镜像队列/仲裁队列（Quorum Queue）做高可用。示例策略（经典镜像，适用于老版本）：rabbitmqctl set_policy ha-all “^myQueue$” ‘{“ha-mode”:“all”,“ha-sync-mode”:“automatic”}’；新业务优先评估仲裁队列以获得更强一致性与恢复能力。
- 大堆积与启动优化：对持久化队列开启惰性队列（Lazy Queue），将消息主要存储在磁盘，减少内存压力并加快节点恢复。RabbitMQ 3.12 起惰性队列默认开启，3.8 需手动配置。
四 消费者侧保障
- 关闭自动确认，采用手动 Ack：在消费处理完成后显式调用 basicAck；处理中若发生异常，可拒绝消息（basicNack/basicReject）并选择重新入队或转入死信队列（DLQ），避免消息在消费者崩溃时丢失。
- 控制未确认消息堆积：设置合理的prefetch（如 10～100，视业务而定），防止未 ack 消息过多导致内存压力与吞吐下降。
- 失败重试与隔离：对可重试业务配置有限次数重试（带退避），重试耗尽后送入DLQ；DLQ 可单独监控、分析与重放，避免影响主流程。
五 快速检查清单与 CentOS 常用命令
- 配置核对清单
- 生产者：已开启Publisher Confirms/Returns，每条消息有唯一 ID，失败可重发；mandatory 路由失败有兜底。
- Broker：Exchange/Queue/Message 均为持久化；队列启用Lazy；关键队列已配置HA/仲裁；有DLQ与监控告警。
- 消费者：手动 Ack、合理prefetch、异常与超时策略、重试与DLQ落地。
- CentOS 常用操作
- 查看服务状态：sudo systemctl status rabbitmq-server
- 启用管理插件：sudo rabbitmq-plugins enable rabbitmq_management
- 查看日志：tail -f /var/log/rabbitmq/rabbit@*.log
- 设置镜像策略（示例）：rabbitmqctl set_policy ha-all “^myQueue$” ‘{“ha-mode”:“all”,“ha-sync-mode”:“automatic”}’
- Web 管理界面：http://<服务器IP>:15672（默认账号密码在首次启用后自行设置）。