一、流程图
二、消息丢失场景
2.1、场景1中生产者将消息发送给Rocket MQ的时候，如果出现了网络抖动或者通信异常等问题，消息就有可能会丢失。
2.2、场景2中消息需要持久化到磁盘中，这时会有两种情况导致消息丢失：
1、RocketMQ为了减少磁盘的IO，会先将消息写入到os cache中，而不是直接写入到磁盘中，消费者从os cache中获取消息类似于直接从内存中获取消息，速度更快，过一段时间会由os线程异步的将消息刷入磁盘中，此时才算真正完成了消息的持久化。在这个过程中，如果消息还没有完成异步刷盘，RocketMQ中的Broker宕机的话，就会导致消息丢失。
2、如果消息已经被刷入了磁盘中，但是数据没有做任何备份，一旦磁盘损坏，那么消息也会丢失。
2.3、消费者成功从RocketMQ中获取到了消息，还没有将消息完全消费完的时候，就通知RocketMQ我已经将消息消费了，然后消费者宕机，但是RocketMQ认为消费者已经成功消费了数据，所以数据依旧丢失了。
三、如何保证消息不丢失
场景1中保证消息不丢失的方案是使用RocketMQ自带的事务机制来发送消息，大致流程为：
1、首先生产者发送half消息到RocketMQ中，此时消费者是无法消费half消息的，若half消息就发送失败了，则执行相应的回滚逻辑；
2、half消息发送成功之后，且RocketMQ返回成功响应，则执行生产者的核心链路；
3、如果生产者自己的核心链路执行失败，则回滚，并通知RocketMQ删除half消息；
4、如果生产者的核心链路执行成功，则通知RocketMQ commit half消息，让消费者可以消费这条数据。