在 RocketMQ 中，消息在被消费者消费后并不会立即删除，而是根据消息的 存储策略 来决定是否删除。这一行为与消息的持久性、消费确认和消息的过期时间等因素密切相关。

消息消费后的删除机制

1. 消息消费确认（Acknowledgment）：

   • 在 RocketMQ 中，消费者从 Broker 拉取消息后，会处理这些消息。消息的消费确认通常是通过更新消息的 消费进度（offset） 来实现的。
   • 消费者在成功处理完消息后，向 Broker 发送消费确认，Broker 会更新该消费者对应消息队列的消费偏移量（offset）。
   • 消费确认 并不意味着消息会被立即删除。只有在满足特定条件时，消息才会被删除。

2. 消息的存储：

   • RocketMQ 将消息存储在 消息队列（Message Queue） 中，每个队列可以存储多个消息。消息队列内部的消息是基于磁盘存储的。
   • 消息存储的时间由消息的 过期时间 或 日志保留策略（如 broker配置 中的 messageStore 配置）决定。

3. 消息的删除机制： 消息在 RocketMQ 中的删除机制主要与 消息过期 和 Broker 存储配置 有关，具体如下：

   • 消息过期：RocketMQ 中的消息有过期时间，过期时间由 Broker 配置参数 messageStore 决定。通常消息在存储一定时间后会被删除，这与消息是否被消费无关。例如，可以通过配置 brokerMessageRetention 来设置消息的最大存储时间。

   • 消费者未确认的消息：如果消费者拉取了消息但没有确认（即没有提交消费进度），这些消息会保留在队列中，直到消息被确认或者超出设置的最大存储时间。即使消息被消费者消费，它仍然可能在队列中存在，直到达到删除条件。

4. 消费模式对消息删除的影响：

   • 在 推送模式（Push） 中，消费者拉取消息并且成功消费后，RocketMQ 会按照消息的消费进度（offset）进行跟踪，并保证消息在达到过期时间前不会删除。
   • 在 拉取模式（Pull） 中，消费者主动拉取消息后，消息会保持在队列中，直到消费者提交了消费确认并更新了消费进度。

5. 消息的删除条件

消息的删除有以下几种条件：

• 消费确认后： 如果消息已经被消费者成功消费，并且消费者提交了消费进度，Broker 会将该消息标记为已消费。当消息过期或者达到消息存储的最大保留时间时，消息会被删除。

• 消息过期： RocketMQ 会根据消息的最大存储时间来删除过期的消息。例如，如果配置了 brokerMessageRetention 为 48 小时，那么消息将在存储超过 48 小时后被自动删除，而不管它是否被消费。

• 日志清理策略： RocketMQ 会根据配置的 日志清理策略 来定期清理过期或不再需要的消息。管理员可以配置相关的参数，设置消息的最大存储时长、最大存储数量等。

  • 配置参数例如：
    • brokerMessageRetention：设置消息保留时间，单位为毫秒。
    • fileReservedTime：设置消息存储在文件中的最大保留时间。
    • cleanFileInterval：设置清理消息文件的时间间隔。