[發(fā)明專利]用于靜態(tài)分布式計(jì)算架構(gòu)的數(shù)據(jù)交換系統(tǒng)及其方法

有效

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

1.一種用于靜態(tài)分布式計(jì)算架構(gòu)的跨計(jì)算數(shù)據(jù)交換系統(tǒng)，所述靜態(tài)分布式計(jì)算架構(gòu)至少含有第一計(jì)算設(shè)備和第二計(jì)算設(shè)備，所述系統(tǒng)包括多個(gè)含有消息倉、狀態(tài)機(jī)組件、操作組件以及輸出數(shù)據(jù)緩存的數(shù)據(jù)執(zhí)行體、部署在每臺計(jì)算機(jī)上的一個(gè)數(shù)據(jù)搬運(yùn)請求匯集組件以及消息傳輸總線，其中

第二計(jì)算設(shè)備上的第二數(shù)據(jù)執(zhí)行體在其第二輸出數(shù)據(jù)緩存已經(jīng)被寫入新數(shù)據(jù)時(shí)從其消息倉向第一計(jì)算設(shè)備上的第一搬運(yùn)執(zhí)行體發(fā)出指明可以讀取第二輸出數(shù)據(jù)緩存中的數(shù)據(jù)的第二消息；

第一計(jì)算設(shè)備上的第一搬運(yùn)執(zhí)行體在經(jīng)由第二計(jì)算機(jī)上的第二消息傳輸總線和第二數(shù)據(jù)搬運(yùn)請求匯集組件以及第一計(jì)算設(shè)備上的第一數(shù)據(jù)搬運(yùn)請求匯集組件和第一消息傳輸總線接收到所述第二消息時(shí)，其有限狀態(tài)機(jī)改變狀態(tài)以觸發(fā)操作組件向第一數(shù)據(jù)搬運(yùn)請求匯集組件發(fā)出執(zhí)行讀取第二輸出數(shù)據(jù)緩存中的數(shù)據(jù)的操作的第一命令；以及

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

2.根據(jù)權(quán)利要求1所述的用于靜態(tài)分布式計(jì)算架構(gòu)的數(shù)據(jù)交換系統(tǒng)，其中所述第一數(shù)據(jù)搬運(yùn)請求匯集組件的數(shù)據(jù)通信單元為第一遠(yuǎn)程直接數(shù)據(jù)存取單元，其基于所述請求描述隊(duì)列管理單元中的請求描述隊(duì)列中的每個(gè)讀取描述，采用第一計(jì)算設(shè)備和第二計(jì)算設(shè)備之間的直接遠(yuǎn)程數(shù)據(jù)訪問協(xié)議直接讀取第二輸出數(shù)據(jù)緩存中的數(shù)據(jù)并存儲到第一搬運(yùn)執(zhí)行體的第一輸出數(shù)據(jù)緩存中。

3.根據(jù)權(quán)利要求1所述的用于靜態(tài)分布式計(jì)算架構(gòu)的數(shù)據(jù)交換系統(tǒng)，其中所述第一數(shù)據(jù)搬運(yùn)請求匯集組件的數(shù)據(jù)通信單元為第一套接字單元，其基于所述請求描述隊(duì)列管理單元中的請求描述隊(duì)列中的每個(gè)讀取描述，采用以太網(wǎng)協(xié)議請求第二數(shù)據(jù)搬運(yùn)請求匯集組件的第二數(shù)據(jù)通信單元的第二套接字單元讀取并發(fā)送第二輸出數(shù)據(jù)緩存中的數(shù)據(jù)。

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

5.根據(jù)權(quán)利要求2-4之一所述的用于靜態(tài)分布式計(jì)算架構(gòu)的數(shù)據(jù)交換系統(tǒng)，其中所述第一搬運(yùn)執(zhí)行體監(jiān)聽第一請求描述隊(duì)列中的讀取回調(diào)描述的出隊(duì)執(zhí)行結(jié)果，并在讀取回調(diào)描述的出隊(duì)執(zhí)行結(jié)果發(fā)生變化時(shí)，所述第一搬運(yùn)執(zhí)行體的消息倉向第一輸出數(shù)據(jù)緩存的下游的第一數(shù)據(jù)執(zhí)行體發(fā)送第一消息以及經(jīng)由第一數(shù)據(jù)搬運(yùn)請求匯集組件、第二數(shù)據(jù)搬運(yùn)請求匯集組件以及消息傳輸總線向第二數(shù)據(jù)執(zhí)行體發(fā)送反饋消息。

6.根據(jù)權(quán)利要求5所述的用于靜態(tài)分布式計(jì)算架構(gòu)的數(shù)據(jù)交換系統(tǒng)，其中所述讀取描述包含了所要讀取數(shù)據(jù)源地址和目的地地址以及數(shù)據(jù)大小、類型。

7.根據(jù)權(quán)利要求1所述的用于靜態(tài)分布式計(jì)算架構(gòu)的數(shù)據(jù)交換系統(tǒng)，其中所述第一數(shù)據(jù)搬運(yùn)請求匯集組件還包括：

內(nèi)存注冊單元，用于將第一輸出數(shù)據(jù)緩存和第二輸出數(shù)據(jù)緩存注冊為鎖頁內(nèi)存。