文件拷贝到【Step2】中设置 的主目录下,执行后的效果如下图所示： 温馨提示：该文件为 nameserver 的日志路劲，可以手动修改 logback_namesrv.x ml 文件中的日志目录，由于这是 logback 的基础知识，这里就不再详细介绍 logback 的 配置方法。 Step4：以 debug 方法运行 NamesrvStartup，执行效果如下图所示,表示启动成功。 Step5：将 Step5：将 distribution/conf/logback_brokerxml、broker.conf 文件拷贝到【 Step2】中设置的主目录下,执行后的效果如下图所示： Step6：修改 broker.conf 中的配置，主要设置 nameserver 的地址，broker 的名称 等相关属性。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 37 > 1.3 }); consumer.start(); System.out.printf("Consumer Started.%n"); } 执行上述代码后，按照期望，应该是不会消费任何消息，只有等生产者再发送消息后， 才会对消息进行消费，事实是这样吗？执行效果如图所示： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.6 RocketMQ 一个新的消费组初次启动时从何处开始消费呢？

1) 一阶段，向 broker 发送一条 prepared 的消息，返回消息的 offset 即消息地址 commitLog 中消息偏移量。Prepared 状态消息不被消费 发送消息 ok，执行本地事物分支， 本地事物方法需要实现 rocketmq 的回调接口 2）2） 2) LocalTransactionExecuter ， 处 理 本 地 事 物 逻 辑 返 回 处 理 的 事 物 状 初始化 rebalance 变量 构建 offsetStore 消费进度存储对象 启动消费消息服务 向 mqClientFactory 注册本消费者 启动 client 端远程通信 启动定时任务 定时获取 nameserver 地址 定时从 nameserver 获取 topic 路由信息 定时清理下线的 borker queue 选择一台 broker 获取基于 group 的所有消费端（有心跳向所有 broker 注册客户端信息） 选择队列分配策略实例 AllocateMessageQueueStrategy 执行分配算法,获取队列集合 Set mqSet 1） 平均分配算法，其实是类似于分页的算法 将所有 queue 排好序类似于记录 将所有消费端 consumer 排好序，相当于页数

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

--- arm64 jdk版本：1.8 maven版本：3.6.3 git clone https://github.com/apache/rocketmq.git cd rocketmq # 执行mvn构建命令, 这里的命令含义是：清理之前编译、打包的文件，激活profile 名为 release-al # 然后打包，不编译单元测试，也不运行单元测试 mvn clean -P release-all 改下启动脚本的内存配置， runserver.sh ● 还有一个就是脚本格式问题，会导致脚本执行不了，解决办法： https://blog.lacknb.cn/articles/ 019/10/10/1577974148936.html#toc_h2_18 nameserver启动完毕后，可以执行 jps ，查看是否起来 Cent OS rocketmq配置文件 1、配置master节点 release-rocketmq-console-1.0.0 4、cd rocketmq-console 5、mvn clean package -Dmaven.test.skip=true 6、构建成功后，执行启动命令 nohup java -jar target/rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr='192.1 8.166

com/alibaba/RocketMQ 21 索引项）。 3. 遍历索引项列表迒回查询时间范围内的结果集（默讣一次最大迒回的 32 条记彔） 4. Hash 冲突；寻找 key 的 slot 位置时相当亍执行了两次散列函数，一次 key 的 hash，一次 key 的 hash 值叏模， 因此返里存在两次冲突的情冴；第一种，key 的 hash 值丌同但模数相同，此时查询的时候会在比较一次 key 的 Consumer。注意：Message Tag 是字符串形式，Consume Queue 中存储的是其对应的 hashcode，比对时也是比对 hashcode。 (2). Consumer 收到过滤后的消息后，同样也要执行在 Broker 端的操作，但是比对的是真实的 Message Tag 字 符串，而丌是 Hashcode。 为什举过滤要返样做？ (1). Message Tag 存储 Hashcode，是为了在 com/alibaba/RocketMQ 40 12.3 Broker 重启对客户端的影响 Broker 重启可能会导致正在収往返台机器的的消息収送失败，RocketMQ 提供了一种优雅关闭 Broker 的方法，通过 执行以下命令会清除 Broker 的写权限，过 40s 后，所有客户端都会更新 Broker 路由信息，此时再关闭 Broker 就丌 会収生収送消息失败的情冴，因为所有消息都収往了其他 Broker。