智慧統(tǒng)一消息平臺研究

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

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

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

中圖分類號：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 ?引 ?言

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

1 ?建設目標

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

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

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

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

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

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

2 ?平臺總體架構

該架構總體上包括四個層次，分別是基礎支撐層（IaaS）、數(shù)據(jù)服務層（DaaS）、平臺服務層（PaaS）以及應用服務層（SaaS）。三套體系包括安全體系、運維體系和標準體系。形成資源共享數(shù)據(jù)交換機制。平臺總體架構如圖1所示。

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

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

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

（4）應用服務層（SaaS）：直接為各業(yè)務部門提供應用服務。應用服務包括移動門戶、消息通知、點對點通信、消息推送、報表分析等應用服務。

3 ?平臺功能

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

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

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

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

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

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

移動應用子系統(tǒng)包括移動應用庫管理、移動消息門戶管理、消息通知管理和接口管理。

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

3.2 ?數(shù)據(jù)調度服務中心

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

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

數(shù)據(jù)調度子系統(tǒng)提供轉換過程管理模塊、數(shù)據(jù)輸入組件、數(shù)據(jù)輸出組件、數(shù)據(jù)處理組件、流模式數(shù)據(jù)傳輸組件、數(shù)據(jù)庫支持組件、數(shù)據(jù)應用組件，數(shù)據(jù)處理服務。

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

3.3 ?頻道管理服務中心

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

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

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

3.4 ?消息服務中心

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

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

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

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

4 ?平臺效果

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

5 ?結 ?論

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

參考文獻：

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

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

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

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

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

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