智慧统一消息平台研究

李雪松 唐亮 王靖 周晨辉 沈少周

摘  要：为实现业务系统的消息推送，并实现消息在不同业务系统间的传递，研发了智慧统一消息平台。通过分析各业务系统消息产生的机制以及消息传递的特征，围绕消息的全生命周期管理，實现了业务系统消息有效获取、消息频道管理、消息处理、消息分发、消息传递、任务监控，并建立统一的消息通信机制规范。通过系统上线试运行，实现了消息的一站式推送和管理，提升了工作效率。

关键词：系统消息;消息传递;消息推送;消息平台

中图分类号：TP315      文献标识码：A 文章编号：2096-4706（2020）21-0123-04

Research on Intelligent Unified Messaging Platform

LI Xuesong1，TANG Liang2，WANG Jing2，ZHOU Chenhui2，SHEN Shaozhou2

（1.Big Data Center of Science and Technology Informatization Detachment of Huangshi Public Security Bureau，Huangshi  435000，China;2.Science and Technology Informatization Detachment of Huangshi Public Security Bureau，Huangshi  435000，China）

Abstract：In order to realize the message push of business system，and realize the message transmission between different business systems，the intelligent unified messaging platform is developed. By analyzing the mechanism of message generation and the characteristics of message delivery in various business systems，and focusing on the whole life cycle management of messages，the effective acquisition of business system messages，message channel management，message processing，message distribution，message delivery and task monitoring are realized，and a unified message communication mechanism specification is established. Through the online trial operation of the system，the one-stop push and management of messages are realized，and the work efficiency is improved.

Keywords：system message;message delivery;message push;message platform

0  引  言

为贯彻落实数据警务、智慧公安的战略规划和数据赋能、全警应用的大数据应用特点，作者根据消息获取、推送、传递等现实业务需要，对该平台的研发申请立项后，确定了系统开发框架、系统建设目标和系统功能，历时近一年的研发，对接了急需消息传递的三个业务系统，该平台自上线运行以来，系统稳定。该平台具有消息管理、渠道分发、任务监控等功能的智能消息推送中心，统一消息推送渠道和标准，提供各业务系统的预警、处置等指令类信息推送服务，畅通大数据服务实战的渠道，对各类时效性要求较高的指令类消息，按照相应权限和处置流程推送至责任单位领导和工作人员的移动警务终端，提升了工作效能。

1  建设目标

为打通数据服务实战的“最后一公里”，实现一站式消息订阅和多业务点对点的消息推送服务，智慧统一消息平台建设确定了提供统一的移动应用管控服务、建立统一的消息中心、建立统一的消息频道管理、建立统一的移动业务门户、建立统一的消息通信机制规范五大目标：

（1）提供统一的移动应用管控服务。整合现有移动应用，并建立应用目录、业务分类。提供统一的移动应用快速入口，减少重复的登录操作，提高易用性。

（2）建立统一的消息中心，实现消息的全生命周期管理。综合使用移动互联网、大数据及云计算等现代科技，实现数据共享、消息分类、信息分级、精准推送等功能。以重点要素为主要对象构建统一的消息中心，把消息更好、更准、更快的推送到指定工作人员。

（3）建立统一的消息频道管理，畅通多元数据融合与消息推送渠道。满足单位对消息信息资源的汇聚、分类、管理、服务、发布等专项需要。建立多维多源的消息频道池，提供个性化、定制化的消息频道发布、整合、订阅、推送等精细服务。

（4）建立统一的移动业务门户，统一业务信息访问渠道，整合各种独立分散的业务系统消息。按照个性化要求对业务进行分类管理，快速定位业务应用并进行业务处理，加快内部信息流通。提供高可用扩展性，便于与其他系统对接、集成;提供应用监控、管理、统计分析等功能，挖掘应用能力，促进应用优化、完善。

（5）建立统一的消息通信机制规范。数据经抽取、清洗、整合、分类、标签化后，形成统一的数据规范;将业务消息的组装、加工、推送、交互等通过消息引擎形成标准的消息流;将业务应用的单点登录等业务交互制定成统一业务应用规范标准，同时不同业务按照规范进行调整。

2  平台总体架构

