RocketMQ消息发送-全流程交互解析

消息发送的高可用设计
- 生产者感知broker宕机是需要时间的,生产者本地缓存需要定时任务周期刷新（30s），例如在两台Broker组成的集群中a:q0,q1,q2,q3）b:q0,q1,q2,q3，按照轮询算法，如果上一次选择的是a:q0队列，当broker宕机后，RocketMQ如何避免再次发送到broker a 造成重试后还是失败？
producerGroup 与 MQProducer实例对应关系
- 1.在一个客户端中，一个producerGroup只能有一个MQProducer实例
- 2.根据不同的producerGroup，MQClientInstance将给出不同的MQProducer和MQConsumer（保存在本地缓存变量—producerTable和consumerTable中）