[發明專利]分布式存儲系統的數據傳輸方法、系統、設備及介質

有效

• 申請號: 202210411972.4
• 申請日: 2022-04-19
• 公開（公告）號: CN114844910B
• 公開（公告）日: 2023-07-25
• 發明（設計）人: 韓磊
• 申請（專利權）人: 重慶紫光華山智安科技有限公司
• 主分類號: H04L67/1097
• 分類號: H04L67/1097;H04L67/1074;H04L67/141;H04L43/12
• 代理公司: 上海光華專利事務所(普通合伙) 31219
• 代理人: 張雙鳳

本發明提出的一種分布式存儲系統的數據傳輸方法、系統、設備及介質，該方法通過將待傳輸數據分割為多個分割數據，并將各分割數據通過發送隊列分別發送至各分割數據對應的目標對象，獲取各目標對象的響應消息，并生成待傳輸數據的傳輸結果，能夠對待傳輸數據進行分割，實現消息的分聚，在客戶端本地線程中就完成了對集群多個節點的請求分發及結果合并，大大提高了分布式存儲系統中的數據傳輸處理的效率。

技術領域

本發明涉及計算機技術領域，尤其涉及一種分布式存儲系統的數據傳輸方法、系統、設備及介質。

背景技術

分布式存儲系統包括一套多個節點組成的存儲集群，運行過程中，其內部有著大量的數據傳輸，因此數據傳輸的功能、性能對分布式存儲系統至關重要。

相關技術中的數據傳輸方式中同樣的任務需要更多的流程來實現，完成認為時需要循環請求或響應等，或者需要依賴于多線程等技術來實現，耗時，且增加了對系統資源的消耗。

發明內容

鑒于以上所述現有技術的缺點，本發明提供一種分布式存儲系統的數據傳輸方法、系統設備及介質，以解決上述技術問題。

本發明提供的一種分布式存儲系統的數據傳輸方法，所述方法包括:

將待傳輸數據分割為多個分割數據，并將各所述分割數據通過發送隊列分別發送至各所述分割數據對應的目標對象；

獲取各所述目標對象的響應消息，并生成所述待傳輸數據的傳輸結果。

可選的，將各所述分割數據通過發送隊列分別發送至各分割數據對應的目標對象包括：

生成所述待傳輸數據的至少一個冗余數據，將所述冗余數據新增為分割數據；

獲取分割數據對應的目標對象標識，根據所述分割數據、目標對象標識和發送標識生成待發送消息，得到各分割數據對應的待發送消息；

將各所述待發送消息通過發送隊列分別發送至各所述分割數據對應的目標對象。

可選的，所述響應消息包括響應標識，所述響應標識與所述發送標識一一對應，獲取各所述目標對象的響應消息，并生成所述待傳輸數據的傳輸結果包括：

獲取各所述響應消息中的響應標識；

根據預設響應標識-發送標識映射關系確定所述響應標識對應的發送標識，并確定各所述分割數據的傳輸狀態；

根據各所述分割數據的傳輸狀態確定所述傳輸結果。

可選的，根據各所述分割數據的傳輸狀態確定所述傳輸結果包括：

若不存在所述分割數據對應的響應標識，所述分割數據的傳輸狀態為傳輸失敗；

獲取目標分割數據的失敗數量，確定所述傳輸結果，其中所述目標分割數據包括傳輸狀態為傳輸失敗的分割數據。

可選的，生成所述待傳輸數據的傳輸結果包括以下至少之一：

監聽各所述目標對象的響應消息，獲取監聽時長，若所述監聽時長超過預設時長閾值，停止監聽，根據當前獲取的各所述目標對象的響應消息生成所述待傳輸數據的傳輸結果；

監聽各所述目標對象的響應消息，獲取監聽時長，將所述監聽時長超過預設時長閾值后獲取到的響應消息丟棄。

可選的，所述待發送消息還包括調用函數標識，所述方法還包括：

所述目標對象獲取所述待發送消息后，通過所述調用函數標識對應的調用函數處理所述待發送消息，生成反饋消息；

獲取所述目標對象反饋的所述反饋消息。