-
RocketMQ源码阅读（十二）Consumer-消息拉取
入口org.apache.rocketmq.client.impl.factory.MQClientInstance#start
RocketMQ的消息消费流程分为三部分，一消息队列负载均衡，二消息的拉取，三消息的消费，其中消息的拉取由 PullMessageService 来实现
PullMessageService
上节看到消息队列负载均衡之后，会new PullRequest(), 然后交给PullMessageService进行消息拉取，这里即是从阻塞队列中取出PullRequest，进行消息拉取操作
PullRequest的属性如下
DefaultMQPushConsumerImpl#pullMessage
首先进行消息流控，如果本地已经拉取的消息超过阈值条数或者阈值大小，进行延迟拉取
构造PULL_MESSAGE命令，异步调用Broker接口进行消息拉取，在回调函数中进行消息的解析存入processQueue
回调函数PullCallback，进行消费端过滤、添加ProcessQueue、异步提交消费申请、发起下次拉取任务
-
相关阅读:
如何用c++制作人生模拟器
VUE项目build后自动生成zip压缩包
What are the differences between Webpack and JShaman?
VUE3中defineExpose的使用方法
QGraphicsView添加item不显示的问题
详解7道经典指针运算笔试题！
BI与数据治理以及数据仓库有什么区别
为忙碌的软件工程师精心准备的编码面试准备材料，超过 100,000 人受益！
中医自学平台---前端网站
MindSpore强化学习：使用PPO配合环境HalfCheetah-v2进行训练
- 原文地址：https://blog.csdn.net/xyjy11/article/details/126242103
