徐樂 姜西斌 劉光耀 公安部第一研究所

引言

近年來，移動警務(wù)終端形態(tài)變得豐富多樣，傳統(tǒng)的移動警務(wù)終端逐步擴展，執(zhí)法記錄儀、無人機、機器人、可佩戴類設(shè)備、車載類設(shè)備層出不窮，數(shù)據(jù)資源也擴展為語音、視頻、圖像、數(shù)據(jù)等，民警對于移動執(zhí)法辦公的需求越來越迫切，視頻回傳、圖像回傳、讓數(shù)據(jù)多跑路，民警少跑腿的需求越加顯著。傳統(tǒng)的監(jiān)控系統(tǒng)、指揮調(diào)度系統(tǒng)等，其管控端均依賴于Web平臺，指揮調(diào)度人員需在監(jiān)控室查看前方民警的實際情況，限制了指揮作戰(zhàn)能力。

各設(shè)備間相互孤立、調(diào)度困難、資源浪費成為移動警務(wù)工作的一大瓶頸，因此，在多形態(tài)移動警務(wù)終端迅猛發(fā)展、5G通信網(wǎng)絡(luò)普及的雙重驅(qū)動下，實現(xiàn)移動警務(wù)的資源調(diào)度成為了必然結(jié)果[1]。

一、系統(tǒng)架構(gòu)

（一）系統(tǒng)概述

該系統(tǒng)是基于物聯(lián)網(wǎng)技術(shù)的移動警務(wù)終端資源調(diào)度系統(tǒng)，實現(xiàn)了資源回傳和遠程調(diào)度功能。一方面，系統(tǒng)可將多形態(tài)移動警務(wù)終端采集的數(shù)據(jù)，實時高效的回傳至民警的移動警務(wù)終端，使民警真正具有“千里眼”“順風(fēng)耳”，可實時查看圖像、文本等信息；另一方面，民警可通過移動警務(wù)終端，隨時隨地遠程調(diào)度有采集功能的多形態(tài)移動警務(wù)終端，使民警辦公更靈活、更便捷，實現(xiàn)協(xié)同作戰(zhàn)。

系統(tǒng)架構(gòu)如圖1所示，系統(tǒng)主要包括采集側(cè)、用戶側(cè)、資源調(diào)度系統(tǒng)三個部分。

1.采集側(cè)

采集側(cè)即為多形態(tài)移動警務(wù)終端，運行于聯(lián)網(wǎng)服務(wù)子平臺或移動互聯(lián)網(wǎng)服務(wù)子平臺，用于接收由資源調(diào)度系統(tǒng)轉(zhuǎn)發(fā)的用戶側(cè)控制信令，采集并推送視頻流、圖像信息、文本消息、音頻流等，終端類型如AR智能眼鏡、警務(wù)機器人、攝像頭、智能手環(huán)、執(zhí)法記錄儀、可穿戴設(shè)備、無人機、移動警務(wù)終端等。

2.用戶側(cè)

用戶側(cè)即為移動警務(wù)終端，運行于聯(lián)網(wǎng)服務(wù)子平臺，一方面用于民警查看采集側(cè)推送的各種數(shù)據(jù)消息及預(yù)警信息，另一方面可遠程發(fā)送控制信令，實現(xiàn)遠程調(diào)度的功能，主要包括統(tǒng)一認證、應(yīng)用?；?、密碼保護等，終端類型如移動警務(wù)手機。

3.資源調(diào)度系統(tǒng)

資源調(diào)度系統(tǒng)即為系統(tǒng)的核心部分，基于Jetlinks物聯(lián)網(wǎng)基礎(chǔ)平臺，為采集側(cè)和用戶側(cè)提供消息路由轉(zhuǎn)發(fā)功能，實現(xiàn)數(shù)據(jù)交互。主要包括設(shè)備接入網(wǎng)關(guān)、系統(tǒng)管理、事件總線三個功能模塊。

（1）設(shè)備接入網(wǎng)關(guān)：負責(zé)系統(tǒng)側(cè)統(tǒng)一的設(shè)備接入，包含網(wǎng)絡(luò)組件、協(xié)議解析等。設(shè)備接入時，由網(wǎng)絡(luò)組件接收請求報文，由協(xié)議解析將報文映射為系統(tǒng)統(tǒng)一的消息類型，然后推送到事件總線。

