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

摘 ?要：為實(shí)現(xiàn)業(yè)務(wù)系統(tǒng)的消息推送，并實(shí)現(xiàn)消息在不同業(yè)務(wù)系統(tǒng)間的傳遞，研發(fā)了智慧統(tǒng)一消息平臺(tái)。通過(guò)分析各業(yè)務(wù)系統(tǒng)消息產(chǎn)生的機(jī)制以及消息傳遞的特征，圍繞消息的全生命周期管理，實(shí)現(xiàn)了業(yè)務(wù)系統(tǒng)消息有效獲取、消息頻道管理、消息處理、消息分發(fā)、消息傳遞、任務(wù)監(jiān)控，并建立統(tǒng)一的消息通信機(jī)制規(guī)范。通過(guò)系統(tǒng)上線試運(yùn)行，實(shí)現(xiàn)了消息的一站式推送和管理，提升了工作效率。

關(guān)鍵詞：系統(tǒng)消息;消息傳遞;消息推送;消息平臺(tái)

中圖分類號(hào)：TP315 ? ? ?文獻(xiàn)標(biāo)識(shí)碼：A 文章編號(hào)：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 ?引 ?言

為貫徹落實(shí)數(shù)據(jù)警務(wù)、智慧公安的戰(zhàn)略規(guī)劃和數(shù)據(jù)賦能、全警應(yīng)用的大數(shù)據(jù)應(yīng)用特點(diǎn)，作者根據(jù)消息獲取、推送、傳遞等現(xiàn)實(shí)業(yè)務(wù)需要，對(duì)該平臺(tái)的研發(fā)申請(qǐng)立項(xiàng)后，確定了系統(tǒng)開(kāi)發(fā)框架、系統(tǒng)建設(shè)目標(biāo)和系統(tǒng)功能，歷時(shí)近一年的研發(fā)，對(duì)接了急需消息傳遞的三個(gè)業(yè)務(wù)系統(tǒng)，該平臺(tái)自上線運(yùn)行以來(lái)，系統(tǒng)穩(wěn)定。該平臺(tái)具有消息管理、渠道分發(fā)、任務(wù)監(jiān)控等功能的智能消息推送中心，統(tǒng)一消息推送渠道和標(biāo)準(zhǔn)，提供各業(yè)務(wù)系統(tǒng)的預(yù)警、處置等指令類信息推送服務(wù)，暢通大數(shù)據(jù)服務(wù)實(shí)戰(zhàn)的渠道，對(duì)各類時(shí)效性要求較高的指令類消息，按照相應(yīng)權(quán)限和處置流程推送至責(zé)任單位領(lǐng)導(dǎo)和工作人員的移動(dòng)警務(wù)終端，提升了工作效能。

1 ?建設(shè)目標(biāo)

為打通數(shù)據(jù)服務(wù)實(shí)戰(zhàn)的“最后一公里”，實(shí)現(xiàn)一站式消息訂閱和多業(yè)務(wù)點(diǎn)對(duì)點(diǎn)的消息推送服務(wù)，智慧統(tǒng)一消息平臺(tái)建設(shè)確定了提供統(tǒng)一的移動(dòng)應(yīng)用管控服務(wù)、建立統(tǒng)一的消息中心、建立統(tǒng)一的消息頻道管理、建立統(tǒng)一的移動(dòng)業(yè)務(wù)門(mén)戶、建立統(tǒng)一的消息通信機(jī)制規(guī)范五大目標(biāo)：

（1）提供統(tǒng)一的移動(dòng)應(yīng)用管控服務(wù)。整合現(xiàn)有移動(dòng)應(yīng)用，并建立應(yīng)用目錄、業(yè)務(wù)分類。提供統(tǒng)一的移動(dòng)應(yīng)用快速入口，減少重復(fù)的登錄操作，提高易用性。

（2）建立統(tǒng)一的消息中心，實(shí)現(xiàn)消息的全生命周期管理。綜合使用移動(dòng)互聯(lián)網(wǎng)、大數(shù)據(jù)及云計(jì)算等現(xiàn)代科技，實(shí)現(xiàn)數(shù)據(jù)共享、消息分類、信息分級(jí)、精準(zhǔn)推送等功能。以重點(diǎn)要素為主要對(duì)象構(gòu)建統(tǒng)一的消息中心，把消息更好、更準(zhǔn)、更快的推送到指定工作人員。

