本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 9 > 开篇：我的另一种参与 RocketMQ 开源社区的方式 接下来我们回到本节的主题，那如何参与一个开源项目呢？ 在参与一个开源项目之前，我觉得第一个最基本的步骤还是要打牢基础，这里的基础至 少要包括 JAVA 集合、JAVA 并发（JUC)这两项，只是最最基本的，至少要阅读其源码， 理解其设计理念，至于 NIO，Netty 这些可以后续在需要使用时再去专门学习，有针对性 动向 Nameserver 拉取该主题的消息。 回到本文的主题：autoCreateTopicEnable，开启自动创建主题，试想一下，如果生 产者向一个不存在的主题发送消息时，上面的任何一个步骤都无法获取一个不存在的主题的 路由信息，那该如何处理这种情况呢？ 在 RocketMQ 中，如果 autoCreateTopicEnable 设置为 true，消息发送者向 NameServer /mqbroker -c ../conf/broker.conf & 查看${user_home}/logs/rocketmqlogs/broker.log，如果输出结果如下图所示表示 启动成功。 经过上面的步骤，就成功在 Linux 环境上安装了 RocketMQ Nameserver 服务器与 Broker 服务器。 温馨提示：如果上面在安装过程中发生了错误，大家可以查看{user_home}为用户主

确保私有⼦网的路由表中存在 NAT 网关或 NAT 实例的路由，使得其拥有出 站 Internet 连接。 • 您必须创建堡垒主机及其关联的安全组以实现⼊站 SSH 访问 快速部署 本文的步骤主要针对在运⾏在由西云数据运营的 AMAZON WEB SERVICES（宁夏）区域 或由光环新网运营的 AMAZON WEB SERVICES（北京）区域中部署该解决方案，您可以 使用以下链接快速启动一个 18 18 VolumeType VolumeType gp2 要挂载到 RocketMQ 节点（gp2 或 io1）的 Amazon EBS（数据） 卷的卷类型。 步骤三：授权并创建堆栈 1. 参数设置完成后，点击下一步设置 tag（可选）。 2. 再点击下一步检查对应参数。 3. 在最后的审核⻚面中，勾选最下方的【我确认，AMAZON CloudFormation 资源】以及【我确认，可能需要以下功能】选择框，点击【创建堆栈】，开始堆 栈的创建。 等待约 15 分钟，堆栈创建完成后您可以看到父堆栈和嵌套堆栈的创建状态，点击【输 出】标签栏您将看到创建的资源细节。 步骤四：查看堆栈 您可以在 AMAZON CloudFormation 控制台的【状态】列中查看堆栈 的状态，并点击右上 方的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈状态变 为 CREA

确保私有⼦⽹的路由表中存在 NAT ⽹关或 NAT 实例的路由，使得其拥有 出站 Internet 连接。 • 您必须创建堡垒主机及其关联的安全组以实现⼊站 SSH 访问 快速部署 本文的步骤主要针对在运行在由西云数据运营的亚马逊云科技（宁夏）区域或由光环 新网运营的亚马逊云科技（北京）区域中部署该解决方案，您可以使用以下链接快速 启动一个 Amazon CloudFormation 为单位)。 18 VolumeType VolumeType gp2 要挂载到 RocketMQ 节点（ gp2 或 io1）的 Amazon EBS （数据）卷的卷类型。 步骤三：授权并创建堆栈 1. 参数设置完成后，点击下⼀步设置 tag（可选）。 2. 再点击下⼀步检查对应参数。 3. 在最后的审核⻚⾯中，勾选最下⽅的【我确认，Amazon CloudFormation 等待约 15 分钟，堆栈创建完成后您可以看到父堆栈和嵌套堆栈的创建状态，点击【输 出】标签栏您将看到创建的资源细节。 Page 15 of 21 步骤四：查看堆栈 您可以在 Amazon CloudFormation 控制台的【状态】列中查看 堆栈的状态，并点击右上 ⽅的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈 状态变为 CREA

DispatchMessageService 服务，来重新 生成 ConsumeQueue 数据，索引以及事物消息的 redolog 什么是恢复 ConsumeQueue, 前面不是有步骤 load 了 ConsumeQueue 吗，为什 么还要恢复? 前面 load 步骤创建了 MapedFile 对象建立了文件的内存映射，但是数据是否正 确，现在文件写到哪了(wrotePosition), Flush 到了什么位置(committedPosition) 的 wrotePosition 和 commitedPosition 值， 值为 proccessOffset%mapedFileSize 2） 正常恢复 commitLog 文件 步骤跟流程恢复 Consume Queue 判断消息有效， 根据消息的存储格式读取消息到 DispatchRequest 对象， 获取 消息大小值 msgSize 大于 0 正常数据

形式发送 一个 RPC 调用，通常是返样一个过程 1. 客户端収送请求到服务器 2. 服务器处理该请求 3. 服务器吐客户端迒回应答 所以一个 RPC 的耗时时间是上述三个步骤的总和，而某些场景要求耗时非常短，但是对可靠性要求幵丌高，例如 日志收集类应用，此类应用可以采用 oneway 形式调用，oneway 形式只収送请求丌等待应答，而収送请求在客 户端实现局面仁仁是一个