[發(fā)明專利]一種適用于航天器研制管理任務協(xié)調的消息傳遞系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202011127693.2
• 申請日: 2020-10-20
• 公開（公告）號: CN112328407A
• 公開（公告）日: 2021-02-05
• 發(fā)明（設計）人: 紀煒;謝政;邵壯;趙伶豐;吳浩;任璐;金鵬;魏平;蘇傳國
• 申請（專利權）人: 北京空間飛行器總體設計部
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 中國航天科技專利中心 11009
• 代理人: 陳鵬

1.一種適用于航天器研制管理任務協(xié)調的消息傳遞系統(tǒng)，其特征在于，包括：消息接收模塊、消息注冊模塊、消息調度模塊以及消息發(fā)送模塊；其中，

所述消息接收模塊，用于根據(jù)預設的接口接收至少一個消息源發(fā)送的未注冊的消息數(shù)據(jù)；

所述消息注冊模塊，與所述消息接收模塊連接，用于根據(jù)預設消息注冊策略在所述消息數(shù)據(jù)中添加注冊信息得到注冊后的消息集，其中，所述注冊信息包括消息名稱、消息來源、消息去向以及發(fā)送時機；

所述消息調度模塊，與所述消息注冊模塊連接，用于將所述注冊后的消息集中添加到存儲待發(fā)送消息的消息隊列中；

所述消息發(fā)送模塊，與所述消息調度模塊連接，用于從所述消息隊列中讀取待發(fā)送消息集，將所述待發(fā)送消息集發(fā)送到至少一個消息接收端。

2.如權利要求1所述的系統(tǒng)，其特征在于，所述預設的接口，包括：RESTFUL接口、WebService接口、URL接口、SMTP接口。

3.如權利要求2所述的系統(tǒng)，其特征在于，所述消息注冊模塊，具體用于：

確定接收每個所述消息數(shù)據(jù)的接口信息，根據(jù)接口信息與注冊信息之間的映射關系確定出所述每個消息數(shù)據(jù)對應的注冊信息；

根據(jù)所述注冊信息確定消息標識以及將所述消息標識和所述注冊信息添加到所述每個消息數(shù)據(jù)中得到所述注冊后的消息集。

4.如權利要求3所述的系統(tǒng)，其特征在于，所述消息調度模塊，具體用于：

對所述注冊后的消息集中未發(fā)送的消息集進行遍歷解析得到所述消息標識以及所述消息去向；

根據(jù)所述消息標識以及預設的消息注冊信息判斷任一所述未發(fā)送的消息是否滿足發(fā)送時機；

若滿足，則將所述任一未發(fā)送的消息插入到所述消息隊列的末尾。

5.如權利要求4所述的系統(tǒng)，其特征在于，所述消息調度模塊，具體用于：

確定所述任一未發(fā)送的消息的消息來源，根據(jù)消息來源與消息隊列之間的映射關系確定出所述任一未發(fā)送的消息對應的所述消息隊列；

將所述任一未發(fā)送的消息插入到所述消息隊列的末尾。

6.如權利要求5所述的系統(tǒng)，其特征在于，所述消息隊列，包括：MSMQ消息隊列、RabbitMQ消息隊列以及RocketMQ消息隊列。

7.如權利要求1～6任一項所述的系統(tǒng)，其特征在于，還包括：消息處理模塊；其中，所述消息處理模塊，設置于所述消息注冊模塊與所述消息調度模塊之間，用于對所述注冊后的消息集中的消息進行內容檢驗和脫敏處理得到檢驗處理后的消息。

8.如權利要求7所述的系統(tǒng)，其特征在于，所述消息處理模塊，具體用于：

對所述注冊后的消息集中的消息進行內容校驗得到校驗后的消息，其中，所述內容校驗包括校驗消息是否已注冊、消息接收端是否存在、消息內容是否超過預設長度或消息內容是否包含預設字符；

將所述校驗后的消息進行脫敏處理得到脫敏處理后的消息，其中，所述脫敏處理包括將所述校驗后的消息與預設的敏感詞庫進行模糊比對確定出所述校驗后的消息中敏感詞，根據(jù)敏感詞與公開詞之間預設的映射關系確定出所述敏感詞對應的所述公開詞，通過所述公開詞替換所述敏感詞。

9.如權利要求8所述的系統(tǒng)，其特征在于，還包括：消息監(jiān)控審計模塊；其中，所述消息監(jiān)控審計模塊，用于接收所述消息接收模塊、所述消息注冊模塊、所述消息處理模塊以及所述消息發(fā)送模塊發(fā)送的數(shù)據(jù)，根據(jù)所述數(shù)據(jù)進行消息監(jiān)控、消息審計以及消息追溯。