其中協(xié)議解析支持自定義協(xié)議和系統(tǒng)默認協(xié)議，規(guī)定了消息解析規(guī)則，可將設(shè)備發(fā)送至系統(tǒng)的消息解析為系統(tǒng)統(tǒng)一Topic，也可將系統(tǒng)下發(fā)給設(shè)備的消息解析為設(shè)備支持的格式類型。

（2）系統(tǒng)管理：從用戶管理、終端管理、安全管理、授權(quán)管理等多維度實現(xiàn)系統(tǒng)的安全管控，確保雙向業(yè)務(wù)數(shù)據(jù)的安全擺渡、可追溯、可審計，特別是將關(guān)鍵業(yè)務(wù)數(shù)據(jù)發(fā)送至民警終端時，確保民警、終端均安全可靠，均在后臺授權(quán)管理，同時數(shù)據(jù)需經(jīng)過脫敏處理，采用加水印、加解密、簽名驗簽、分級顯示、黑白名單等方法，避免數(shù)據(jù)被惡意篡改或泄露。

（3）事件總線：基于Topic和事件驅(qū)動，負責(zé)進程內(nèi)的數(shù)據(jù)轉(zhuǎn)發(fā)。事件總線是一個基于發(fā)布/訂閱模式的事件傳遞組件，通過解耦發(fā)布者和訂閱者之間的調(diào)用，降低設(shè)備接入網(wǎng)關(guān)與后續(xù)業(yè)務(wù)邏輯之間的耦合，發(fā)布者將數(shù)據(jù)經(jīng)設(shè)備接入網(wǎng)關(guān)發(fā)送至事件總線，由事件總線轉(zhuǎn)發(fā)/廣播至已訂閱該Topic的訂閱者[2]。

（二）關(guān)鍵技術(shù)

系統(tǒng)基于Jetlinks物聯(lián)網(wǎng)基礎(chǔ)平臺，采用Java8、Springboot、Webflux、Netty、Vert.x等開發(fā)，是一個全響應(yīng)式的資源調(diào)度系統(tǒng)，通過響應(yīng)式編程、事件總線、多協(xié)議適配等技術(shù)解決了關(guān)鍵難題。

1.響應(yīng)式編程

系統(tǒng)中會有很多耗時任務(wù)，比如網(wǎng)絡(luò)請求（甚至是跨網(wǎng)請求）、復(fù)雜計算、接口異常引起的超時等，導(dǎo)致接口響應(yīng)延遲，如果采用傳統(tǒng)函數(shù)編程模式，等待任務(wù)執(zhí)行完再繼續(xù)執(zhí)行，則會造成系統(tǒng)阻塞，嚴(yán)重影響系統(tǒng)性能，采用傳統(tǒng)的異步編程模式，則只能解決單一的事務(wù)異步處理，對于復(fù)雜的多事務(wù)異步組合型回調(diào)問題無法處理，因此系統(tǒng)采用響應(yīng)式編程框架，可以協(xié)調(diào)多個異步任務(wù)，解決耗時任務(wù)造成的系統(tǒng)阻塞問題[3]。

系統(tǒng)從網(wǎng)絡(luò)層到持久層全部封裝為非阻塞、響應(yīng)式調(diào)用，先構(gòu)造一個流以及處理流中數(shù)據(jù)的邏輯，當(dāng)流中產(chǎn)生了數(shù)據(jù)（發(fā)布、訂閱），才會執(zhí)行構(gòu)造好的邏輯，具有如下四個特性。

系統(tǒng)選用主流的Reactor作為響應(yīng)式編程框架，Reactor提供了強大的API，簡化了對數(shù)據(jù)各種處理方式的復(fù)雜度，通過訂閱和發(fā)布數(shù)據(jù)流中的數(shù)據(jù)對數(shù)據(jù)進行處理，提高了系統(tǒng)的計算速度和響應(yīng)速度。但開發(fā)過程中，響應(yīng)式編程也有缺點，調(diào)試不易，異常棧難跟蹤，對開發(fā)人員有更高的要求，因此可以在有網(wǎng)絡(luò)請求、計算量大、耗時較長的方法上使用該編程模式。

2.事件總線