该架构总体上包括四个层次，分别是基础支撑层（IaaS）、数据服务层（DaaS）、平台服务层（PaaS）以及应用服务层（SaaS）。三套体系包括安全体系、运维体系和标准体系。形成资源共享数据交换机制。平台总体架构如图1所示。

（1）基础支撑层（IaaS）：承载该平台所需的硬件等基础设施全部由已建成的云平台统一提供，部分互联网端资源根据需要租用公有政务云资源。

（2）数据服务层（DaaS）：平台采集和抽取各业务管理系统数据并形成基础资源库，再根据人、地、物、事件、组织、网络等分类信息抽取整理为要素库，根据具体业务和实战化应用需要建设平台业务库，为业务应用和各实战化应用提供消息传递支撑服务。

（3）平台服务层（PaaS）：平台统一提供数据分析管控应用工具并建设业务应用中心。提供消息通信服务、智能推送服务、数据可视化调度服务、频道数据管理服务、统计分析服务、平台统一管理等服务，建设含可视化数据任务设计工具、自动化任务监控管理服务、可视化图表展示配置工具、可视化消息模板设计工具、数据源管理工具等平台服务。

（4）应用服务层（SaaS）：直接为各业务部门提供应用服务。应用服务包括移动门户、消息通知、点对点通信、消息推送、报表分析等应用服务。

3  平臺功能

智能消息推送中心建设采用统一的“1+3+X”架构，即：一个统一消息管理平台，三个服务中心（数据调度服务中心、频道管理服务中心、消息服务中心），及X个业务系统和实战化系统做支撑。明确统一消息平台是消息通信、信息推送工作唯一的综合性、智能化、大数据平台，数据调度服务中心是各业务系统协同开展数据交互消息传达桥梁通道。频道管理服务中心是海量的、异步的消息数据管理中心，对消息进行智能分类管理[1，2]，确保消息服务正常、精准、快速的运转。消息服务中心是实现消息业务互通、信息共享、信息直达，落实应用、资讯、任务的协同中心。

3.1  统一消息管理平台

统一消息管理平台包含统一用户管理子系统、平台管理子系统、移动应用市场子系统、移动应用子系统和智能图表分析子系统。

用户管理子系统包括用户登录、单点登录设置、用户账户查询、用户名称模糊检索、所在部门查询、用户录入、用户编辑、用户删除、批量删除、查看个人信息、重置密码、锁定用户、激活用户、导入用户、设置用户角色、设置组织机构等模块功能维护。

平台管理子系统包括平台风格管理、菜单管理、平台接口管理、字典库管理、平台日志管理、平台监控和黑名单管理等其他管理模块。

移动应用市场子系统包括移动应用信息管理、APP移动应用分类管理、第三方接入APP移动应用接口管理。

移动应用子系统包括移动应用库管理、移动消息门户管理、消息通知管理和接口管理。

智能图表分析子系统包括基础图表、移动图标和图标字段等图形报表管理以及报表信息、报表设置、报表参数、动态报表配置等管理。

3.2  数据调度服务中心

数据调度服务中心包括调度任务监控管理子系统、数据调度子系统以及作业任务管理[3]。

调度任务监控管理子系统包括：提供可视化操作界面自动生成满足业务需要的调度服务器管理，含服务器IP、别名查询、服务器分类查询、新增服务器、编辑服务器信息、删除服务器等模块功能维护;提供可视化操作界面自动生成满足业务需要的服务器监控管理，包括服务器运行状态监控、服务器运行日志等模块功能维护。

数据调度子系统提供转换过程管理模块、数据输入组件、数据输出组件、数据处理组件、流模式数据传输组件、数据库支持组件、数据应用组件，数据处理服务。

作业任务管理包括作业管理、作业存储管理、流程化管理、数据接口扩展管理、传输及校验管理。作业管理包括作业管理、作业嵌套、任务执行、集群功能等模块功能维护;作业存储管理包括文本文件扩展、目录与文件扩展、导出数据文件、数据接口、数据库写入支持、数据转换与数据处理、数据映射扩展等模块功能维护;流程化管理包括事务支持、流程起止控制、数据流优先级控件、过程检测与判断、数据过滤、追加数据流、阻塞数据指导步骤完成、情况判断、分支处理、并行处理等模块功能维护;数据接口扩展管理包括规则表达式、代码逻辑嵌入、接口查询、数据仓库支持等模块功能维护;传输及校验管理包括数据校验、数据传输加解密、转换及作业导出、数据存储加解密等模块功能维护。

