启 autoCreateTopicEnable 机制，什么情况会在两个 Broker 上都创建队列，其实，我们只需要连续快速的发送 9 条消 息，就有可能在 2 个 Broker 上都创建队列，验证代码如下： public static void main(String[] args) throws MQClientException, InterruptedException { DefaultMQProducer 命令，逐一查看文件大小不为０的文件，从而寻找错误日志，便于快速解决 问题。 RocketMQ 提供了众多的运维命令来查看 RocketMQ 集群的运行状态，在这里我先 简单使用 clusterList 命令来查看集群的状态，用于验证一下集群的状态。 sh ./mqadmin clusterList -n 127.0.0.1:9876 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.3 实战：RocketMQ rocketmq-console-ng-1.0.0.jar & 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.3 实战：RocketMQ 学习环境搭建指南篇 < 34 在浏览器中输入:http://localhost:8080 查看是否安装成功，如果出现如下图则表示安 装成功。 3. 异常分析与解决思路 如果在安装过程中出现意想不到的错误，别慌，通过查看相关的日志文件，寻找错误日

Availability Zones 参数中 的选择⼀致；否则，部署将失败 Page 9 of 21 ，⽽且会发⽣ Amazon CloudFormation 模板验证错误 。 3 VPC CIDR VPCCIDR 10.0.0.0/16 要创建的 VPC 的 CIDR 块。 4 Private Subnet 1 CIDR PrivateSubnet1CIDR SwitchyOmega 插件之后，打开插件的选项页, 点击左边的“+New Profile”，如下图所示 5. 在弹出的窗口中输入 New Profile 的名字，并点击右下方的 Create 按钮，如 下图： Page 18 of 21 6. 输入 Proxy Server 的信息，如下图，完成后点击左下方的 Apply changes， 注意 Port 对应的值需要设置为您建立 Page 19 of 21 8. 完成了上面这步之后，浏览器就会将所有的流量通过本地的 40011 端口 proxy 到 Bastion Host 机器。 9. 在浏览器中输入部署好的任何一个 Nameserver 的私有 ip 地址加上 8080 端 口（http://10.0.6.235:8080），你可以通过 EC2 Console 找到 Nameserver 对应的

注册 handler NettyEncoder 协议编码器，将 RemotingCommand 转换为字节，给 netty 传输 NettyDecoder 协议解码器， 将 netty 接收的输入流，转换成 RemotingCommand NettyConnetManageHandler 处理 register，unregiter， active， inactive， exception handler NettyEncoder 协议编码器，将 RemotingCommand 转换为字节，给 netty 传输 NettyDecoder 协议解码器， 将 netty 接收的输入流，转换成 RemotingCommand NettyConnetManageHandler 处理 register，unregiter， active， inactive， exception

类型，64 位，理论上在 100 年内丌会溢出，所以讣为是长度无限，另外队列中只保存最近几天的数据，乀前的数据会挄照过期时间来 删除。 也可以讣为 Message Queue 是一个长度无限的数组，offset 就是下标。 4 消息中间件需要解决哪些问题？ 本节阐述消息中间件通常需要解决哪些问题，在解决返些问题当中会遇到什举困难，RocketMQ 是否可以解决， 规范中如何定丿返些问题。

中使用的可用区的数量 (2 个或 3 个)。此数量必须与您 在 Availability Zones 参数中的选 择一致；否则，部署将失败，而 且会发⽣ AMAZON CloudFormation 模板验证错误。 3 VPC CIDR VPCCIDR 10.0.0.0/16 要创建的 VPC 的 CIDR 块。 4 Private Subnet 1 CIDR PrivateSubnet1CIDR