AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
RocketMQ Consumer启动流程
2021-12-14 11:43:28
6
举报
分享方式
免费使用
RocketMQ Consumer启动流程
RocketMQ
模板推荐
作者其他创作
大纲/内容
启动MQClientInstance实例
启动后委托给DefaultMQPushConsumerImpl启动
注册消费者缓存
定时持久化消费进度
启动
启动一些后台定时任务
为重平衡组件设置消费的属性
DefaultMQPushConsumer
DefaultMQPushConsumerImpl
MQClientInstance
启动重平衡服务（本质上是一个线程）
启动MQClientAPIImpl实例，其实就是启动netty客户端
定时从NameServer拉取路由信息
向所有的broker发送心跳
立即发心跳和重平衡
为该消费组注册消费者缓存
启动拉取消息服务（本质上是一个线程）
根据并发消费还是顺序消费创建不同的 消费消息服务
创建消息拉取组件pullAPIWrapper
订阅重试主题
重平衡
集群模式 并行消费 启动流程
获取或创建MQClientInstance
定时向所有的broker发送心跳
从DefaultMQPushConsumer获取offset管理组件
没获取到就创建一个
收藏
立即使用
RocketMQ思维导图
收藏
立即使用
ShenYu HTTP服务注册流程
收藏
立即使用
Seata AT解决脏读问题
收藏
立即使用
shenyu客户端注册流程
指尖凉
职业：Java开发工程师
去主页
Collect
Get Started
Consumer and Industrial Marketing Channels
Collect
Get Started
consumer数据流
Collect
Get Started
RocketMQ Consumer消费消息流程
Collect
Get Started
RocketMQ Consumer重平衡流程
评论
0
条评论
下一页
Document