（3）建立統(tǒng)一的消息頻道管理，暢通多元數(shù)據(jù)融合與消息推送渠道。滿足單位對(duì)消息信息資源的匯聚、分類、管理、服務(wù)、發(fā)布等專項(xiàng)需要。建立多維多源的消息頻道池，提供個(gè)性化、定制化的消息頻道發(fā)布、整合、訂閱、推送等精細(xì)服務(wù)。

（4）建立統(tǒng)一的移動(dòng)業(yè)務(wù)門(mén)戶，統(tǒng)一業(yè)務(wù)信息訪問(wèn)渠道，整合各種獨(dú)立分散的業(yè)務(wù)系統(tǒng)消息。按照個(gè)性化要求對(duì)業(yè)務(wù)進(jìn)行分類管理，快速定位業(yè)務(wù)應(yīng)用并進(jìn)行業(yè)務(wù)處理，加快內(nèi)部信息流通。提供高可用擴(kuò)展性，便于與其他系統(tǒng)對(duì)接、集成;提供應(yīng)用監(jiān)控、管理、統(tǒng)計(jì)分析等功能，挖掘應(yīng)用能力，促進(jìn)應(yīng)用優(yōu)化、完善。

（5）建立統(tǒng)一的消息通信機(jī)制規(guī)范。數(shù)據(jù)經(jīng)抽取、清洗、整合、分類、標(biāo)簽化后，形成統(tǒng)一的數(shù)據(jù)規(guī)范;將業(yè)務(wù)消息的組裝、加工、推送、交互等通過(guò)消息引擎形成標(biāo)準(zhǔn)的消息流;將業(yè)務(wù)應(yīng)用的單點(diǎn)登錄等業(yè)務(wù)交互制定成統(tǒng)一業(yè)務(wù)應(yīng)用規(guī)范標(biāo)準(zhǔn)，同時(shí)不同業(yè)務(wù)按照規(guī)范進(jìn)行調(diào)整。

2 ?平臺(tái)總體架構(gòu)

該架構(gòu)總體上包括四個(gè)層次，分別是基礎(chǔ)支撐層（IaaS）、數(shù)據(jù)服務(wù)層（DaaS）、平臺(tái)服務(wù)層（PaaS）以及應(yīng)用服務(wù)層（SaaS）。三套體系包括安全體系、運(yùn)維體系和標(biāo)準(zhǔn)體系。形成資源共享數(shù)據(jù)交換機(jī)制。平臺(tái)總體架構(gòu)如圖1所示。

（1）基礎(chǔ)支撐層（IaaS）：承載該平臺(tái)所需的硬件等基礎(chǔ)設(shè)施全部由已建成的云平臺(tái)統(tǒng)一提供，部分互聯(lián)網(wǎng)端資源根據(jù)需要租用公有政務(wù)云資源。

（2）數(shù)據(jù)服務(wù)層（DaaS）：平臺(tái)采集和抽取各業(yè)務(wù)管理系統(tǒng)數(shù)據(jù)并形成基礎(chǔ)資源庫(kù)，再根據(jù)人、地、物、事件、組織、網(wǎng)絡(luò)等分類信息抽取整理為要素庫(kù)，根據(jù)具體業(yè)務(wù)和實(shí)戰(zhàn)化應(yīng)用需要建設(shè)平臺(tái)業(yè)務(wù)庫(kù)，為業(yè)務(wù)應(yīng)用和各實(shí)戰(zhàn)化應(yīng)用提供消息傳遞支撐服務(wù)。

（3）平臺(tái)服務(wù)層（PaaS）：平臺(tái)統(tǒng)一提供數(shù)據(jù)分析管控應(yīng)用工具并建設(shè)業(yè)務(wù)應(yīng)用中心。提供消息通信服務(wù)、智能推送服務(wù)、數(shù)據(jù)可視化調(diào)度服務(wù)、頻道數(shù)據(jù)管理服務(wù)、統(tǒng)計(jì)分析服務(wù)、平臺(tái)統(tǒng)一管理等服務(wù)，建設(shè)含可視化數(shù)據(jù)任務(wù)設(shè)計(jì)工具、自動(dòng)化任務(wù)監(jiān)控管理服務(wù)、可視化圖表展示配置工具、可視化消息模板設(shè)計(jì)工具、數(shù)據(jù)源管理工具等平臺(tái)服務(wù)。

（4）應(yīng)用服務(wù)層（SaaS）：直接為各業(yè)務(wù)部門(mén)提供應(yīng)用服務(wù)。應(yīng)用服務(wù)包括移動(dòng)門(mén)戶、消息通知、點(diǎn)對(duì)點(diǎn)通信、消息推送、報(bào)表分析等應(yīng)用服務(wù)。

