type
status
date
slug
summary
tags
category
icon
password
RocketMQ 支持 3 种消息发送方式 ：同 步（sync ）、异步（async）、单向（oneway ）。这些大家应该都比较了解了，我们从生产者的启动开始聊起。
DefaultMQProducer 是默认的消息生产者实现，他实现了MQAdmin接口。
生产者的启动，常规是用 DefaultMQProducerlmpl的start()方法进行追踪，以下为主要步骤：
- 检查生产者组是否符合要求，并改变生产者的实例名为进程ID。
- 创建 MQClientlnstance 实例 。 整个JVM实例中只存在一个MQClientManager 实例，同时维护了一个MQClientlnstance缓存表，最终通过clientId（ip+pid）生成一个实例。
- 向MQClientInstance注册，并加入其管理。
- 启动实例。