之后需要在浏览器中设置 proxy，浏览器有很多自动选择 Proxy 的插件，本文使用 SwitchyOmega 作为例⼦。 3. 安装 SwitchyOmega 浏览器插件，Edge 浏览器请访问这个链接，Firefox 浏览器 访问这个链接，Chrome 浏览器访问这个链接。 4. 安装好 SwitchyOmega 插件之后，打开插件的选项页, 点击左边的“+New Profile”，如下图所⽰ Apply changes，注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端⼝，见第一步的-D 参数后 面的那个数字，如下图： 7. 点击 SwitchyOmega 插件并选择刚刚创建的 RocketMQ profile，如下图 Page 16 of 18 8. 完成了上面这步之后，浏览器就会将所有的流量通过本地的 40011 端⼝

之后需要在浏览器中设置 proxy，浏览器有很多自动选择 Proxy 的插件，本文使用 SwitchyOmega 作为例子。 3. 安装 SwitchyOmega 浏览器插件，Edge 浏览器请访问这个链接，Firefox 浏 览器访问这个链接，Chrome 浏览器访问这个链接。 4. 安装好 SwitchyOmega 插件之后，打开插件的选项页, 点击左边的“+New Profile”，如下图所示 Apply changes， 注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端口，见第一步的-D 参数后面的那个数字，如下图： 7. 点击 SwitchyOmega 插件并选择刚刚创建的 RocketMQ profile，如下图 Page 19 of 21 8. 完成了上面这步之后，浏览器就会将所有的流量通过本地的 40011 端口

10 5.2 RocketMQ 物理部署结构 ............................................................................................................................... 11 5.3 RocketMQ 逡辑部署结构 ..................... .................................................................................... 14 6.3 数据存储结构 .................................................................................................. ................................. 14 项目开源主页：https://github.com/alibaba/RocketMQ II 6.4 存储目彔结构 ..................................................................................................

况不符合，那成为一个开源项目的 Committer 有些什么条件呢？ 1. 扎实的 Java 基础功底 一个开源项目的底层都会涉及到存储，这就要求具备一定的数据结构基础，JAVA 集 合框架中的类自然成为了我们突破数据结构最好的老师，其次是 java 并发，即多线程、并 发容器、锁等课题，这方面可以好好学习一下 JUC 框架。最后最好是具备一些网络方面的 知识，例如 NIO、Netty。 有着突出贡献。 我比较“苦逼”，在带娃方面我的资源只有我老婆，父母在老家无法分身，故下班后我 没有连续的空闲时间专心投入一项任务中，而开源最需要的是精益求精，不只是需要完成功 能，而是要编写结构优良的代码，设计所占据的时间比代码开发时间要多的多，故我个人认 为我暂时不方便走代码贡献这条道路。但我零碎时间还是充足的，故现阶段我会好好利用这 些零碎时间，继续通过写文章的方式为开源项目贡献自己的一份力量。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 29 > 1.3 实战：RocketMQ 学习环境搭建指南篇 其中 conf 文件夹存放的是 RocketMQ 的配置文件，提供了各种部署结构的示例配 置。例如 2m-2s-async 是 2 主 2 从异步复制的配置示例；2m-noslave 是 2 主的示例 配置。由于本文主要是搭建一个学习环境，故采取的部署架构为 1 主的部署架构，关于生产

....................................................................................... 42 6.1 索引结构 .................................................................................................. 根 据 producer 请 求 的 RequestCode.SEND_MESSAGE 选 择 对 应 的 处 理 器 SendMessageProcessor 根据请求消息内容构建消息内部结构 MessageExtBrokerInner 调 DefaultMessageStore 加消息写入 commitlog 2.2 分布式事物消息落地 2.2.1 消息落地 被本机器所有 queue 共享不 做区分 文件地址：${user.home} \store\${commitlog}\${fileName} 一个消息存储单元长度是不定的，顺序写但是随机读 消息存储结构： = 4 //4 个字节代表这个消息的大小 + 4 //四个字节的 MAGICCODE = daa320a7 + 4 // 消息体 BODY CRC 当 broker

等数据同步过程中，需要保证严格顺序 RAFT 存储支持：自动主从切换，强一致性保证 逻辑队列：秒级无损弹性扩缩，无数据复制，流量精准调度 消息与流融合索引支持 核心问题 • 消息体小且存储结构面向单 条消息，导致提升吞吐困难 • 在进行状态存储时，无 KV 语义支撑 挑战 • Commitlog 格式存储， 统一复制算法 • 不借助外部依赖，提供 状态存储能力 • 单一数据文件，支持面向流的索引及面向

distribution/target目录，rocket-mq-xxx.tar.gz 和 rocket-mq-xxx.zip 两种，zip 是w ndow下的，tar.gz为Linux下的； tar.gz解压后的目录结构： . ├── LICENSE ├── NOTICE ├── README.md ├── benchmark │ ├── batchproducer.sh │ ├── consumer.sh