3 ?平臺(tái)功能

智能消息推送中心建設(shè)采用統(tǒng)一的“1+3+X”架構(gòu)，即：一個(gè)統(tǒng)一消息管理平臺(tái)，三個(gè)服務(wù)中心（數(shù)據(jù)調(diào)度服務(wù)中心、頻道管理服務(wù)中心、消息服務(wù)中心），及X個(gè)業(yè)務(wù)系統(tǒng)和實(shí)戰(zhàn)化系統(tǒng)做支撐。明確統(tǒng)一消息平臺(tái)是消息通信、信息推送工作唯一的綜合性、智能化、大數(shù)據(jù)平臺(tái)，數(shù)據(jù)調(diào)度服務(wù)中心是各業(yè)務(wù)系統(tǒng)協(xié)同開(kāi)展數(shù)據(jù)交互消息傳達(dá)橋梁通道。頻道管理服務(wù)中心是海量的、異步的消息數(shù)據(jù)管理中心，對(duì)消息進(jìn)行智能分類管理[1，2]，確保消息服務(wù)正常、精準(zhǔn)、快速的運(yùn)轉(zhuǎn)。消息服務(wù)中心是實(shí)現(xiàn)消息業(yè)務(wù)互通、信息共享、信息直達(dá)，落實(shí)應(yīng)用、資訊、任務(wù)的協(xié)同中心。

3.1 ?統(tǒng)一消息管理平臺(tái)

統(tǒng)一消息管理平臺(tái)包含統(tǒng)一用戶管理子系統(tǒng)、平臺(tái)管理子系統(tǒng)、移動(dòng)應(yīng)用市場(chǎng)子系統(tǒng)、移動(dòng)應(yīng)用子系統(tǒng)和智能圖表分析子系統(tǒng)。

用戶管理子系統(tǒng)包括用戶登錄、單點(diǎn)登錄設(shè)置、用戶賬戶查詢、用戶名稱模糊檢索、所在部門(mén)查詢、用戶錄入、用戶編輯、用戶刪除、批量刪除、查看個(gè)人信息、重置密碼、鎖定用戶、激活用戶、導(dǎo)入用戶、設(shè)置用戶角色、設(shè)置組織機(jī)構(gòu)等模塊功能維護(hù)。

平臺(tái)管理子系統(tǒng)包括平臺(tái)風(fēng)格管理、菜單管理、平臺(tái)接口管理、字典庫(kù)管理、平臺(tái)日志管理、平臺(tái)監(jiān)控和黑名單管理等其他管理模塊。

移動(dòng)應(yīng)用市場(chǎng)子系統(tǒng)包括移動(dòng)應(yīng)用信息管理、APP移動(dòng)應(yīng)用分類管理、第三方接入APP移動(dòng)應(yīng)用接口管理。

移動(dòng)應(yīng)用子系統(tǒng)包括移動(dòng)應(yīng)用庫(kù)管理、移動(dòng)消息門(mén)戶管理、消息通知管理和接口管理。

智能圖表分析子系統(tǒng)包括基礎(chǔ)圖表、移動(dòng)圖標(biāo)和圖標(biāo)字段等圖形報(bào)表管理以及報(bào)表信息、報(bào)表設(shè)置、報(bào)表參數(shù)、動(dòng)態(tài)報(bào)表配置等管理。

3.2 ?數(shù)據(jù)調(diào)度服務(wù)中心

數(shù)據(jù)調(diào)度服務(wù)中心包括調(diào)度任務(wù)監(jiān)控管理子系統(tǒng)、數(shù)據(jù)調(diào)度子系統(tǒng)以及作業(yè)任務(wù)管理[3]。

調(diào)度任務(wù)監(jiān)控管理子系統(tǒng)包括：提供可視化操作界面自動(dòng)生成滿足業(yè)務(wù)需要的調(diào)度服務(wù)器管理，含服務(wù)器IP、別名查詢、服務(wù)器分類查詢、新增服務(wù)器、編輯服務(wù)器信息、刪除服務(wù)器等模塊功能維護(hù);提供可視化操作界面自動(dòng)生成滿足業(yè)務(wù)需要的服務(wù)器監(jiān)控管理，包括服務(wù)器運(yùn)行狀態(tài)監(jiān)控、服務(wù)器運(yùn)行日志等模塊功能維護(hù)。

