RocketMQ客户端源码分析-DefaultMQProducer

结构 DefaultMQProducer包含了DefaultMQProducerImpl,而DefaultMQProducerImpl又包含了MQClientInstance。 start start的逻辑主要在MQClientInstance,做了这四个事情: this.mQClientAPIImpl.start(); APIImpl主要负责对外的API请求,比如在需要获取broker状态时就需
相关文章
相关标签/搜索