基于消息优先级队列分布式交换网元调用系统的研究

胡佳

（中国联合网络通信有限公司广东省分公司，广东 广州 510320）

1 引言

随着移动互联网和手机的不断发展和普及，电信行业的数据业务量呈爆发式增长。针对如何处理如此大量的数据，在现有的解决方案中最普遍的就是搭建一个分布式的消息队列进行数据存储，数据存储在消息队列中等待被处理，这样可以实现消息的不遗漏处理。

现有的按照普通消息队列进行消费的处理方式存在明显的缺点。数据业务可细分出紧急业务，正常业务，低优先级业务等，当大量的低优先级或者普通业务堆积时，在现有的普通的消息队列中，需要按照时间顺序来一个一个处理，紧急业务不能得到优先处理，导致紧急业务被贻误，从而造成不必要的损失。

本研究的目的在于提供一种基于消息优先级队列的分布式交换网元调用系统，解决现有技术存在的无法按照优先级处理订单的问题。通过增添消息队列topic个数并且赋予每个消息队列topic优先级属性，然后按照高优先级的消息队列topic优先消费来将处理订单的顺序重新排列，达到高优先级的订单优先处理的目的，而且保证了消息队列还是分布式。同时，通过Json微服务调用工单拆分模块，将优先级高的订单分配到优先级高的消息队列中。最后高优先级的订单会优先执行工单激活模块，从而使多主机多节点同时工作，起到负载均衡和自动切换的作用，实现高可用。

2 总体技术方案

通过Json微服务调用工单拆分接口内的方法，工单拆分模块接收到Json调用后会接收到该订单要办理的业务的相关数据信息，在这个模块中有三部分要操作，即工单校验、工单拆分、工单入库。……