启 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 图所示： 看到这样的提示就表示大功告成。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.3 实战：RocketMQ 学习环境搭建指南篇 < 38 接下来简单来做一个验证。 首先先在 AbstractSendMessageProcessor 类的 parseRequestHeader 方法中 打上一个断点。 然后运行 example 中 org/apache/

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

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