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

项目职责：包含多个子服务，共同组成了一个运维平台，对平台内部的所有设备、点位进行诊断和维护。主要功能如下：●维护平台内所有的设备信息(百万设备级别)，对添加至系统内的摄像机、卡口、服务器、硬盘等设备进行管理。●所有监控设备的视频和图片智能诊断、相关报警信息的推送和处理。●对异常设备可以进行派单处理，使用workflow流完成复杂的业务流程●每天生成各种统计报表，作为各种基层操作人员的考核项