Producer启动流程
2022-01-17 09:31:02 0 举报
rocketmq Producer启动流程
作者其他创作
大纲/内容
1.start()
7.从工厂中获取实例
MQClientManager
DefaultMQProducer
10.将当前生产者注册到客户端表中producerTable
9.返回客户端实例
6.获取MQ客户端的实例
13生产者状态更新为RUNNING
MQClientInstance
8.返回客户端实例
DefaultMQProducerImpl
11.返回注册结果
4.校验生产者组GROUP名称是否合法
2.判断生产者状态是否为CREATE_JUST，否则 返回
5.如果生产者组不是CLIENT_INNER_PRODUCER，则设置生产者实例名称为：进程ID + '#' + 系统时间
12.mQClientFactory启动客户端：mQClientAPIImpl，pullMessageService，rebalanceService
14.向所有Broker发送心跳 sendHeartbeatToAllBrokerWithLock
3.状态设置为START_FAILED
0 条评论
回复 删除
下一页
