[發(fā)明專利]一種基于數(shù)據(jù)流分布式處理的通航監(jiān)視方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202011306789.5
• 申請日: 2020-11-20
• 公開（公告）號: CN112311900B
• 公開（公告）日: 2023-02-03
• 發(fā)明（設(shè)計）人: 汪毅;程旗;姜山;馮軍;王彥成
• 申請（專利權(quán)）人: 四川九洲空管科技有限責任公司
• 主分類號: H04L67/12
• 分類號: H04L67/12;H04L67/52;H04L67/565;G01S19/14;G08G3/00
• 代理公司: 成都九鼎天元知識產(chǎn)權(quán)代理有限公司 51214
• 代理人: 胡川

1.一種基于數(shù)據(jù)流分布式處理的通航監(jiān)視方法，其特征在于，包括步驟：

S1：根據(jù)預(yù)先設(shè)定的策略調(diào)度分布部署于各服務(wù)器上的服務(wù)，形成監(jiān)視任務(wù)；

其中，預(yù)先設(shè)定的策略指定了監(jiān)視任務(wù)的執(zhí)行時間、執(zhí)行次數(shù)、性能要求，自動執(zhí)行任務(wù)并反饋信息，進行調(diào)度時，用戶可以在前端Web界面上可視化地完成監(jiān)視任務(wù)的管理，包括增加、刪除、修改、查詢、任務(wù)運行狀態(tài)監(jiān)控和運行日志查看功能，通過DAG圖在線配置監(jiān)視任務(wù)的依賴關(guān)系，對監(jiān)視任務(wù)進行編排，通過定制調(diào)度策略，實現(xiàn)定時、延遲和固定頻率執(zhí)行；

S2：在所述監(jiān)視任務(wù)形成后，接收各監(jiān)視設(shè)備發(fā)送的報文，并轉(zhuǎn)換成預(yù)定數(shù)據(jù)格式的監(jiān)視數(shù)據(jù)；

在所述監(jiān)視任務(wù)形成后，接收各監(jiān)視設(shè)備發(fā)送的報文，判斷報文是否符合預(yù)設(shè)協(xié)議，在符合預(yù)設(shè)協(xié)議時，解析報文的數(shù)據(jù)類型，查詢數(shù)據(jù)模板庫中是否存在相同的數(shù)據(jù)模板，在存在相同的數(shù)據(jù)模板時，轉(zhuǎn)換成預(yù)定數(shù)據(jù)格式的監(jiān)視數(shù)據(jù)；

S3：對各監(jiān)視設(shè)備的監(jiān)視數(shù)據(jù)進行關(guān)聯(lián)、跟蹤和航跡管理得到監(jiān)視對象，并輸出監(jiān)視對象的目標航跡；

S4：利用GIS引擎將監(jiān)視對象的目標航跡展示在人機交互界面上，同時監(jiān)聽人機交互界面上的指令操作，將所述指令操作分發(fā)給各服務(wù)器，提供目標告警服務(wù)和目標關(guān)聯(lián)研判服務(wù)；

其中，GIS引擎讀取本地的GIS地圖數(shù)據(jù)，將地圖和航線、空域作為底圖展示在人機交互界面上，并不斷將監(jiān)視對象的目標航跡更新到底圖上，指令操作分發(fā)給各服務(wù)器后，重新調(diào)度分布部署于各服務(wù)器上的服務(wù)，形成新的監(jiān)視任務(wù)。

2.根據(jù)權(quán)利要求1所述的通航監(jiān)視方法，其特征在于，所述步驟S2還包括：在不符合預(yù)設(shè)協(xié)議或不存在相同的數(shù)據(jù)模板時，生成日志記錄。

3.根據(jù)權(quán)利要求2所述的通航監(jiān)視方法，其特征在于，所述數(shù)據(jù)模板為xml格式。

4.根據(jù)權(quán)利要求2所述的通航監(jiān)視方法，其特征在于，所述預(yù)定數(shù)據(jù)格式為JSON格式。

5.一種基于數(shù)據(jù)流分布式處理的通航監(jiān)視系統(tǒng)，其特征在于，包括任務(wù)調(diào)度模塊、協(xié)議轉(zhuǎn)換模塊、目標處理模塊和通航監(jiān)視模塊；

所述任務(wù)調(diào)度模塊用于根據(jù)預(yù)先設(shè)定的策略調(diào)度分布部署于各服務(wù)器上的服務(wù)，形成監(jiān)視任務(wù)；

其中，預(yù)先設(shè)定的策略指定了監(jiān)視任務(wù)的執(zhí)行時間、執(zhí)行次數(shù)、性能要求，自動執(zhí)行任務(wù)并反饋信息，進行調(diào)度時，用戶可以在前端Web界面上可視化地完成監(jiān)視任務(wù)的管理，包括增加、刪除、修改、查詢、任務(wù)運行狀態(tài)監(jiān)控和運行日志查看功能，通過DAG圖在線配置監(jiān)視任務(wù)的依賴關(guān)系，對監(jiān)視任務(wù)進行編排，通過定制調(diào)度策略，實現(xiàn)定時、延遲和固定頻率執(zhí)行；

所述協(xié)議轉(zhuǎn)換模塊用于在所述監(jiān)視任務(wù)形成后，接收各監(jiān)視設(shè)備發(fā)送的報文，并轉(zhuǎn)換成預(yù)定數(shù)據(jù)格式的監(jiān)視數(shù)據(jù)；

在所述監(jiān)視任務(wù)形成后，接收各監(jiān)視設(shè)備發(fā)送的報文，判斷報文是否符合預(yù)設(shè)協(xié)議，在符合預(yù)設(shè)協(xié)議時，解析報文的數(shù)據(jù)類型，查詢數(shù)據(jù)模板庫中是否存在相同的數(shù)據(jù)模板，在存在相同的數(shù)據(jù)模板時，轉(zhuǎn)換成預(yù)定數(shù)據(jù)格式的監(jiān)視數(shù)據(jù)；

所述目標處理模塊用于對各監(jiān)視設(shè)備的監(jiān)視數(shù)據(jù)進行關(guān)聯(lián)、跟蹤和航跡管理得到監(jiān)視對象，并輸出監(jiān)視對象的目標航跡；

所述通航監(jiān)視模塊用于利用GIS引擎將監(jiān)視對象的目標航跡展示在人機交互界面上，同時監(jiān)聽人機交互界面上的指令操作，將所述指令操作分發(fā)給各服務(wù)器，提供目標告警服務(wù)和目標關(guān)聯(lián)研判服務(wù)；

其中，GIS引擎讀取本地的GIS地圖數(shù)據(jù)，將地圖和航線、空域作為底圖展示在人機交互界面上，并不斷將監(jiān)視對象的目標航跡更新到底圖上，指令操作分發(fā)給各服務(wù)器后，重新調(diào)度分布部署于各服務(wù)器上的服務(wù)，形成新的監(jiān)視任務(wù)。

6.根據(jù)權(quán)利要求5所述的通航監(jiān)視系統(tǒng)，其特征在于，所述協(xié)議轉(zhuǎn)換模塊還用于在不符合預(yù)設(shè)協(xié)議或不存在相同的數(shù)據(jù)模板時，生成日志記錄。

7.根據(jù)權(quán)利要求6所述的通航監(jiān)視系統(tǒng)，其特征在于，所述數(shù)據(jù)模板為xml格式。

8.根據(jù)權(quán)利要求6所述的通航監(jiān)視系統(tǒng)，其特征在于，所述預(yù)定數(shù)據(jù)格式為JSON格式。