入口org.apache.rocketmq.client.impl.factory.MQClientInstance#start

RocketMQ的消息消费流程分为三部分，一消息队列负载均衡，二消息的拉取，三消息的消费，其中消息的拉取由 PullMessageService 来实现

PullMessageService

上节看到消息队列负载均衡之后，会new PullRequest(), 然后交给PullMessageService进行消息拉取，这里即是从阻塞队列中取出PullRequest，进行消息拉取操作

 PullRequest的属性如下

RocketMQ文档和书籍.zip

zip 0星 超过10%的资源 5.71MB

下载

DefaultMQPushConsumerImpl#pullMessage

首先进行消息流控，如果本地已经拉取的消息超过阈值条数或者阈值大小，进行延迟拉取

构造PULL_MESSAGE命令，异步调用Broker接口进行消息拉取，在回调函数中进行消息的解析存入processQueue

回调函数PullCallback，进行消费端过滤、添加ProcessQueue、异步提交消费申请、发起下次拉取任务