基于RocketMQ队列的消息优先级控制方法和可靠性保障方法

本发明涉及RocketMQ消息中间件应用技术领域，尤其涉及基于RocketMQ队列的消息优先级控制方法和可靠性保障方法。根据队列选择算法判断消息队列总数Z是否大于等于算法下限配置T；若大于等于算法下限配置T，则根据队列选择算法将消息选择性地发送至X个普通队列或Y个优先队列中进而发送给消费者。在不调整已有主题数量和配置的情况下，通过引入该队列选择算法，实现主题队列优先级的逻辑分组从而完成对RocketMQ队列消息的优先级控制；有利于提升单位数量的主题队列的资源调度能力，从而提升整体消息发送的效率，解决现有的RocketMQ的消息优先级控制方法容易导致消息队列管理、使用以及运维成本增加的技术问题。