推荐超值课程：点击获取RocketMQ开源是使用文件作为持久化工具，阿里内部未开源的性能会更高，使用oceanBase作为持久化工具。在RocketMQ1.x和2.x使用zookeeper管理集群，3.x开始使用nameserver代替zk，更轻量级，此外RocketMQ的客户端拥有两种的操作方式：DefaultMQPushConsumer和DefaultMQPu

消费原理概览 先简单说下常见的rocketMq的部署方式，上图中broker为真正计算和存储消息的地方，而nameServer负责维护broker地 图中右侧consumemessage部分即是本文重点描述的部分，主要分为ConsumerGroup和Consumer，consumerGroup可以参考https://rocketmq.apache.org/docs/do

一、概述对于任何一款消息中间件而言，消费者客户端一般有两种方式从消息中间件获取消息并消费：Push方式：由消息中间件(MQ消息服务器代理)主动地将消息推送给消费者；采用Push方式，可以尽可能实时地将消息发送给消费者进行消费。但是，在消费者的处理消息的能力较弱的时候(比如，消费者端

精华推荐|【深入浅出RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程上篇：分析对应总体消费流程的判断和校验以及限流控制和回

名言警句任何先进的技术均与魔法无异追本溯源【​​经历了6个月的失踪，我将带着干货终究归来！【RocketMQ入门到精通】​​】RocketMQ消费机制回顾   在众多MQ的体系中，一