[發明專利]用于靜態分布式計算架構的數據交換系統及其方法

有效

• 申請號: 202010063542.9
• 申請日: 2020-01-20
• 公開（公告）號: CN111225063B
• 公開（公告）日: 2020-09-22
• 發明（設計）人: 袁進輝;上官士源;蔡晟航;張文驍
• 申請（專利權）人: 北京一流科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京金訊知識產權代理事務所(特殊普通合伙) 11554
• 代理人: 黃劍飛

1.一種用于靜態分布式計算架構的跨計算數據交換系統，所述靜態分布式計算架構至少含有第一計算設備和第二計算設備，所述系統包括多個含有消息倉、狀態機組件、操作組件以及輸出數據緩存的數據執行體、部署在每臺計算機上的一個數據搬運請求匯集組件以及消息傳輸總線，其中

第二計算設備上的第二數據執行體在其第二輸出數據緩存已經被寫入新數據時從其消息倉向第一計算設備上的第一搬運執行體發出指明可以讀取第二輸出數據緩存中的數據的第二消息；

第一計算設備上的第一搬運執行體在經由第二計算機上的第二消息傳輸總線和第二數據搬運請求匯集組件以及第一計算設備上的第一數據搬運請求匯集組件和第一消息傳輸總線接收到所述第二消息時，其有限狀態機改變狀態以觸發操作組件向第一數據搬運請求匯集組件發出執行讀取第二輸出數據緩存中的數據的操作的第一命令；以及

第一數據搬運請求匯集組件，包括：請求描述隊列管理單元，在計算架構初始化時針對存在通信連接關系的第一計算設備和第二計算設備生成一個或多個第一請求描述隊列，并按照先進先出原則管理請求描述隊列；數據讀取單元，基于第一搬運執行體的發出第一命令，將第一命令中的讀取描述插入與第一搬運執行體對應的第一請求描述隊列；回調任務單元，基于第一搬運執行體的發出第一命令，在第一請求描述隊列中的所述讀取描述之后插入一個或多個讀取回調描述，并且所述讀取回調描述在出隊時被執行；以及第一數據通信單元，對于出隊的描述，判斷描述的類型是否為讀取描述，并在描述的類型為讀取描述時，采用直接遠程數據訪問協議直接讀取第二輸出數據緩存中的數據并存儲到第一搬運執行體的第一輸出數據緩存中或者采用以太網協議請求第二數據搬運請求匯集組件讀取第二輸出數據緩存中的數據并接收第二數據搬運請求匯集組件發送來的數據以便存儲到第一搬運執行體的第一輸出數據緩存中。

2.根據權利要求1所述的用于靜態分布式計算架構的數據交換系統，其中所述第一數據搬運請求匯集組件的數據通信單元為第一遠程直接數據存取單元，其基于所述請求描述隊列管理單元中的請求描述隊列中的每個讀取描述，采用第一計算設備和第二計算設備之間的直接遠程數據訪問協議直接讀取第二輸出數據緩存中的數據并存儲到第一搬運執行體的第一輸出數據緩存中。

3.根據權利要求1所述的用于靜態分布式計算架構的數據交換系統，其中所述第一數據搬運請求匯集組件的數據通信單元為第一套接字單元，其基于所述請求描述隊列管理單元中的請求描述隊列中的每個讀取描述，采用以太網協議請求第二數據搬運請求匯集組件的第二數據通信單元的第二套接字單元讀取并發送第二輸出數據緩存中的數據。

4.根據權利要求3所述的用于靜態分布式計算架構的數據交換系統，其中所述第一套接字單元在接收到作為第一數據搬運請求匯集組件的數據通信單元的第二套接字單元發送的數據寫入請求消息后，返回含有數據頭部的數據讀取請求消息，并將第二輸出數據緩存中的數據按照預定的大小以消息方式發送到第一套接字單元以便其接收。

5.根據權利要求2-4之一所述的用于靜態分布式計算架構的數據交換系統，其中所述第一搬運執行體監聽第一請求描述隊列中的讀取回調描述的出隊執行結果，并在讀取回調描述的出隊執行結果發生變化時，所述第一搬運執行體的消息倉向第一輸出數據緩存的下游的第一數據執行體發送第一消息以及經由第一數據搬運請求匯集組件、第二數據搬運請求匯集組件以及消息傳輸總線向第二數據執行體發送反饋消息。

6.根據權利要求5所述的用于靜態分布式計算架構的數據交換系統，其中所述讀取描述包含了所要讀取數據源地址和目的地地址以及數據大小、類型。

7.根據權利要求1所述的用于靜態分布式計算架構的數據交換系統，其中所述第一數據搬運請求匯集組件還包括：

內存注冊單元，用于將第一輸出數據緩存和第二輸出數據緩存注冊為鎖頁內存。