在CentOS上解决RabbitMQ消息丢失问题，可从生产者、服务端、消费者三方面入手，具体措施如下：

• 生产者端

  1. 启用Confirm模式：通过channel.confirmSelect()开启异步确认，确保消息成功投递到交换机，失败时可重试或记录日志。
  2. 事务机制（可选）：使用channel.txSelect()开启事务，消息发送失败时可回滚并重试，但性能较低，建议仅在关键场景使用。
  3. 消息持久化：发送消息时设置deliveryMode=2，确保消息持久化到磁盘，避免服务端重启后丢失。

• 服务端（RabbitMQ）

  1. 队列持久化：创建队列时设置durable=true，确保队列元数据不丢失。
  2. 镜像队列（高可用）：通过rabbitmqctl set_policy ha-all "队列名" '{"ha-mode":"all"}'配置镜像队列，将队列同步到多个节点，防止单点故障。
  3. 持久化配置：修改配置文件/etc/rabbitmq/rabbitmq.conf，确保消息和队列持久化参数生效。

• 消费者端

  1. 手动ACK机制：关闭自动ACK（autoAck=false），在消息处理成功后手动调用channel.basicAck()，失败时调用channel.basicNack()或channel.basicReject()，避免消息丢失。
  2. 死信队列（DLQ）：配置死信队列接收处理失败的消息，便于后续分析和重试。

• 通用措施

  1. 监控与日志：通过/var/log/rabbitmq/目录查看日志，使用监控工具（如Prometheus）实时跟踪队列状态和消息积压情况。
  2. 网络与资源检查：确保网络稳定，防火墙放行RabbitMQ端口（默认5672），并保证服务器内存、磁盘空间充足。

参考来源：