對于錯綜復(fù)雜的資源調(diào)度系統(tǒng)，掛載幾十個甚至上百個移動警務(wù)終端（采集側(cè)和用戶側(cè)），設(shè)備產(chǎn)生的事件種類繁雜、格式多樣、交互任務(wù)繁重，需要能準(zhǔn)確的將數(shù)據(jù)路由到接收端。因此，該系統(tǒng)采用事件總線作為數(shù)據(jù)交互媒介，有效降低了代碼的耦合度，準(zhǔn)確將采集側(cè)的數(shù)據(jù)擺渡到用戶側(cè)，將用戶側(cè)指令下發(fā)到采集端。

事件總線是基于觀察者模式構(gòu)建的，觀察者模式是指當(dāng)一個對象（被觀察者）的狀態(tài)發(fā)生改變時，所有依賴于它的對象（觀察者）都將得到通知并自動更新。事件總線包含主題、發(fā)布者、訂閱者三部分，發(fā)布者將消息發(fā)送到事件總線后，無需關(guān)注由誰消費該事件，事件總線會發(fā)送廣播，將消息發(fā)送給已訂閱該消息的訂閱者，訂閱者也無需關(guān)心由誰發(fā)布的該事件，發(fā)布者和訂閱者均只需關(guān)注消息本身，避免發(fā)布者和訂閱者直接通信，從而使代碼更加簡潔。

該系統(tǒng)中，發(fā)布者（采集側(cè)或用戶側(cè)）推送消息到事件總線，并自動根據(jù)終端類型指定編碼器進行序列化，系統(tǒng)接收到發(fā)布者發(fā)送的消息后，根據(jù)協(xié)議解析消息，并將消息轉(zhuǎn)換為對應(yīng)的Topic 發(fā)送到事件總線，訂閱者從事件總線中訂閱該Topic，并按照指定的解碼器進行數(shù)據(jù)的轉(zhuǎn)換和接收，發(fā)布者也可通過系統(tǒng)確定有多少訂閱者多訂閱了此Topic。

3.多協(xié)議適配

多形態(tài)移動警務(wù)終端設(shè)備協(xié)議多樣化，單一的公有協(xié)議接入無法滿足多形態(tài)需求，私有協(xié)議無法接入或者接入困難，嚴(yán)重限制了多形態(tài)移動警務(wù)終端在警務(wù)工作中的擴展和使用。因此，系統(tǒng)實現(xiàn)了多協(xié)議適配，以滿足采集側(cè)不同警用裝備、不同格式數(shù)據(jù)的接入[4]。

該系統(tǒng)支持多協(xié)議、多形態(tài)移動警務(wù)終端的接入，在基礎(chǔ)通信協(xié)議TCP、UDP、HTTP、WEBSOCKET、MQTT等基礎(chǔ)上，能夠根據(jù)消息頭的不同，識別建立連接的多形態(tài)移動警務(wù)終端的協(xié)議類別，進行正確的編解碼，滿足低延時、高可靠、長連接、大吞吐、有序性、結(jié)構(gòu)化、非結(jié)構(gòu)化、可廣播等多種不同通信場景的需求。

協(xié)議轉(zhuǎn)換流程分五步進行：

（1）創(chuàng)建并發(fā)布產(chǎn)品。對于同一類型的移動警務(wù)終端，均歸屬于同一產(chǎn)品，同一產(chǎn)品則采用相同的通信協(xié)議。

（2）定義設(shè)備。在已發(fā)布的產(chǎn)品下，錄入/創(chuàng)建待接入的設(shè)備，并根據(jù)設(shè)備以及設(shè)備接入文檔（報文說明），定義設(shè)備的三種資源描述模型，并激活設(shè)備。

如表2所示，系統(tǒng)將設(shè)備從屬性、功能、事件三方面抽象為資源描述模型，分別對應(yīng)三種消息類型。采用這三種資源描述模型來對資源進行歸類，可屏蔽設(shè)備的異構(gòu)性，對應(yīng)用提供統(tǒng)一的服務(wù)接口。

（3）接收報文，協(xié)議映射。設(shè)備向系統(tǒng)發(fā)送報文信息，系統(tǒng)收到終端上報的報文，使用創(chuàng)建產(chǎn)品時約定的協(xié)議包，將報文解析為系統(tǒng)統(tǒng)一的消息。

（4）發(fā)送至事件總線。將已解析的消息轉(zhuǎn)換為對應(yīng)的Topic，發(fā)送到事件總線。

