有些什么条件呢？ 1. 扎实的 Java 基础功底 一个开源项目的底层都会涉及到存储，这就要求具备一定的数据结构基础，JAVA 集 合框架中的类自然成为了我们突破数据结构最好的老师，其次是 java 并发，即多线程、并 发容器、锁等课题，这方面可以好好学习一下 JUC 框架。最后最好是具备一些网络方面的 知识，例如 NIO、Netty。 2. 持续输出能力 成为一个开源项目的 contributions 看看官方文档，特别是设计手册，从整体上把握其设计理念。  写写源码分析类文章，从整体上把控这个框架，这个花费时间较多，如果框架正在起步。 阶段，不建议该方法；如果框架比较成熟，非常建议采用该方法。  尝试看看开源项目中的 issues，看能不能解决，从问题入手，快速融入该项目。  尝试谢谢单元测试用例，测试驱动开发，借此学习该框架。 后面的事情就是坚持不懈，朝着目标不断前进，中途可以放慢速度，但千万别放弃，因 弃，因 为只有坚持，才能胜利，只要前进，就离目标更近。 参与开源，一个最基本的条件是拥有大量的连续时间，想要成为一个开源框架的 Committer ,唯有坚持不懈，持续投入，持续产出。 最后再次感谢 RocketMQ 社区对我的认可，我会尽努力做出更大的贡献，也希望广 大读者朋友们，积极参与开源社区，贡献一份自己的力量，同事打造自身影响力，助力职场 步步高升。 本文来自『中间件兴趣圈

............................................................................... 28 9 RocketMQ 通信组件 .................................................................................................. mq-example/src/main/java/com/alibaba/rocketmq/example/ filter/Consumer.java 9 RocketMQ 通信组件 RocketMQ 通信组件使用了 Netty-4.0.9.Final，在乀上做了简单的协议封装。 9.1 网络协议 length header length header data body data remark 字符串 传输自定丿文本信息 错诨详细描述信息 extFields HashMap 请求自定丿字段 应答自定丿字段 9.2 心跳处理 通信组件本身丌处理心跳，由上局迕行心跳处理。 项目开源主页：https://github.com/alibaba/RocketMQ 31 9.3 连接复用 同一个网络连接，客户端多个线程可以同时収送请求，应答响应通过

Producer B Consumer 1 Consumer 2 MessageQueue1 MessageQueue2 MessageQueue1 MessageQueue2 部署模型 组件细节 Broker Netty RemotingServer Netty Remoting Client NameServer All Info In Memory except KV config 设计，搭建和部署应⽤用的⽅方式 • 运⾏行行在云计算环境 IaaS • 快速，弹性 • 降低技术⻛风险 • 互操作性，易易部署，可监控管理理 消息系统挑战 • 传统设计和实现⽅方⾯面 • 组件的微服务化，例例如存储和计算分离 • 开源软件的冲击，云服务选型⾯面临挑战 • 缺少稳定的多语⾔言类库 • Cloud AI Ops⽅方⾯面 • 容器器化部署，K8S编排 • 诸如IoT/

部署到新 VPC 环境中，另⼀种是 部署 到已有 VPC 环境中。使⽤默认参数为在新 VPC 环境中 部署以下资源。如果您选择的 是将此⽅案部署到已有 VPC 中，将跳过 (不创建) 带有星号（*）的组件，并提⽰ 您⽬ 前现有的配置。 按照默认 RocketMQ 的部署参数部署完成后，该方案会在用户的亚马逊云科技账户下 部署如下的一个架构，包含两个 Nameserver 互为备份，三个 堆栈的状态，并点击右上 ⽅的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈 状态变为 CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及 其他需要的组件均已创建完毕。下图列出了默认设置部署完成后在 EC2 Console 的一 个 截图，可以从 Name 属性判断这个 Instance 安装的是哪种类型的节点。 使用 Apache

部署到新 VPC 环境中，另一种是 部署到已有 VPC 环 境中。使用默认参数为在新 VPC 环境中 部署以下资源。如果您选择的是将此方案部署 到已有 VPC 中，将跳过 (不创建) 带有星号（*）的组件，并提⽰ 您目前现有的配置。 按照默认 RocketMQ 的部署参数部署完成后，该方案会在用户的 AMAZON WEB SERVICES account 下部署如下的一个架构，包含两个

BrokerLiveInfo 的时间戳，如果过期关闭 channel 连接 第五章 Remoting 通信层： Rocketmq 的通信层是基于通信框架 netty 4.0.21.Final 之上做了简单的协议封装，是强依赖。 一： NettyRemotingAbstract Server 与 Client 公用抽象类 ResponseFuture