3.3  频道管理服务中心

频道管理服务中心是一种基于多维分析和决策树相结合的数据分类管理系统，提供池化数据的收集、组织、分类、转换、加工、传播等功能，包括数据指标管理和频道管理。

数据指标管理包括数据指标规则的定义、指标项的定义、指标的发布和指标的维护，提供包括指标查询、基础指标多维报表的生成以及为其他系统提供的对接接口等功能。

频道管理将发布的对接接口进行二次封装，通过包装、转换化繁为简，通过定义频道规则、频道内容、频道分类等形成结构化频道目录库。将复杂专业的数据操作转换为直观的频道信息，供用户订阅。

3.4  消息服务中心

消息服务中心包括强制消息、重要消息、普通消息的管理。

强制消息模式用于处理带有强制推送消息标识的消息实体，强制消息实体的处理优先级高，排在消息队列的前面，系统会进行优先处理。除了优先级外，强制消息实体也会在消息推送处理[4]、消息提醒处理、消息展示处理、消息统计分析时与普通消息不同，如展示位置、提醒方式等[5]。强制消息的展示位置统一设置成置顶显示，提醒方式为震动加响铃双提醒。

重要消息模式用于处理带有重要推送消息标识的消息实体，重要消息实体的处理优先级高，但低于强制消息实体，同样排在消息队列的前面，系统会进行优先处理。重要消息的展示位置统一设置成在终端中部展示，提醒方式为响铃提醒。

普通消息模式是指平台消息模式优先级低于其他模式，并且不做强调处理的模式，消息在队列中将等待其他优先级高的消息执行完成后在空闲时间执行，并且在展示、统计、提醒时进行弱化，不响铃、不震动、不置顶显示。

4  平台效果

随着平台的上线运行，不断地接入各业务系统需要传递的消息，实现了系统建设初期设定的各项任务指标，完成了系统间消息的无缝对接和传递，解决了系统消息封闭在系统内的死循环问题，落实了消息的全生命周期的管理。同时，通过研发大屏看板，直观展示了物理资源的使用情況及效率，通过柱状图、饼状图、数据表等方式以不同维度统计了各种消息传递的数量和质量。图2为该平台的后台管理界面示意图。

5  结  论

智慧统一消息平台的研究和开发，进一步强化了系统思维，坚持了强基导向，为各业务系统消息的传递提供了平台级的架构支撑，解决了平台内和平台间消息无法传递的问题。后期，将随着业务发展的需要，进一步完善和丰富平台功能，在统一接口规范的框架和机制下，实现消息的应接尽接，并在消息的溯源管理、接口的可扩展性、一键直达业务应用、全消息便捷订阅、消息处理结果的反哺与回归等方面不断丰富和完善。

参考文献：

[1] 刘继刚.海量高性能分布式消息系统的设计与实现 [D].广州：华南理工大学，2018.

[2] 骆文亮.基于异步消息处理的RabbitMQ运行原理探讨 [J].数码世界，2017（11）：400.

[3] 刘明剑.多自治车辆协同消息调度机制研究 [D].大连：大连理工大学，2017.

[4] 王晓玉.基于Comet的消息推送系统的研究与实现 [D].西安：西安电子科技大学，2018.

[5] 廖宁，杨文.智慧校园高校统一消息中心平台的设计与实现 [J].电脑知识与技术，2019，15（19）：93-95.

作者简介：李雪松（1978.09—），男，汉族，湖北武穴人，主任，本科，研究方向：公安大数据实战应用;唐亮（1984.06—），男，汉族，湖北黄陂人，就职于公共视频管理大队，大队长，本科，研究方向：公安视频大数据应用;王靖（1988.02—），男，汉族，湖北黄石人，民警，本科，研究方向：公安大数据实战应用;周晨辉（1992.01—），男，汉族，湖北黄梅人，民警，本科，研究方向：公安大数据实战应用;沈少周（1992.06—），男，汉族，河南信阳人，民警，本科，研究方向：公安大数据实战应用。