中支持广播模式与集群模式。 广播模式：一个消费组内的所有消费者每一个都会处理 topic 中的每一条消息，通常用 于刷新内存缓存。 集群模式：一个消费组内的所有消费者共同消费一个 topic 中的消息，即分工协作，一 个消费者消费一部分数据，启动负载均衡， 集群模式是非常普遍的模式，符合分布式架构的基本理念，即横向扩容，当前消费者如 果无法快速及时处理消息时，可以通过增加消费者的个数横向扩容，快速提高消费能力，及 消费，如果是消费组重试主题，从重试队列偏移量为 0 开始消费；如果是普通主题，则从 队列当前的最大的有效偏移量开始消费，即 CONSUME_FROM_LAST_OFFSET 语义 的实现。 代码@4：如果从远程服务拉取最大偏移量拉取异常或其他情况，则使用-1 作为第一 次拉取偏移量。 分析，上述执行的现象，虽然设置的是 CONSUME_FROM_LAST_OFFSET，但 现象是从队列的第一条消息开 } 从队列的开始偏移量开始消费，其计算逻辑如下：  代码@1：首先通过偏移量存储器查询消费队列的消费进度。  代码@2：如果大于等于 0，则从当前该偏移量开始消费。  代码@3：如果远程返回-1，表示并没有存储该队列的消息消费进度，从 0 开始。  代码@4：否则从-1 开始消费。 4. CONSUME_FROM_TIMESTAMP 从指定时戳后的消息开始消费。 case

service Send message Receive message 先执⾏行行本地事务还是先发送消息？ 交易易型分布式事务的 RocketMQ使⽤用场景 分布式事务解决⽅方案 半消息 远程事务 特点： 1. 稳定，⽀支持⾼高并发 2. 回查机制可靠易易⽤用 3. 不不引⼊入额外的依赖 注意：回查⽅方法需要幂等 Broker 实现细节 Producer with PID

初始化 rebalance 变量 构建 offsetStore 消费进度存储对象 启动消费消息服务 向 mqClientFactory 注册本消费者 启动 client 端远程通信 启动定时任务 定时获取 nameserver 地址 定时从 nameserver 获取 topic 路由信息 定时清理下线的 borker