............................................................................... 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

在正式进入 RocketMQ 的学习之前，我觉得有必要梳理一下 RocketMQ 核心概念， 为大家学习 RocketMQ 打下牢固的基础。 一、RocketMQ 部署架构 在 RocketMQ 主要的组件如下： 1. Nameserver Nameserver 集群，topic 的路由注册中心，为客户端根据 Topic 提供路由服务，从 而引导客户端向 Broker 发送消息。Nameserver 绝大数的程序员最信赖的开发调试工具基本都是 DEBUG，那能在 IDEA 中 debug RocketMQ 的源码吗？答案当然是可以的。本节就来演示如何在 IDEA 中运行 RocketMQ 的 Nameserver、Broker 组件，并进行 Debug。 Setp1：从 github 上下载 RocketMQ 源码，并将其导入到 IEDA 中，其截图如下： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 三、如何存储消息轨迹数据 消息轨迹需要存储什么消息以及在什么时候记录消息轨迹的问题都以及解决，那接下来 就得思考将消息轨迹存储在哪里？存储在数据库中或其他媒介中，都会加重消息中间件，使 其依赖外部组件，最佳的选择还是存储在 Broker 服务器中，将消息轨迹数据也当成一条消 息存储到 Broker 服务器。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.16 RocketMQ

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