该文所涉及的 RocketMQ 源码版本为 4.9.3。 RocketMQ 生产者启动流程 入口: org.apache.rocketmq.client.producer.DefaultMQProducer#start 第一步、检查 producerGroup 第二步、设置 instanceName 第三步、创建 mqClientInstance,它是与 nameserver 和 broker 通信的中介 第四步、将生产者加入 mqClientInstance 管理 第五步、启动 MQClientInstance(有一些关于消费者的任务 会在消费者启动流程中讲解) 启动 netty 客户端 ,创建与 nameserver、broker 通信的 channel 启动一些周期性的任务: 更新