[發明專利]一種衛星消息監聽與分發服務系統

有效

• 申請號: 201810309922.9
• 申請日: 2018-04-09
• 公開（公告）號: CN108566390B
• 公開（公告）日: 2020-03-17
• 發明（設計）人: 王利明;侯雨橋;宋晨;唐鼎
• 申請（專利權）人: 中國科學院信息工程研究所
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L29/08;H04B7/185
• 代理公司: 北京科迪生專利代理有限責任公司 11251
• 代理人: 安麗

1.一種衛星消息監聽與分發服務系統，其特征在于：包括消息監聽模塊、消息接收模塊、消息解析模塊和消息分發模塊；其中：

消息監聽模塊，組網衛星與地面接入網關使用socket方式通信，組網衛星被認為是服務端，與組網衛星相連接的網絡設備被認為是客戶端，組網衛星同時接入多個客戶端時，在監聽端口生成一個等待隊列，每一個來自客戶端的連接都會送入等待隊列中，服務端用新建線程處理的方法選擇相應的連接請求并進行處理；采用多線程技術分別處理每個客戶端的連接請求，接收和發送每個客戶端各自數據并做回應，完成了客戶端與服務端同時收發的和實時傳輸的功能；

消息接收模塊采用socket通信方式，單一線程對數據接收時，如果數據長度超過客戶端的接收方預設緩沖區大小，則對于所述消息過長造成緩沖區溢出，則應根據計算的消息長度與緩沖區大小的比例，計算出接收次數，建立循環分支并在循環中持續接收，最后將分多次接收到的消息拼接成一條完整的消息；

消息解析模塊，根據組網衛星收到的消息，按照預先約定的衛星消息的應用層標識協議的格式進行消息類型和功能的解析，所述衛星消息的應用層標識協議包括消息頭和消息體，所述消息體在最后部分；所述消息頭中各個字段如下：

①Src ID：發送方設備或是來自當前組網衛星的內部設備的編號標識；

②Src_Temp ID：實際發送所述衛星消息的設備標識，用于記錄所述衛星消息實際發送方的名稱并判斷所述消息發送方是否正確；

③DestID：接收所述消息的設備ID，用于判斷所述消息是否應該發送給當前組網衛星；

④Type號：包括兩部分：模塊類型Module Type和子模塊類型Sub_Module Type；所述Module Type用于區分衛星消息的功能模塊；所述Sub_Module Type指示衛星消息用于執行的函數方法；衛星消息的分發框架包括對模塊類型的分支判斷和對子模塊類型的分支判斷；模塊類型Module Type指示消息應進入的功能模塊；子模塊類型Sub_Module Type指示消息應從該模塊進入的具體函數功能分支；

5○Length：衛星消息長度，包括消息頭與消息體的總長度；所述消息體的總長度包括消息頭長度head_length和消息體長度body_length，所述消息頭長度head_length固定；Type號包含Module Type和Sub_Module Type，其中Module Type模塊類型標識指示了衛星消息應進入的功能模塊，而在結構上，功能模塊中又包含了由Sub_Module Type指示的具體函數功能，因此分別解析Module Type和Sub_Module Type；

消息分發模塊，對消息頭解析正確的情況，首先根據Module Type找到應進入的功能模塊分支，再根據Sub_Module Type子模塊功能類型這個類型標識找到衛星消息應進入的具體函數功能分支，從而將Message_body消息體下發到對應模塊內的對應函數中，消息解析模塊和消息分發模塊分別實現了對衛星消息的解析校驗和功能分發要求。

2.根據權利要求1所述的一種衛星消息監聽與分發服務系統，其特征在于：所述消息監聽模塊中，多線程技術實現為：使用多線程調度方式，實現多個網絡設備同時與衛星通信的功能，監聽到一個網絡設備的連接請求后，在新建線程內處理連接并收發消息，線程間的連接與消息是隔離的；多個網絡設備與衛星間的通信互相獨立，數據收發過程互不干擾。

3.根據權利要求1所述的一種衛星消息監聽與分發服務系統，其特征在于：所述消息接收模塊中，接收次數計算公式為：

其中，服務器端的socket預設數據接收長度為buf_len，從消息體中分離出消息總長度Length。

4.根據權利要求1所述的一種衛星消息監聽與分發服務系統，其特征在于：所述消息解析模塊中，消息分發前需要將消息頭與消息體分開，消息頭長度head_length固定且消息頭各個字段長度已知，消息體長度為消息長度與消息頭長度的差值，即body_length＝Length-head_length，可從監聽到的消息中提取任意消息頭數據以及完整的消息體數據，并用于函數分發的傳遞參數使用。

5.根據權利要求1所述的一種衛星消息監聽與分發服務系統，其特征在于：所述消息分發模塊中，將提取到的消息頭數據和全部消息體數據作為輸入參數傳遞給功能模塊的分支結構，若分支結構的判斷條件中有與輸入參數一致的，則進入對應的功能模塊分支執行對應的函數功能，若無對應的情況，則說明消息未被納入可執行的流程，則執行默認的報錯記錄流程。