一、描述：RocketMq分布式消息的热点队列消息调度处理，通过定时监控，针对热点队列消息进行负载均衡处理，减少热点队列处理压力，全面提高队列消息的处理性能，尤其是针对客户直接感知的计费、话单等计算。

二、解决问题：

1、解决rocketMq分布式消息队列大量积压的问题，做到快速负载均衡处理；

2、解决rocketMq分布式消息中单个队列处理性能不足的问题，自动触发分布式策略处理。

三、主要流程：

1、系统部署图

1.1 客户端(生产者)：负责生产消息的客户端。

1.2 Rocket消息中间件(主)：接收消息的组件，并把消息保存到对应的消息队列里。

1.3 Rocket消息中间件(备)：作为消息中间件的备机。

1.4 队列：负责保存消息的队列。

1.5 消息调度服务：负责监控队列的积压量以及和zookeeper集群交互。

1.6 Zookeeper集群：保存着不同的策略和持久化队列信息以及对消息队列的监控。

2、流程图：

主要流程处理：

消息中间件接收到客户端生产者发过来的消息，保存到对应队列中，调度消息服务定时监控各个消息队列，判断是否达到配置的积压阈值，如果未达到，则返回继续定时监控，如果达到积压阈值，则根据配置的策略，判断如果存在多个非热点队列，则均匀分发到对应队列处理，如果不存在，则新增多个队列处理，处理完即可以回收队列。