该服务作为一个中间服务，上游对接平台mq的各种类型消息协议，下游对接平台事件中心或终端。各业务服务需要使用和获取平台消息时，向该服务订阅消息类型及过滤规则等信息，该服务将mq中相关类型消息按要求过滤后，推送至平台事件中心，供业务方使用。主要功能如下：
● 动态对接mq，只有有相关消息类型的订阅，才会创建相关mq队列及消费、处理线程；取消订阅后，mq队列被动态回收删除。mq队列上bindingKey随业务订阅信息的动态变更等。
● 数据量支持性很高，支持mq中每个队列亿级的消息流量
● 数据延迟性低，内部对消息的消费、处理、推送等流程都使用多线程方式实现高并发处理，并且针对不同数据类型，可以自由配置推送方式如大流量模式，低延迟模式等
● cpu和内存占用低，内部各消费、处理、推送等线程都做了动态回收处理，在一定时间范围内没有新数据时，各线程都会被回收，在有数据时再重新启用。
● 支持分布式集群部署，满足不同场景下的数据量要求。
项目均为公安内网项目，无线上地址