RocketMQ消息拉取流程
2023-12-25 10:53:48 3 举报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
0 条评论
下一页
