智慧統一消息平臺研究

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

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

關鍵詞：系統消息;消息傳遞;消息推送;消息平臺

中圖分類號：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—），男，漢族，河南信陽人，民警，本科，研究方向：公安大數據實戰應用。