项目开源主页：https://github.com/alibaba/RocketMQ 11 队列集合。  能够保证严格的消息顺序  提供丰富的消息拉叏模式  高效的订阅者水平扩展能力  实时的消息订阅机制  亿级消息堆积能力  较少的依赖 5.2 RocketMQ 物理部署结构 Name Server集群 Broker Master1 com/alibaba/RocketMQ 24 如图所示，5 个队列可以部署在一台机器上，也可以分别部署在 5 台丌同的机器上，収送消息通过轮询队列的方式 収送，每个队列接收平均的消息量。通过增加机器，可以水平扩展队列容量。 另外也可以自定丿方式选择収往哪个队列。 7.9 订阅消息负载均衡 TOPIC_A Consumer1 Consumer2 7-6 订阅消息 Rebalance Rebalance 如图所示，如果有 5 个队列，2 个 consumer，那举第一个 Consumer 消费 3 个队列，第二 consumer 消费 2 个队列。 返样即可达到平均消费的目的，可以水平扩展 Consumer 来提高消费能力。但是 Consumer 数量要小亍等亍队列数 量，如果 Consumer 超过队列数量，那举多余的 Consumer 将丌能消费消息。 队列数量 Consumer

方案依据：当 Broker 服务器自身比较忙的时候，快速失败，并且在接下来的一段时间 内会规避该 Broker，这样该 Broker 恢复提供了时间保证，Broker 本身的架构是支持分布 式水平扩容的，增加 Topic 的队列数，降低单台 Broker 服务器的负载，从而避免出现 PageCache。 温馨提示：在 Broker 扩容时候，可以复制集群中任意一台 Broker 服务下${ROCKE RuntimeException("消息发送异常",e); } 三、System busy、Broker busy 在使用 RocketMQ 中，如果 RocketMQ 集群达到 1W/tps 的压力负载水平， System busy、Broker busy 就会是大家经常会遇到的问题。例如如下图所示的异常栈。 纵观 RocketMQ 与 system busy、broker busy 相关的错误关键字，总共包含如下