RocketMQ源码分析----Producer队列选择与容错策略

队列选择 在HA的文章里大概讲了一下Producer如何为高可用贡献出一份力量的,当时只是说了遍历列表选择队列,而后选择一个,没有深刻分析,这篇文章深刻分析一下其源码,首先从发送消息选择队列的代码开始:java String lastBrokerName = null == mq ? null : mq.getBrokerName(); MessageQueue tmpmq = this.
相关文章
相关标签/搜索