Java架构领域

关注

RocketMQ Consumer源码剖析

Java架构领域

关注

阅读 55

2022-01-22

一,Consumer实例初始化

DefaultMQPushConsumer#start()

DefaultMQPushConsumerImpl#start()

 二,拉取消息

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

PullMessageService#run()

DefaultMQPushConsumerImpl#pullMessage()

 三,消费消息组装

PullMessageProcessor#processRequest()

DefaultMessageStore#getMessage()

PullMessageProcessor#processRequest() 

相关推荐

静守幸福

精通RocketMQ系列:万字深度剖析RocketMQ Consumer start启动流程源码

静守幸福 23 0 0

有点d伤

RocketMQ源码解读之Consumer

有点d伤 74 0 0

认真的老去

rocketmq源码解析-producer与consumer

认真的老去 56 0 0

少_游

RocketMQ-consumer

少_游 80 0 0

新鲜小饼干

源码剖析RocketMQ延时消息原理

新鲜小饼干 94 0 0

落拓尘嚣

[RocketMQ] Consumer 负载均衡服务 RebalanceService入口源码 (十五)

落拓尘嚣 61 0 0

张宏涛心理

[RocketMQ] Consumer消费者启动主要流程源码 (六)

张宏涛心理 64 0 0

sin信仰

SB-RocketMQ-Provider-Consumer20230331

sin信仰 27 0 0

Spinach菠菜

RocketMQ源码分析pullMessage:Consumer是如何从broker拉取消息的?

Spinach菠菜 24 0 0

阿尚青子自由写作人

Kafka 源码分析——Consumer

阿尚青子自由写作人 43 0 0

精彩评论(0)

0 0 举报