RocketMQ消费者启动类时序图
2024-12-03 11:30:02 0 举报
RocketMQ消费者启动类时序图展示了消费者实例的启动过程。在启动过程中,消费者首先会加载配置,包括Topic和消费者分组信息。然后,消费者会启动心跳线程,用于与Broker保持心跳,确认自己的订阅状态。接下来,消费者会启动拉取线程,从Broker拉取消息,并将消息提交到消费者客户端的线程池进行处理。处理完成后,消费者会将处理结果返回给Broker。最后,消费者会关闭资源,结束运行。此过程涉及了配置加载、心跳机制、消息拉取、消息处理和资源关闭等关键环节,确保了RocketMQ消费者实例的正常运行。
作者其他创作
大纲/内容
MQClientManager
RebalanceImpl
ConsumeMessageService
RemoteBrokerOffsetStore
2.1checkConfig()校验消息合法性
2.4 返回MQClientInstance
DefaultMQPushConsumerImpl
2.start启动消费者
2.14更改运行状态为运行中
2.3构建MQClientInstance
2.5构建rebalanceImpl
2.9创建消息消费线程服务
3.enableTrace配置为true注册异步调度跟踪器
2.13启动MQClientInstance
DefaultMQPushConsumer
2.2copySubscription()构建主题订阅信息
2.11start启动消费者
2.15从 Namesrv 更新路由信息
2.10 返回消息消费线程
2.12注册消费者
2.17唤醒重平衡线程,立即执行重平衡
1.设置消费者组
2.6返回rebalanceImpl
4.如果注册了调度跟踪器开始调度监控
2.16将客户端信息上报给 Broker
MQClientInstance
LocalFileOffsetStore
0 条评论
下一页