需注意，針對不同的協(xié)議包、不同的消息類型，系統(tǒng)分別定義了不同URI接口和參數(shù)類供第三方調(diào)用和擴展，終端需依據(jù)標(biāo)準(zhǔn)URI和擴展參數(shù)類發(fā)送報文，從而便于消息向Topic映射。

（5）消費已訂閱事件。消息訂閱者可通過從事件總線訂閱消息來處理這些消息。

二、應(yīng)用示例

（一）通用應(yīng)用架構(gòu)

鑒于民警工作場景的復(fù)雜多樣、地域網(wǎng)絡(luò)建設(shè)的限制、業(yè)務(wù)場景的限制等，多形態(tài)移動警務(wù)終端多以聯(lián)網(wǎng)服務(wù)子平臺和移動互聯(lián)網(wǎng)服務(wù)子平臺兩種網(wǎng)絡(luò)形式接入，兩種網(wǎng)絡(luò)的通用應(yīng)用架構(gòu)如圖3所示。

在業(yè)務(wù)流程上，資源調(diào)度系統(tǒng)由資源調(diào)度服務(wù)器、流媒體播放平臺兩部分組成，依托前端數(shù)據(jù)采集單元、前端數(shù)據(jù)匯聚單元、及后方的移動警務(wù)終端實現(xiàn)協(xié)同作戰(zhàn)。

數(shù)據(jù)采集單元，即多形態(tài)移動警務(wù)終端，用于采集音視頻流、圖像、文本消息等。

數(shù)據(jù)匯聚單元，多形態(tài)移動警務(wù)終端對應(yīng)的后臺數(shù)據(jù)處理系統(tǒng)，如視頻網(wǎng)關(guān)、數(shù)據(jù)匯聚服務(wù)器、數(shù)據(jù)處理服務(wù)器、代理轉(zhuǎn)發(fā)服務(wù)器等。

網(wǎng)絡(luò)接入控制單元，即網(wǎng)絡(luò)接入控制器，部署在聯(lián)網(wǎng)服務(wù)子平臺，是移動警務(wù)邊界安全的重要實現(xiàn)機制，支持擴展直連終端接入到移動警務(wù)信息網(wǎng)的接入控制器設(shè)備，支持橋接中繼設(shè)備接入到移動警務(wù)信息網(wǎng)的接入控制器設(shè)備，部署于橋接中繼設(shè)備中的接入控制模塊，實現(xiàn)多形態(tài)設(shè)備安全地接入到移動警務(wù)平臺。

資源調(diào)度服務(wù)器，部署在聯(lián)網(wǎng)服務(wù)子平臺，實現(xiàn)圖像、文本、信令等短消息的數(shù)據(jù)擺渡、遠程調(diào)度等主要功能。

流媒體播放平臺，部署在聯(lián)網(wǎng)服務(wù)子平臺，實現(xiàn)音視頻等流媒體信息的數(shù)據(jù)擺渡，當(dāng)收到客戶端發(fā)起的視頻播放請求后，將流媒體信息根據(jù)客戶端需要的分辨率，推送到移動警務(wù)終端，實現(xiàn)視頻轉(zhuǎn)發(fā)播放功能。

移動警務(wù)終端，即民警使用的移動警務(wù)手機，用于遠程控制多形態(tài)移動警務(wù)終端，并接收其發(fā)布的數(shù)據(jù)流，實時展現(xiàn)在客戶端，便于民警協(xié)同作戰(zhàn)。

（二）多形態(tài)移動警務(wù)終端從聯(lián)網(wǎng)服務(wù)子平臺接入

終端從聯(lián)網(wǎng)服務(wù)子平臺接入，系統(tǒng)面向應(yīng)用提供服務(wù)接入能力。下面通過AR智能眼鏡資源調(diào)度系統(tǒng)進行舉例說明，系統(tǒng)架構(gòu)如圖4所示。

AR智能眼鏡運行在聯(lián)網(wǎng)服務(wù)子平臺，已符合安全接入規(guī)范，無需通過網(wǎng)絡(luò)接入控制器接入。

AR智能眼鏡是常見的警用穿戴設(shè)備，AR眼鏡端集成了高清攝像頭（單目或雙目）、麥克風(fēng)、耳機、微型顯示屏等，通過OTG與移動警務(wù)終端連接，眼鏡后臺有管理服務(wù)器和流媒體服務(wù)器，指揮調(diào)度人員可登錄WEB網(wǎng)頁端，對AR智能眼鏡端發(fā)起呼叫請求，建立連接后，民警眼鏡端的視頻可實時回傳至后臺網(wǎng)頁端，并可與后臺指揮人員實時通話，發(fā)送文字、圖片等。

