通过追踪源码来寻求答案，如果大家想急于答案，可以跳过问题分析，直接查看本文末尾的 问题解答部分。 通过本文的阅读，您将获得如下信息： 1. RocketMQ 消费 TPS 的收集与计算逻辑。 2. RocketMQ 监控指标的设计思路。 3. RocketMQ 主从同步，消费者从主服务器拉取还是从从服务器拉取的判断逻辑。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 51 > 1.5 踩坑记：rocketmq-console rGroup，即消息主 题@消费组名。 要读懂 代码@2 的代码，先来看一下 rocketmq 监控指标的存储数据结构，如下图 所示： 正如上图所示：RocketMQ 使用 HashMap 来存储监 控收集的数据，其中 Key 为监控指标的类型，例如 topic 发送消息数量、topic 发送消息 大小、消费组获取消息个数等信息，每一项使用 代表某一个具体的统计目标，例如记录消 费组拉取消息的数量监控指标，那其统计的对象即 topic@consumer_group，最终数据 的载体是 StatsItem，使用如下几个关键字段来记录统计信息：  AtomicLong value = new AtomicLong(0) 总数量，统计指标 TOPIC_GET_NUMS 指标为例，记录的是消息拉取的总条数，例 如一次消息拉取操作获取了