數(shù)據(jù)調(diào)度子系統(tǒng)提供轉(zhuǎn)換過(guò)程管理模塊、數(shù)據(jù)輸入組件、數(shù)據(jù)輸出組件、數(shù)據(jù)處理組件、流模式數(shù)據(jù)傳輸組件、數(shù)據(jù)庫(kù)支持組件、數(shù)據(jù)應(yīng)用組件，數(shù)據(jù)處理服務(wù)。

作業(yè)任務(wù)管理包括作業(yè)管理、作業(yè)存儲(chǔ)管理、流程化管理、數(shù)據(jù)接口擴(kuò)展管理、傳輸及校驗(yàn)管理。作業(yè)管理包括作業(yè)管理、作業(yè)嵌套、任務(wù)執(zhí)行、集群功能等模塊功能維護(hù);作業(yè)存儲(chǔ)管理包括文本文件擴(kuò)展、目錄與文件擴(kuò)展、導(dǎo)出數(shù)據(jù)文件、數(shù)據(jù)接口、數(shù)據(jù)庫(kù)寫(xiě)入支持、數(shù)據(jù)轉(zhuǎn)換與數(shù)據(jù)處理、數(shù)據(jù)映射擴(kuò)展等模塊功能維護(hù);流程化管理包括事務(wù)支持、流程起止控制、數(shù)據(jù)流優(yōu)先級(jí)控件、過(guò)程檢測(cè)與判斷、數(shù)據(jù)過(guò)濾、追加數(shù)據(jù)流、阻塞數(shù)據(jù)指導(dǎo)步驟完成、情況判斷、分支處理、并行處理等模塊功能維護(hù);數(shù)據(jù)接口擴(kuò)展管理包括規(guī)則表達(dá)式、代碼邏輯嵌入、接口查詢、數(shù)據(jù)倉(cāng)庫(kù)支持等模塊功能維護(hù);傳輸及校驗(yàn)管理包括數(shù)據(jù)校驗(yàn)、數(shù)據(jù)傳輸加解密、轉(zhuǎn)換及作業(yè)導(dǎo)出、數(shù)據(jù)存儲(chǔ)加解密等模塊功能維護(hù)。

3.3 ?頻道管理服務(wù)中心

頻道管理服務(wù)中心是一種基于多維分析和決策樹(shù)相結(jié)合的數(shù)據(jù)分類管理系統(tǒng)，提供池化數(shù)據(jù)的收集、組織、分類、轉(zhuǎn)換、加工、傳播等功能，包括數(shù)據(jù)指標(biāo)管理和頻道管理。

數(shù)據(jù)指標(biāo)管理包括數(shù)據(jù)指標(biāo)規(guī)則的定義、指標(biāo)項(xiàng)的定義、指標(biāo)的發(fā)布和指標(biāo)的維護(hù)，提供包括指標(biāo)查詢、基礎(chǔ)指標(biāo)多維報(bào)表的生成以及為其他系統(tǒng)提供的對(duì)接接口等功能。

頻道管理將發(fā)布的對(duì)接接口進(jìn)行二次封裝，通過(guò)包裝、轉(zhuǎn)換化繁為簡(jiǎn)，通過(guò)定義頻道規(guī)則、頻道內(nèi)容、頻道分類等形成結(jié)構(gòu)化頻道目錄庫(kù)。將復(fù)雜專業(yè)的數(shù)據(jù)操作轉(zhuǎn)換為直觀的頻道信息，供用戶訂閱。

3.4 ?消息服務(wù)中心

消息服務(wù)中心包括強(qiáng)制消息、重要消息、普通消息的管理。

強(qiáng)制消息模式用于處理帶有強(qiáng)制推送消息標(biāo)識(shí)的消息實(shí)體，強(qiáng)制消息實(shí)體的處理優(yōu)先級(jí)高，排在消息隊(duì)列的前面，系統(tǒng)會(huì)進(jìn)行優(yōu)先處理。除了優(yōu)先級(jí)外，強(qiáng)制消息實(shí)體也會(huì)在消息推送處理[4]、消息提醒處理、消息展示處理、消息統(tǒng)計(jì)分析時(shí)與普通消息不同，如展示位置、提醒方式等[5]。強(qiáng)制消息的展示位置統(tǒng)一設(shè)置成置頂顯示，提醒方式為震動(dòng)加響鈴雙提醒。

重要消息模式用于處理帶有重要推送消息標(biāo)識(shí)的消息實(shí)體，重要消息實(shí)體的處理優(yōu)先級(jí)高，但低于強(qiáng)制消息實(shí)體，同樣排在消息隊(duì)列的前面，系統(tǒng)會(huì)進(jìn)行優(yōu)先處理。重要消息的展示位置統(tǒng)一設(shè)置成在終端中部展示，提醒方式為響鈴提醒。

