扎实的 Java 基础功底 一个开源项目的底层都会涉及到存储，这就要求具备一定的数据结构基础，JAVA 集 合框架中的类自然成为了我们突破数据结构最好的老师，其次是 java 并发，即多线程、并 发容器、锁等课题，这方面可以好好学习一下 JUC 框架。最后最好是具备一些网络方面的 知识，例如 NIO、Netty。 2. 持续输出能力 成为一个开源项目的 contributions 非常容易，提交一个 size() > 7) { this.csListMinute.removeFirst(); } } } 就是将当前 StatsItem 中的 value 与 变更次数(time ) 存入封装成 CallSnapshot ，然后存储在快照列表中。这里的关键是 times values 这些值在什么情况下会改变呢？ 接着往下看，源码在消息拉取的时候，会将本次拉取的信息加入到统计信息中，其入口 是消息拉取命令处理器。  RequestCode 请求 CODE，用来区分请求的类型，例如 SEND_MESSAGE：表示该请求为消息发 送，PULL_MESSAGE:消息拉取请求。  Pair 用来封装 NettyRequestProcessor 与 ExecuteService 的绑定关系。在 RocketMQ 的网络处理模型中，会为每一个 NettyRequestProcessor 与特定的线程池绑

// 2 个 字 节 （ short ） 存 放 属 性 值 大 小 ， 后 存 放 propertiesLength 大小的属性数据 3） MapedFile 是 PageCache 文件封装，操作物理文件在内存中的映射以及将内存数据持久 化到物理文件中， 代码中写死了要求 os 系统的页大小为 4k, 消息刷盘根据参数 （commitLog 默认至少刷 4 页, consumeQueue 第五章 Remoting 通信层： Rocketmq 的通信层是基于通信框架 netty 4.0.21.Final 之上做了简单的协议封装，是强依赖。 一： NettyRemotingAbstract Server 与 Client 公用抽象类 ResponseFuture 模式: invokeSyncImpl register，unregiter， active， inactive， exception NettyClientHandler netty 处理请求的业 Client 与通信层的交互封装了 MQClientAPIImpl 统一处理，在 MQClientAPIImpl 构造的时候注 册了 ClientRemotingProcessor 来处理 server 的请求

Broker，那举只需要依赖 rocketmq-broker 返个 jar 包即可，可通过 API 迕行交互， 如果定制 client，则依赖 rocketmq-client 返个 jar 包，对其提供的 api 迕行再封装。 开源社区地址： https://github.com/alibaba/RocketMQ 在 RocketMQ 项目基础上衍生的项目如下  com.taobao.metaq tmq/example/ filter/Consumer.java 9 RocketMQ 通信组件 RocketMQ 通信组件使用了 Netty-4.0.9.Final，在乀上做了简单的协议封装。 9.1 网络协议 length header length header data body data 4 4 1. 大端 4 个字节整数，等亍 2、3、4 长度总和 2

14:9876 autoCreateTopicEnable=true autoCreateSubscriptionGroup=true 五、启动 # 启动 docker-compose up -d #进入容器测试 docker exec -it rmqbroker bash // 生产消息 ./tools.sh org.apache.rocketmq.example.quickstart.Producer

消息系统挑战 • 传统设计和实现⽅方⾯面 • 组件的微服务化，例例如存储和计算分离 • 开源软件的冲击，云服务选型⾯面临挑战 • 缺少稳定的多语⾔言类库 • Cloud AI Ops⽅方⾯面 • 容器器化部署，K8S编排 • 诸如IoT/IIoT新场景下的规模化部署能⼒力力不不⾜足 • HTTP/RESTful/JSON 灵活调⽤用，监控及运维能⼒力力不不⾜足 • Cloud云⼚厂商⽅方⾯面

e t h i n g a b o u t 云原生时代的 Apache RocketMQ 02 C loud Hosting C loud Native 公有云 专有云 混合云 EC S 容器 K8S 物理机 经典网络/VPC 网络 Overlay/Underlay NVMe 普通云盘 ESSD 云盘 SA TA 独占/混部/独立交付…… • 集群节点异常成为常态 • 依赖服务随时可能在进行迁移或重启