RocketMQ消息消费（二）消息队列负载与重新分布机制消息消费过程
消息队列负载与重新分布机制RocketMQ消息队列重新分布是由RebalanceService线程来实现的。一个MQClient-Instance持有一个RebalanceService实现，并随着MQClientInstance的启动而启动。RebalanceService#run @Override public void run() { log.info(this.getServiceName() + " service started");
