[發明專利]非可靠物理傳輸通道下的多并發調用式通信方法

在審

• 申請號: 202210918020.1
• 申請日: 2022-08-01
• 公開（公告）號: CN115297193A
• 公開（公告）日: 2022-11-04
• 發明（設計）人: 杜若蒙;魏志峰
• 申請（專利權）人: 北京左江科技股份有限公司
• 主分類號: H04L69/16
• 分類號: H04L69/16;H04L67/568
• 代理公司: 中國兵器工業集團公司專利中心 11011
• 代理人: 辛海明

1.一種非可靠物理傳輸通道下的多并發調用式通信方法，其特征在于，該方法包括如下步驟：

用戶數據處理服務接收到用戶實體發來的請求數據，記錄用戶實體信息和I/O端口信息，并對用戶實體發來的請求數據做相應處理，交給下行數據處理組件；

下行數據處理組件收到請求數據，根據服務實體的需求對請求數據做解封裝和封裝處理，將請求數據中的元數據組織為服務實體能夠識別的請求數據包，并將處理完畢的請求數據包交給設備數據處理服務；

設備數據處理服務收到請求數據包，通過設備數據處理服務與服務實體間的可靠傳輸協議，發送給服務實體，同時設備數據處理服務還異步地接收服務實體的響應數據包，收到響應數據包后將會通知上行數據處理組件，并將響應數據包交給上行數據處理組件；

上行數據處理組件收到通知，收取響應數據包，通過解析數據包，將響應數據中的元數據封裝為用戶實體能夠解析的響應數據，并交給用戶數據處理服務；

用戶數據處理服務收到響應數據，通過查找用戶信息，查找到匹配的I/0端口,異步的將響應數據發給用戶；

其中，TCP服務器及用戶API調用為用戶實體，PCI-E數據處理設備為服務實體。

2.如權利要求1所述的非可靠物理傳輸通道下的多并發調用式通信方法，其特征在于，用戶數據處理服務的服務建立流程包括如下步驟：

步驟S21、初始化通信服務，創建TCP監聽服務；并創建如下數據結構：

創建請求數據隊列sort_q_s，并初始化，用于多用戶并行數據的串行化處理；

創建滑動窗口隊列wind_q_s，并初始化，用于實現用戶數據處理服務到物理設備的可靠傳輸；

創建客戶端隊列clients_s，并初始化，用于實現用戶和用戶數據的管理；

步驟S22、啟動通信服務，等待接收客戶端請求，即用戶的調用服務請求；

步驟S23、如果有用戶調用服務請求，創建用戶連接信息結構，包含如下信息：

保存與用戶通信的句柄，用于接收用戶調用請求數據和響應用戶的數據；

用戶請求數據ID，用于唯一表示該次用戶請求建立的連接通；

用戶調用服務請求包隊列req_q_cli，用于存儲有效的用戶調用請求數據；

響應消息等待發送隊列send_pading_cli；

響應消息發送隊列send_do_cli；

將創建的用戶連接信息結構掛載到通信服務創建的數據結構客戶端隊列clients_s中；如果沒有用戶調用服務請求，執行步驟S22；

步驟S23：接收用戶調用請求數據；執行后續流程。

3.如權利要求2所述的非可靠物理傳輸通道下的多并發調用式通信方法，其特征在于，設備數據處理服務的服務處理流程包括如下步驟：

步驟S31：初始化設備信息，根據PCI-E數據處理設備實際情況，創建Device設備信息結構，包含如下信息：

設備唯一標識cid_dev,用于用戶數據處理服務識別具體設備；

初始化設備服務通道讀寫句柄fd_dev，用于設備數據處理服務與物理設備服務通信；

同步機制write_cond,用于獲取同步用戶數據處理服務的通知；

用戶調用請求數據發送隊列write_q_dev，用于獲取用戶數據處理服務輸出的用戶請求數據；

同步機制write_lock，用于同步用戶數據處理服務與設備數據處理服務，操作用戶調用請求數據發送隊列；

用戶調用響應數據接收隊列read_q_dev，用于獲取物理設備服務的響應數據；

同步機制resp_lock，用于同步用戶數據處理服務與設備數據處理服務，操作用戶調用響應數據接收隊列；

步驟S32：創建獨立的讀寫線程，并創建設備服務通道讀寫句柄，并賦值給設備信息；

步驟S33：啟動讀寫線程，線程分別執行用戶調用服務下行數據處理和用戶調用服務上行數據處理的數據接收和發送流程；

步驟S34：通知用戶數據處理服務，返回步驟S31。