RocketMQ如何保证消息不丢失？ #

首先在如下三个部分都可能会出现丢失消息的情况：

• Producer端
• Broker端
• Consumer端

Producer端如何保证消息不丢失 #

• 采取send()同步发消息，发送结果是同步感知的。

• 发送失败后可以重试，设置重试次数。默认3次。

  producer.setRetryTimesWhenSendFailed(10);

• 集群部署，比如发送失败了的原因可能是当前Broker宕机了，重试的时候会发送到其他Broker上。

Broker端如何保证消息不丢失 #

• 修改刷盘策略为同步刷盘。默认情况下是异步刷盘的。

  flushDiskType = SYNC_FLUSH

• 集群部署，主从模式，高可用。

Consumer端如何保证消息不丢失 #

• 完全消费正常后在进行手动ack确认。