RocketMQ Consumer启动流程
2021-12-14 11:43:28 6 举报
登录查看完整内容
RocketMQ Consumer启动流程
作者其他创作
大纲/内容
启动MQClientInstance实例
启动后委托给DefaultMQPushConsumerImpl启动
注册消费者缓存
定时持久化消费进度
启动
启动一些后台定时任务
为重平衡组件设置消费的属性
DefaultMQPushConsumer
DefaultMQPushConsumerImpl
MQClientInstance
启动重平衡服务（本质上是一个线程）
启动MQClientAPIImpl实例，其实就是启动netty客户端
定时从NameServer拉取路由信息
向所有的broker发送心跳
立即发心跳和重平衡
为该消费组注册消费者缓存
启动拉取消息服务（本质上是一个线程）
根据并发消费还是顺序消费创建不同的 消费消息服务
创建消息拉取组件pullAPIWrapper
订阅重试主题
重平衡
集群模式 并行消费 启动流程
获取或创建MQClientInstance
定时向所有的broker发送心跳
从DefaultMQPushConsumer获取offset管理组件
没获取到就创建一个
0 条评论
回复 删除
下一页
