0
点赞
收藏
分享

微信扫一扫

RocketMQ Consumer源码剖析

Java架构领域 2022-01-22 阅读 54
javaRocketMQ

一,Consumer实例初始化

DefaultMQPushConsumer#start()

DefaultMQPushConsumerImpl#start()

 二,拉取消息

RocketMQ中推送与拉取消息底层皆为拉取

PullMessageService#run()

DefaultMQPushConsumerImpl#pullMessage()

 三,消费消息组装

PullMessageProcessor#processRequest()

DefaultMessageStore#getMessage()

PullMessageProcessor#processRequest() 

举报

相关推荐

0 条评论