RocketMQ如何保证消息不丢失

同步发送消息，那为什么还会有异步，因为异步发送效率高。

存储消息 通过配置持久化策略。 存储消息的过程，先存到内存page cache，再持久化到磁盘，默认配置是直接到内存后就返回成功了,但是如果这时候机器断电了,就会丢失消息,需要配置成落磁盘后再返回成功。 那如果这台机器故障死机了怎么办?—主从

消费者执行完业务逻辑，再反馈会Broker说消费成功,这样才可以保证消费阶段不丢消息。有些业务场景为了快速消费数据就拿到消息后直接返回成功，但是有可能消费数据失败，那这条数据对下游来说就等于丢失了。