RocketMQ 采用了多种机制来保证消息的可靠性传输和消费顺序，从而确保消息不会丢失和重复消费。
1. 写入磁盘的方式：RocketMQ将消息写入磁盘来确保消息的持久性。一旦消息被存储在磁盘上，即使发生系统故障，消息也能够被保留下来，并在系统恢复后继续进行消费。
2. 快速复制方式：RocketMQ使用主从架构，在消息发送时，消息会被复制到多台机器上，保证了消息的冗余备份。在主节点故障时，副本节点可以继续提供服务，避免了消息丢失的风险。
3. 强制刷磁盘：RocketMQ在发送消息后，会强制将消息写入磁盘并确认存储成功，然后才返回成功的响应。这样可以保证消息在存储层面的持久性，避免在发生故障时，已发送但未持久化的消息丢失。
4. 消息消费的位移管理：RocketMQ会为每个消费者维护一个位移（offset），记录消费者当前消费到的消息位置。通过位移管理，RocketMQ可以保证消息不被重复消费。消费者需要定期提交消费位移，若消费者异常退出，下次启动时会从上次提交的位移处继续消费消息。
5. 幂等消费：在实际业务中，对于幂等性要求严格的操作，消费者可以在消费消息时实现幂等性处理。通过保证幂等性操作的唯一性，即使发生重复消费，也不会产生实际影响。
综上所述，RocketMQ通过将消息持久化、副本复制、强制刷盘、位移管理和幂等消费等机制，保证了消息的可靠性传输和消费顺序，有效地避免了消息丢失和重复消费的问题。
向大家推荐《Activiti工作流实战教程》:https://xiaozhuanlan.com/activiti