普通消息模式是指平臺(tái)消息模式優(yōu)先級(jí)低于其他模式，并且不做強(qiáng)調(diào)處理的模式，消息在隊(duì)列中將等待其他優(yōu)先級(jí)高的消息執(zhí)行完成后在空閑時(shí)間執(zhí)行，并且在展示、統(tǒng)計(jì)、提醒時(shí)進(jìn)行弱化，不響鈴、不震動(dòng)、不置頂顯示。

4 ?平臺(tái)效果

隨著平臺(tái)的上線運(yùn)行，不斷地接入各業(yè)務(wù)系統(tǒng)需要傳遞的消息，實(shí)現(xiàn)了系統(tǒng)建設(shè)初期設(shè)定的各項(xiàng)任務(wù)指標(biāo)，完成了系統(tǒng)間消息的無(wú)縫對(duì)接和傳遞，解決了系統(tǒng)消息封閉在系統(tǒng)內(nèi)的死循環(huán)問(wèn)題，落實(shí)了消息的全生命周期的管理。同時(shí)，通過(guò)研發(fā)大屏看板，直觀展示了物理資源的使用情況及效率，通過(guò)柱狀圖、餅狀圖、數(shù)據(jù)表等方式以不同維度統(tǒng)計(jì)了各種消息傳遞的數(shù)量和質(zhì)量。圖2為該平臺(tái)的后臺(tái)管理界面示意圖。

5 ?結(jié) ?論

智慧統(tǒng)一消息平臺(tái)的研究和開(kāi)發(fā)，進(jìn)一步強(qiáng)化了系統(tǒng)思維，堅(jiān)持了強(qiáng)基導(dǎo)向，為各業(yè)務(wù)系統(tǒng)消息的傳遞提供了平臺(tái)級(jí)的架構(gòu)支撐，解決了平臺(tái)內(nèi)和平臺(tái)間消息無(wú)法傳遞的問(wèn)題。后期，將隨著業(yè)務(wù)發(fā)展的需要，進(jìn)一步完善和豐富平臺(tái)功能，在統(tǒng)一接口規(guī)范的框架和機(jī)制下，實(shí)現(xiàn)消息的應(yīng)接盡接，并在消息的溯源管理、接口的可擴(kuò)展性、一鍵直達(dá)業(yè)務(wù)應(yīng)用、全消息便捷訂閱、消息處理結(jié)果的反哺與回歸等方面不斷豐富和完善。

參考文獻(xiàn)：

[1] 劉繼剛.海量高性能分布式消息系統(tǒng)的設(shè)計(jì)與實(shí)現(xiàn) [D].廣州：華南理工大學(xué)，2018.

[2] 駱文亮.基于異步消息處理的RabbitMQ運(yùn)行原理探討 [J].數(shù)碼世界，2017（11）：400.

[3] 劉明劍.多自治車輛協(xié)同消息調(diào)度機(jī)制研究 [D].大連：大連理工大學(xué)，2017.

[4] 王曉玉.基于Comet的消息推送系統(tǒng)的研究與實(shí)現(xiàn) [D].西安：西安電子科技大學(xué)，2018.

[5] 廖寧，楊文.智慧校園高校統(tǒng)一消息中心平臺(tái)的設(shè)計(jì)與實(shí)現(xiàn) [J].電腦知識(shí)與技術(shù)，2019，15（19）：93-95.

作者簡(jiǎn)介：李雪松（1978.09—），男，漢族，湖北武穴人，主任，本科，研究方向：公安大數(shù)據(jù)實(shí)戰(zhàn)應(yīng)用;唐亮（1984.06—），男，漢族，湖北黃陂人，就職于公共視頻管理大隊(duì)，大隊(duì)長(zhǎng)，本科，研究方向：公安視頻大數(shù)據(jù)應(yīng)用;王靖（1988.02—），男，漢族，湖北黃石人，民警，本科，研究方向：公安大數(shù)據(jù)實(shí)戰(zhàn)應(yīng)用;周晨輝（1992.01—），男，漢族，湖北黃梅人，民警，本科，研究方向：公安大數(shù)據(jù)實(shí)戰(zhàn)應(yīng)用;沈少周（1992.06—），男，漢族，河南信陽(yáng)人，民警，本科，研究方向：公安大數(shù)據(jù)實(shí)戰(zhàn)應(yīng)用。