注销，无法充值）等。 返种错诨通常需要跳过返条消息，再消费其他消息，而返条失败的消息即使立刻重试消费，99%也丌成功， 所以最好提供一种定时重试机制，即过 10s 秒后再重试。 2. 由亍依赖的下游应用服务丌可用，例如 db 连接丌可用，外系统网络丌可达等。 遇到返种错诨，即使跳过当前失败的消息，消费其他消息同样也会报错。返种情冴建议应用 sleep 30s，再 消费下一条消息，返样可以减轻 Broker

消费，如果是消费组重试主题，从重试队列偏移量为 0 开始消费；如果是普通主题，则从 队列当前的最大的有效偏移量开始消费，即 CONSUME_FROM_LAST_OFFSET 语义 的实现。 代码@4：如果从远程服务拉取最大偏移量拉取异常或其他情况，则使用-1 作为第一 次拉取偏移量。 分析，上述执行的现象，虽然设置的是 CONSUME_FROM_LAST_OFFSET，但 现象是从队列的第一条消息开 } 从队列的开始偏移量开始消费，其计算逻辑如下：  代码@1：首先通过偏移量存储器查询消费队列的消费进度。  代码@2：如果大于等于 0，则从当前该偏移量开始消费。  代码@3：如果远程返回-1，表示并没有存储该队列的消息消费进度，从 0 开始。  代码@4：否则从-1 开始消费。 4. CONSUME_FROM_TIMESTAMP 从指定时戳后的消息开始消费。 case CONSUME_FROM_LAST_OFFSET 一样：  代码@1：首先通过偏移量存储器查询消费队列的消费进度。  代码@2：如果大于等于 0，则从当前该偏移量开始消费。  代码@3：如果远程返回-1，表示并没有存储该队列的消息消费进度，如果是重试主题， 则从当前队列的最大偏移量开始消费，如果是普通主题，则根据时间戳去 Broker 端查 询，根据查询到的偏移量开始消费。 原理就介绍到这里，

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

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