生产者启动流程

使用rmq提供的快速启动里边的producer来看生产者启动的流程。

代码位置：org.apache.rocketmq.example.quickstart.Producer

类的关系继承图：

image-20240128010506590

image-20240128012534578

可见他是拥有admin的能力的

属性

生产者很简单，核心属性是DefaultMQProducerImpl，其实他发送消息之类的能力也是依赖于这个类来完成的。

启动

org.apache.rocketmq.client.producer.DefaultMQProducer#start

@Override
public void start() throws MQClientException {
    this.defaultMQProducerImpl.start();
}

可以看到，启动函数很简单，启动了 defaultMQProducerImpl

org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl#start(boolean)

启动是在不知道如何写？

因为 启动就是启动那一堆的组件，那些组件可以单独去解释？

不如发送接受，在平衡，写数据之类的流程比较复杂一点。