[發(fā)明專利]一種航班數(shù)據(jù)發(fā)布系統(tǒng)、航班變更方法及消息處理方法

有效

• 申請?zhí)枺?/td>: 201910200075.7
• 申請日: 2019-03-15
• 公開（公告）號: CN109873873B
• 公開（公告）日: 2021-10-29
• 發(fā)明（設(shè)計）人: 王宇中
• 申請（專利權(quán)）人: 北京恒贏智航科技有限公司;北京三贏偉業(yè)科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06Q50/30
• 代理公司: 廣州粵高專利商標(biāo)代理有限公司 44102
• 代理人: 張金福

1.一種航班數(shù)據(jù)發(fā)布系統(tǒng)，為各下游系統(tǒng)提供航班數(shù)據(jù)，其特征在于，包括航班運行管理子系統(tǒng)、消息服務(wù)子系統(tǒng)、認證授權(quán)子系統(tǒng)、服務(wù)注冊中心子系統(tǒng)和服務(wù)網(wǎng)關(guān)子系統(tǒng)，其中：

航班運行管理子系統(tǒng)負責(zé)航班數(shù)據(jù)的管理，包括消息路由模塊和Webservice模塊，消息路由模塊將航班數(shù)據(jù)傳送至消息服務(wù)子系統(tǒng)；

服務(wù)網(wǎng)關(guān)子系統(tǒng)接收下游系統(tǒng)的服務(wù)請求，并從服務(wù)注冊中心子系統(tǒng)獲取認證授權(quán)服務(wù)地址對請求進行認證與授權(quán)，然后從服務(wù)注冊中心子系統(tǒng)中查找服務(wù)請求所對應(yīng)的webservice地址，轉(zhuǎn)發(fā)請求到實際webservice，webservice返回的數(shù)據(jù)經(jīng)服務(wù)網(wǎng)關(guān)返回給請求的下游系統(tǒng)；

消息服務(wù)子系統(tǒng)包括若干消息主題，每一個消息主題根據(jù)航班屬性劃分為若干個消息分區(qū)，分類順序儲存航班數(shù)據(jù)，每一個消息主題將儲存的航班數(shù)據(jù)發(fā)布至各下游系統(tǒng)；

所述航班運行管理子系統(tǒng)、消息服務(wù)子系統(tǒng)、認證授權(quán)子系統(tǒng)、服務(wù)注冊中心子系統(tǒng)和服務(wù)網(wǎng)關(guān)子系統(tǒng)均采用多節(jié)點集群；

所述若干消息主題中其中一個消息主題為第一消息主題存儲，所述第一消息主題存儲其它消息主題中每日首班航班消息的存儲位置及對應(yīng)航班日期；其它消息主題依次存儲不同時間段對應(yīng)的航班數(shù)據(jù)以及對應(yīng)的航班變更數(shù)據(jù)；

所述若干消息分區(qū)中的每一個消息分區(qū)配置獨立存儲器；

航班信息以航班日期或航班計劃起飛時間順序追加存入消息主題，對應(yīng)的航班變更數(shù)據(jù)按變更先后順序存入消息主題，航班信息采用分批次間隔追加存入消息主題，航班變更數(shù)據(jù)實時或近實時追加存入消息主題，所述的近實時指通過自動數(shù)據(jù)處理或網(wǎng)絡(luò)傳輸在事件發(fā)生和使用之間引入的時間延遲。

2.根據(jù)權(quán)利要求1所述的航班數(shù)據(jù)發(fā)布系統(tǒng)，其特征在于，所述航班屬性為機型或航班號或航班日期或航班計劃起飛時間或起飛機場或到達機場。

3.根據(jù)權(quán)利要求1所述的航班數(shù)據(jù)發(fā)布系統(tǒng)，其特征在于，Webservice模塊提供航班計劃查詢接口、航班變更查詢接口和消息分區(qū)位置查詢接口，其中：

航班計劃查詢接口根據(jù)下游系統(tǒng)的指定返回航班數(shù)據(jù)記錄列表；

航班變更查詢接口根據(jù)下游系統(tǒng)的指定返回航班變更記錄列表。

4.根據(jù)權(quán)利要求3所述的航班數(shù)據(jù)發(fā)布系統(tǒng)，其特征在于，Webservice模塊還提供消息分區(qū)位置查詢接口，所述消息分區(qū)位置查詢接口根據(jù)下游系統(tǒng)的指定返回航班日期、位置信息列表，下游系統(tǒng)也可以采用MQ，消費位置消息隊列獲取航班日期、位置信息列表。

5.根據(jù)權(quán)利要求4所述的航班數(shù)據(jù)發(fā)布系統(tǒng)的航班變更方法，其特征在于，包括以下步驟：

S01：航班運行管理子系統(tǒng)收到新增、修改航班數(shù)據(jù)的請求，持久化航班變更記錄，通知發(fā)布變更數(shù)據(jù)，同時航班運行管理子系統(tǒng)在后臺線程的控制下定時檢查未發(fā)布的航班變更記錄并發(fā)布，保證發(fā)布失敗重新發(fā)布；

S02：接收通知并查詢該航班未發(fā)布的航班變更記錄，如航班從未發(fā)布則發(fā)布整條航班信息；

S03：由消息路由將航班變更記錄通過定義的消息分區(qū)與消息路由算法存儲至指定的消息分區(qū)；

S04：更新航班變更記錄或者更新航班發(fā)布狀態(tài)，并發(fā)布至下游系統(tǒng)中。

6.根據(jù)權(quán)利要求5所述的航班數(shù)據(jù)發(fā)布系統(tǒng)的航班變更方法，其特征在于，所述的消息路由算法將航班計劃起飛時間按12個月份或每月31天或24小時或60分鐘時間單位組合方式路由至消息分區(qū)。

7.根據(jù)權(quán)利要求6所述的航班數(shù)據(jù)發(fā)布系統(tǒng)的下游系統(tǒng)消息處理方法，其特征在于，包括以下步驟：

S11：下游系統(tǒng)是否需要指定航班日期對應(yīng)的位置信息，若需要，則通過消息分區(qū)位置查詢接口或者通過第一消息主題獲取指定航班日期消息分區(qū)位置并從指定消息分區(qū)位置獲取信息；若不需要，從上次下游系統(tǒng)終止消息分區(qū)位置獲取消息或從原始消息分區(qū)位置獲取消息；

S12：以多線程方式將下游系統(tǒng)需要的消息反饋給下游系統(tǒng)；

S13：下游系統(tǒng)檢測航班信息是否已經(jīng)存在，若不存在，新增航班信息并回復(fù)消息服務(wù)子系統(tǒng)確認消費信息；若存在且航班變更時間大于下游系統(tǒng)存儲的變更時間，修改航班信息并回復(fù)消息服務(wù)子系統(tǒng)確認消費信息，若存在且航班變更時間不大于下游系統(tǒng)存儲的變更時間，放棄修改；記錄下游系統(tǒng)消息消費位置并返回步驟S12。