setTps(tps); statsSnapshot.setAvgpt(avgpt); } return statsSnapshot; } 代码@1：首先取快照中的第一条消息。 代码@2：取快照列表中的最后一条消息。 代码@3：计算这两个时间点 value 的差值，即这段时间内新增的总数。 代码@4：计算这段时间内的 tps，即每秒处理的消息条数。 代码@5：计算 avgpt ，即平均一 csListMinute.removeFirst(); } } } 就是将当前 StatsItem 中的 value 与 变更次数(time ) 存入封装成 CallSnapshot ，然后存储在快照列表中。这里的关键是 times values 这些值在什么情况下会改变呢？ 接着往下看，源码在消息拉取的时候，会将本次拉取的信息加入到统计信息中，其入口 为： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 一直无法请求成功，故客户端的缓存路由信息一直无法得到更新，造成了上面的现象 那问题来了，按照我们对 RocketMQ 的认识，NameServer 宕机，客户端会自动去 从 nameserver 列表中选择下一个 nameserver，那为什么这里并无发生 nameserver 切换，而是等到 14:53 才切换呢？ 接下来我们将目光投向 NameServer 的切换代码，其代码片段如下图所示：

slotNum=5000000）。 2. 根据 slotValue（slot 位置对应的值）查找到索引项列表的最后一项（倒序排列，slotValue 总是挃吐最新的一个 项目开源主页：https://github.com/alibaba/RocketMQ 21 索引项）。 3. 遍历索引项列表迒回查询时间范围内的结果集（默讣一次最大迒回的 32 条记彔） 4. Hash 冲突；寻找 key setNamesrvAddr("192.168.0.1:9876"); 11.2.2 客户端的公共配置 参数名 默认值 说明 namesrvAddr Name Server 地址列表，多个 NameServer 地址用分号 隔开 clientIP 本机 IP 客户端本机 IP 地址，某些机器会发生无法识别客户端 IP 地址情况，需要应用在代码中强制指定 instanceName

构建一个单线程的本地线程, 用来稍后定时重新消费 ConsumeRequest, 用来执行 定时周期性（一秒）钟锁队列任务 周期性锁队列 lockMQPeriodically 获取正在消费队列列表 ProcessQueueTable 所有 MesssageQueue， 构建根据 broker 归类成 MessageQueue 集合 Map> 第三章： broker 一：brker 的启动 Broker 向 namesrv 注册 1. 获取 namesrv 的地址列表（是乱序的） 2. 遍历向每个 namesrv 注册 topic 的配置信息 topicconfig Topic 在 broker 文件上的存储 json 格式 "TopicTest":{

默认值 说明 Network Configuration 网络配置 1 Availability Zones AvailabilityZones 必填项 ⼦网可用区的列表。 您指定的 逻辑顺序会被保留。此部署使用 Page 8 of 18 2 个或 3 个可用区。完 成选择 后，请确保“可用区数量”参数 与 您此处的选择是一致的。

说明 Network Configuration 网络配置 1 Availability Zones AvailabilityZones 必填项 ⼦⽹可⽤区的列表。 您指定的 逻辑顺序会被保留。此部署使⽤ 2 个或 3 个可⽤区。完 成选择 后，请确保“可⽤区数量”参数 与您此处的选择是⼀致的。 2 Number of Availability