RocketMQ 消费中 Broker 端处理逻辑

RocketMQ 是一种分布式的消息中间件，它支持多种消息模式，包括发布 / 订阅模式、点对点模式和事务消息模式。本文将重点介绍 RocketMQ 消费中 Broker 端处理逻辑。

1.Broker 接收消息

当 Producer 发送消息时，Broker 会接收到消息，并将消息存储在内存和磁盘中，然后将消息发送给消费者。

2.Broker 处理消息

当消费者收到消息时，Broker 会将消息放入内存队列中，并将消息的状态更新为“发送中”状态。如果消息发送成功，Broker 会将消息的状态更新为“发送成功”，如果消息发送失败，Broker 会将消息的状态更新为“发送失败”。

3.Broker 更新消息状态

当消息发送成功或失败后，Broker 会将消息的状态更新到磁盘上，以便消息可以持久化。如果消息发送失败，Broker 也会根据消息的重试次数来重新发送消息，以确保消息可以发送成功。

4.Broker 确认消息

当消息发送成功后，Broker 会向 Producer 发送确认消息，以通知 Producer 消息已经发送成功。如果 Producer 收到确认消息，则表示消息发送成功，如果 Producer 没有收到确认消息，则表示消息发送失败。