RocketMQ消息拉取流程

返回拉取消息结果

执行消息过滤逻辑(TAG)

PullMessageService

DefaultMQPushConsumerImpl

MQClientAPIImpl

PullAPIWrapper编码解码拉取的结果

pullRequest.getConsumerGroup()为空

将拉取到的消息提交到消费者线程池，并处罚下一次拉取

PullMessageProcessor

MessageStore.getMessage

执行PullCallBack拉取回调

pullMessage调用pullMessage调用后马上返回

run

pullMessageAsync

构建消息过滤器

消息拉取流控

N

获取ProcessQueue

构建消息拉取系统标记

pullRequestQueue#take

获取Broker或FilterServer地址

获取主题订阅消息

向Broker发起消息拉取请求

pullMessage(PullRequest)

Y