扫一扫加入作者公众号 扫一扫关注 中间件兴趣圈 RocketMQ 官微 扫一扫关注【阿里巴巴云原生】公众号 阿里云开发者“藏经阁” 获取第一手技术干货 海量免费电子书下载 作者简介 作者简介 丁威，《RocketMQ 技术内幕》作者，RocketMQ 官方社区优秀布道师，荣获 CSDN2020 博客之星亚军；担任中通快递研发中心资深架构师，维护『中间件兴趣圈』公 众号，主打成体系剖析 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 9 > 开篇：我的另一种参与 RocketMQ 开源社区的方式 接下来我们回到本节的主题，那如何参与一个开源项目呢？ 在参与一个开源项目之前，我觉得第一个最基本的步骤还是要打牢基础，这里的基础至 少要包括 JAVA 集合、JAVA 并发（JUC)这两项，只是最最基本的，至少要阅读其源码， 理解其设计理念，至于 NIO，Netty 这些可以后续在需要使用时再去专门学习，有针对性 NameServer 汇报路由信息。此时消 息发送者缓存的路由信息是 2 个 Broker，每个 Broker 默认 4 个队列（原因见 3.2.1: Step2 的分析）。消息发送者然后按照轮询机制，发送第一条消息选择(broker-a 的 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.2 生产环境中，autoCreateTopicEnable 为什么不能设置为 true <

存储的支持，因为第二阶段的提交回 滚需要修改消息状态，一定涉及到根据 Key 去查找 Message 的劢作。RocketMQ 在第二阶段绕过了根据 Key 去查找 Message 的问题，采用第一阶段収送 Prepared 消息时，拿到了消息的 Offset，第二阶段通过 Offset 去访问消息， 幵修改状态，Offset 就是数据的地址。 RocketMQ 返种实现事务方式，没有通过 优点：可以利用 DMA 方式，消耗 CPU 较少，大块文件传输效率高，无内存安全新问题。 缺点：小块文件效率低亍 mmap 方式，只能是 BIO 方式传输，丌能使用 NIO。 RocketMQ 选择了第一种方式，mmap+write 方式，因为有小块数据传输的需求，效果会比 sendfile 更好。 关亍 Zero Copy 的更详细介绍，请参考以下文章 http://www.linuxjournal 32 条记彔） 4. Hash 冲突；寻找 key 的 slot 位置时相当亍执行了两次散列函数，一次 key 的 hash，一次 key 的 hash 值叏模， 因此返里存在两次冲突的情冴；第一种，key 的 hash 值丌同但模数相同，此时查询的时候会在比较一次 key 的 hash 值（每个索引项保存了 key 的 hash 值），过滤掉 hash 值丌相等的项。第二种，hash 值相等但

............................................................................................... 4 第一章： producer ....................................................................................... https://github.com/alibaba/RocketMQ 获取最权威的文档、问题解答、原理介 绍等。 第一章： producer 一：Producer 启动流程 Producer 如何感知要发送消息的 broker 即 brokerAddrTable 中的值是怎么获得的， 1. 发送消息的时候指定会指定 ce 异步预创建下一个 MapedFile 文件，这样下次创建新文件请求就不要等待，因为创建文件特别是一个 1G 的文 件还是有点耗时的， getMinOffset 获取队列消息最少偏移量，即第一个文件的文件起始偏移量 getMaxOffset 获取队列目前写到位置偏移量 getCommitWhere 刷盘刷到哪里了 5) DefaultMessageStore 消息存储层实现

subnet-a0246dcd) 。此⼦网需要 在您选择的 VPC 中。 3 Secondary0 Node Subnet Secondary0NodeSubnet 必填项 副本集中第一个 secondary RocketMQ 节点所在⼦网 ID。此 ⼦网需存在于所选 VPC 中。 4 Secondary1 Node Subnet Secondary1NodeSubnet 图： 6. 输⼊ Proxy Server 的信息，如下图，完成后点击左下方的 Apply changes，注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端⼝，见第一步的-D 参数后 面的那个数字，如下图： 7. 点击 SwitchyOmega 插件并选择刚刚创建的 RocketMQ profile，如下图 Page 16 of 18

6. 输入 Proxy Server 的信息，如下图，完成后点击左下方的 Apply changes， 注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端口，见第一步的-D 参数后面的那个数字，如下图： 7. 点击 SwitchyOmega 插件并选择刚刚创建的 RocketMQ profile，如下图 Page 19 of 21