AR智能眼鏡作為數(shù)據(jù)采集單元，僅有采集功能，民警實際應(yīng)用中，后臺指揮人員或者協(xié)作人員，不能局限于WEB端管理，還需要在移動警務(wù)終端實時獲取前方民警眼鏡端的視頻內(nèi)容，便于協(xié)作開展工作，因此需要本系統(tǒng)作為調(diào)度系統(tǒng)，將AR眼鏡端的數(shù)據(jù)實時回傳至后方民警的移動警務(wù)終端。

民警可通過AR智能眼鏡，遠距離無感采集需識別的相關(guān)信息，經(jīng)過眼鏡端簡單的數(shù)據(jù)處理后，再將采集信息通過流媒體服務(wù)器傳送至資源調(diào)度系統(tǒng)，通過約定的推送策略，推送至已上線并訂閱該主題的移動警務(wù)終端。同時，AR智能眼鏡端采集的音視頻流，也可依次通過流媒體服務(wù)器、流媒體播放平臺發(fā)送至移動警務(wù)終端。民警也可通過移動警務(wù)終端遠程操控AR眼鏡。

（三）多形態(tài)移動警務(wù)終端從移動互聯(lián)網(wǎng)服務(wù)子平臺接入

終端從移動互聯(lián)網(wǎng)服務(wù)子平臺接入，系統(tǒng)面向應(yīng)用提供服務(wù)接入能力。下面通過門禁系統(tǒng)進行舉例說明。監(jiān)控攝像頭、邊緣計算終端、數(shù)據(jù)匯聚服務(wù)器等均位于移動互聯(lián)網(wǎng)服務(wù)子平臺，系統(tǒng)架構(gòu)如圖5所示。

不同于從聯(lián)網(wǎng)服務(wù)子平臺接入的移動警務(wù)終端，移動互聯(lián)網(wǎng)服務(wù)子平臺的系統(tǒng)終端不具備身份管理、認證、接入、管控、數(shù)據(jù)訪問等安全管控機制，均需通過網(wǎng)絡(luò)接入控制器接入聯(lián)網(wǎng)服務(wù)子平臺[5]。

門禁系統(tǒng)部署在受控區(qū)域的大門位置，能有效核查受控區(qū)域狀況，及時發(fā)現(xiàn)在門口出現(xiàn)的情況并立即通知工作人員，確保受控區(qū)域安全，提升受控區(qū)域的安全防范系數(shù)。

監(jiān)控攝像頭持續(xù)采集受控區(qū)域附近的相關(guān)信息，實時將采集數(shù)據(jù)發(fā)送至數(shù)據(jù)匯聚服務(wù)器，再通過網(wǎng)絡(luò)接入控制器轉(zhuǎn)發(fā)至資源調(diào)度系統(tǒng)，一旦出現(xiàn)預(yù)警信息，立即向客戶端APP推送告警。同時，攝像頭端采集的視頻流可依次通過數(shù)據(jù)匯聚服務(wù)器、網(wǎng)絡(luò)接入控制器、流媒體播放平臺發(fā)送至移動警務(wù)終端。民警也可通過移動警務(wù)終端遠程操控監(jiān)控攝像頭。

三、結(jié)語

本系統(tǒng)作為一項基礎(chǔ)慧警系統(tǒng)，基于物聯(lián)網(wǎng)平臺實現(xiàn)了移動警務(wù)終端采集側(cè)和用戶側(cè)的數(shù)據(jù)轉(zhuǎn)發(fā)、遠程調(diào)度，優(yōu)化作戰(zhàn)方式，提升作戰(zhàn)效率，實現(xiàn)勤務(wù)模式的便捷和高效。針對不同警種的業(yè)務(wù)場景和業(yè)務(wù)需求，第三方開發(fā)者可在該系統(tǒng)的基礎(chǔ)上擴展豐富的應(yīng)用模式，將資源調(diào)度能力應(yīng)用到更廣泛的業(yè)務(wù)場景中，如門禁系統(tǒng)、車載系統(tǒng)、無人機、會議安保系統(tǒng)等，為公安移動信息化建設(shè)提供有力支撐。