十四、RocketMQ源码分析消息拉取拉模式PULL
本节目录
1、 RocketMQ推拉模式简介；
2、 DefaultMQPullConsumer核心属性；
3、 消息消费者启动流程分析；
1、RocketMQ 推拉模式简介
消费者与消息存储方 Broker一般有两种通信机制：推（PUSH）、拉(PULL)。
- 推模式：消息发送者将消息发送到Broker，然后Broker主动推送给订阅了该消息的消费者。
- 拉模式：消息发送者将消息发送到Broker上，然后由消息消费者自发的向Broker拉取消息。
RocketMQ 推拉机制实现：严格意义上来讲，RocketMQ 并没有实现 PUSH 模式，而是对拉模式进行一层包装，在消费端开启一个线程 PullMessageService 循环向 Broke r拉取消息，一次拉取任务结束后马上又发起另一次拉取操作，实现准实时自动拉取，PUSH 模式的实现请参考如下博文：
1、 推模式消息拉取机制；
2、 推模式消息队列负载机制；
本文重点在讨论RocketMQ拉模式DefaultMQPullConsumer实现。
RocketMQ 拉模式，RocketMQ 消费者不自动向消息服务器拉取消息，而是将控制权移交给应用程序，RocketMQ消费者只是提供拉取消息API。
为了对RocketMQ 拉模式有一个直观的了解，我们先大概浏览一下 MQPullConsumer 接口。
从上面我们可以看到除了启动、关闭，注册消息监听器，其他的就是针对 MessageQueue 拉取消息，特别值得留意的是每一个拉取 pull 方法，都是直接针对消息消费队列。PUSH 模式可以说基于订阅与发布模式，而PULL模式可以说是基于消息队列模式。