理念。  写写源码分析类文章，从整体上把控这个框架，这个花费时间较多，如果框架正在起步。 阶段，不建议该方法；如果框架比较成熟，非常建议采用该方法。  尝试看看开源项目中的 issues，看能不能解决，从问题入手，快速融入该项目。  尝试谢谢单元测试用例，测试驱动开发，借此学习该框架。 后面的事情就是坚持不懈，朝着目标不断前进，中途可以放慢速度，但千万别放弃，因 为只有坚持，才能胜利，只要前进，就离目标更近。 于项目在昨天 20：00 发过变更，故为了快速恢复业务，项目组首先决定将版本进行回退， 回退后通过 rocketmq-console 查看消费组的消费 TPS，却显示为 0，如图所示： 乍一看，第一时间得出应用还未恢复，就开始去查看相关的启动日志,通常查看的是应 用服务器的 /home/baseuser/logs/rockemqlogs/rocketmq_client.logs，碰巧又看到 ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 乍一看确实是 rocketmq 相关的问题，导致上述 消费 TPS 为 0，经过半个小时的日 志分析，发现这是 RocketMQ 这是一种正常现象，最终会自动恢复，经过日志分析得出 rocketmq 没

fetchMessageQueuesInBalance(topic) 获取消费的队 列 业务自己获取消费队列，自己到 broker 拉取消息，以及自己更新消费进度 因为内部实现跟 push 方式类似就不在啰嗦，用法也请求看示例代码去 七：shutdown DefaultMQPushConsumerImpl 关闭消费端 关闭消费线程 将分配到的 Set的消费进度保存到