时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户 端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。 温馨提示：Nameserver 是在内存中存储 Topic 的路由信息，持久化 Topic 路由信息 的地方是在 Broker 中，即${ ROCKETMQ_HOME}/store/config/topics.json。 在 RocketMQ4 那这三个消费者如何来分工来共同消费 order_topic 中的消息呢？ 在 RocketMQ 中支持广播模式与集群模式。 广播模式：一个消费组内的所有消费者每一个都会处理 topic 中的每一条消息，通常用 于刷新内存缓存。 集群模式：一个消费组内的所有消费者共同消费一个 topic 中的消息，即分工协作，一 个消费者消费一部分数据，启动负载均衡， 集群模式是非常普遍的模式，符合分布式架构的基本理念，即横向扩容，当前消费者如 Topic 的路由信息，如果存在，说明启用了 autoCreateTopi cEnable，则在 TopicConfigManager 中创建新 Topic 的路由信息，此时存在与 Broker 服务端的内存中，然后本次消息发送结束。此时，在 NameServer 中还不存在新创建的 Topic 的路由信息。 这里有三个关键点： 1. 启用 autoCreateTopicEnable 创建主题时，在

CIDR 块。 4 Private Subnet 1 CIDR PrivateSubnet1CIDR 10.0.0.0/19 可用区 1 中的私有⼦网的 CIDR 块。 5 Private Subnet 2 CIDR PrivateSubnet2CIDR 10.0.32.0/19 可用区 2 中的私有⼦网的 CIDR 块。 CIDR 块。 7 Public Subnet 1 CIDR PublicSubnet1CIDR 10.0.128.0/20 可用区 1 中的公有⼦网的 CIDR 块。 8 Public Subnet 2 CIDR PublicSubnet2CIDR 10.0.144.0/20 可用区 2 中的公有⼦网的 CIDR 块。 9 9 Public Subnet 3 CIDR PublicSubnet3CIDR 10.0.160.0/20 可用区 3 中的公有⼦网的 CIDR 块。 10 Allowed Bastion External Access CIDR RemoteAccessCIDR 必填项 允许对堡垒主机进⾏外部 SSH 访 问的 CIDR

3 VPC CIDR VPCCIDR 10.0.0.0/16 要创建的 VPC 的 CIDR 块。 4 Private Subnet 1 CIDR PrivateSubnet1CIDR 10.0.0.0/19 可⽤区 1 中的私有⼦⽹的 CIDR 块。 5 Private Subnet 2 CIDR PrivateSubnet2CIDR PrivateSubnet2CIDR 10.0.32.0/19 可⽤区 2 中的私有⼦⽹的 CIDR 块。 6 Private Subnet 3 CIDR PrivateSubnet3CIDR 10.0.64.0/19 可⽤区 3 中的私有⼦⽹的 CIDR 块。 7 Public Subnet 1 CIDR PublicSubnet1CIDR CIDR 块。 8 Public Subnet 2 CIDR PublicSubnet2CIDR 10.0.144.0/20 可⽤区 2 中的公有⼦⽹的 CIDR 块。 9 Public Subnet 3 CIDR PublicSubnet3CIDR 10.0.160.0/20 可⽤区 3 中的公有⼦⽹的 CIDR 块。 10

...................................................................... 25 7.14 单个 JVM 迕程也能利用机器超大内存 .................................................................................................. 通信而言。在此丌再详述。 4.2 Message Priority 规范中描述的优兇级是挃在一个消息队列中，每条消息都有丌同的优兇级，一般用整数来描述，优兇级高的消 息兇投递，如果消息完全在一个内存队列中，那举在投递前可以挄照优兇级排序，令优兇级高的兇投递。 由亍 RocketMQ 所有消息都是持丽化的，所以如果挄照优兇级来排序，开销会非常大，因此 RocketMQ 没有特 意支持消息优 项目开源主页：https://github.com/alibaba/RocketMQ 6 (4). 对内存数据做一个持丽化镜像，例如 beanstalkd，VisiNotify (1)、(2)、(3)三种持丽化方式都具有将内存队列 Buffer 迕行扩展的能力，(4)只是一个内存的镜像，作用是当 Broker 挂掉重启后仍然能将乀前内存的数据恢复出来。 JMS 不 CORBA Notification 规范没有

流量控制，正在消费队列中消息的跨度超过阀值（默认 2000），稍后在消费 5. 根据 topic 获取订阅关系 6. 构建拉消息回调对象 PullBack, 从 broker 拉取消息（异步拉取）返回结果是回调 7. 从内存中获取 commitOffsetValue //TODO 这个值跟 pullRequest.getNextOffset 区别 8. 构建 sysFlag pull 接口用到的 flag 9 的本地线程定时 5 秒钟以后重试重新消费消息， 在走一次上面的消费流程。 删除正在消费的队列 processQueue 中本次消费的消息，放回消费进度 更新消费进度， 这里的更新只是一个内存 offsetTable 的更新，后面有定时任务定 时更新到 broker 上去 五：push 消费-顺序消费消息 key，表示提交的 offset 清空 msgTreeMapTemp 的消息，已经成功消费 2） 事物提交，由用户来控制提交回滚（精卫专用） 更新消费进度， 这里的更新只是一个内存 offsetTable 的更新，后面有定时任务定时更 新到 broker 上去 六：pull 消息消费

... } index ⾼高效存储 Disk （commitLog/consumeQueue/indexFile） NIO MappedByteBuffer 堆外内存 零拷⻉贝 mmap(内存映射) store/ | — commitlog/ MappedFileQueue | — 000000000 MappedFile

2-SNAPSHOT/bin/mqnamesrv >> /root/rocketmq/logs namesrv/namesrv.log & Linux 环境下遇到的问题： ● 启动的时候设置内存太大，只是用来测试的话，我们可以改下启动脚本的内存配置， runserver.sh ● 还有一个就是脚本格式问题，会导致脚本执行不了，解决办法： https://blog.lacknb.cn/articles/ 019/10/10/1577974148936