一、RocketMQ 在存储阶段保证消息不丢失的措施

      RocketMQ通过刷盘机制、消息拉取机制和ACK机制等多种方式来确保消息投递的可靠性，防止消息丢失。

二、详解各个措施

1.刷盘机制

      RocketMQ中的消息分为内存消息和磁盘消息，内存消息在Broker内存中进行读写，磁盘消息则保存在磁盘上。RocketMQ支持同步刷盘和异步刷盘两种方式，通过刷盘机制可以确保消息在Brocker宕机时不会丢失。在同步刷盘模式下，消息写入磁盘时，会等待磁盘写入完成才返回写入成功的响应。在异步刷盘模式下，消息写入磁盘后立即返回写入成功的响应，但不等待磁盘写入完成。

2. ACK机制

      在RocketMQ中，Producer发送消息后，Brocker会返回确认信号，表示发送成功。如果Brocker未收到ACK确认信号，则会尝试重新发送消息，直到收到确认消息。
      RocketMQ采用主从复制机制，每个消息队列都有一个主节点和多个从节点。主节点负责消息的写入和读取，从节点负责备份数据。当主节点宕机时，从节点会自动接管主节点的工作，确保消息不会丢失。

3.消息存储机制

      RocketMQ默认采用双写模式存储消息，即将消息同时写入内存和磁盘，然后异步将内存中的消息刷盘到磁盘中。这种方式确保了消息的可靠性，即使系统宕机，也尽可能地避免消息丢失。
      此外，RocketMQ还提供了多种机制来保证消息不丢失，例如事务消息、延迟消息、顺序消息等，可以根据业务需要选择和使用。
      值得注意的是，为了保证消息的可靠性，RocketMQ发送消息的速度可能收到一定的限制，需要在消息可靠性和性能之间做出权衡。