RocketMQ 通过多层次的机制来确保消息不丢失，涵盖从生产者发送到消费者处理的整个过程。以下是主要保障措施：

1. 生产者端保障

• 同步发送模式：使用 send() 方法而非 sendOneway()，确保收到Broker确认响应
• 事务消息：支持分布式事务消息，通过二阶段提交保证消息和本地事务的一致性
• 失败重试：内置重试机制（默认重试2次）
• 刷盘确认：生产者可等待Broker刷盘完成后再返回发送成功状态

2. Broker端保障

• 同步刷盘：配置 flushDiskType=SYNC_FLUSH 确保消息持久化到磁盘后才返回确认
• 同步复制：主从模式下配置 brokerRole=SYNC_MASTER，确保消息同步到从节点后才返回确认
• 持久化存储：消息存储在CommitLog文件中，定期做Checkpoint
• 高可用部署：主从架构，主节点故障时从节点可继续服务

3. 消费者端保障

• 可靠消费：消费者正确返回 CONSUME_SUCCESS 状态
• 消费重试：消费失败时可通过重试队列重新消费（最多16次）
• 手动ACK：确保业务处理完成后再确认消息
• 消费位点持久化：定期将消费进度持久化，避免重复消费或消息丢失

4. 其他保障措施

• 定期备份：Broker定期备份消息数据
• 监控告警：监控消息堆积、消费延迟等指标
• 消息轨迹：记录消息全链路轨迹，便于排查问题

最佳实践配置示例

java

// 生产者配置
DefaultMQProducer producer = new DefaultMQProducer("group_name");
producer.setNamesrvAddr("name-server-ip:9876");
producer.setRetryTimesWhenSendFailed(3); // 发送失败重试次数
producer.start();


// 同步发送消息
try {
    SendResult result = producer.send(msg);
} catch (Exception e) {
    // 处理异常，可记录日志并人工介入
}


// Broker配置(conf/broker.conf)
brokerRole=SYNC_MASTER  # 同步复制
flushDiskType=SYNC_FLUSH  # 同步刷盘

通过以上多层次的保障措施，RocketMQ能够在绝大多数场景下确保消息不丢失。但在极端情况下（如所有副本同时故障），仍需结合业务层面的补偿机制来确保数据完整性。