[發明專利]數據交換方法及其系統

在審

• 申請號: 201711120378.5
• 申請日: 2017-11-13
• 公開（公告）號: CN109783201A
• 公開（公告）日: 2019-05-21
• 發明（設計）人: 韓飛;張侃;劉彥偉;曾光耀
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/50;G06F9/54;H04L12/24
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 呂雁葭

1.一種數據交換方法，包括：

獲取數據交換任務的配置參數；

解析所述配置參數；

根據配置參數解析結果，將所述數據交換任務拆分成多個數據交換子任務，其中，不同的數據交換子任務使用不同的數據交換執行器實例完成數據交換；以及

為所述多個數據交換子任務中的各個數據交換子任務申請對應的系統資源，以執行對應的數據交換執行器實例來完成各數據交換子任務。

2.根據權利要求1所述的方法，其中，為所述多個數據交換子任務中的各個數據交換子任務申請對應的系統資源包括：

獲取預先指定的完成所述數據交換任務所需要的擬定系統資源；以及

基于所述擬定系統資源，為所述多個數據交換子任務中的每個數據交換子任務申請對應的系統資源。

3.根據權利要求1或2所述的方法，其中，所述方法還包括：

根據申請到的系統資源，啟動對應的數據交換執行器實例。

4.根據權利要求1所述的方法，其中，解析所述配置參數包括：

根據預先指定的并行度解析所述配置參數，其中，所述并行度用于限定能夠并行運行的所述多個數據交換子任務的個數。

5.根據權利要求1所述的方法，其中，所述數據交換任務所針對的數據交換雙方為異構數據源。

6.根據權利要求1所述的方法，其中，所述數據交換執行器實例在實現數據交換的過程中：

數據的讀操作和寫操作是分開執行的；和/或

利用內存隊列進行數據傳輸。

7.一種數據交換系統，包括：

獲取模塊，用于獲取數據交換任務的配置參數；

解析模塊，用于解析所述配置參數；

拆分模塊，用于根據配置參數解析結果，將所述數據交換任務拆分成多個數據交換子任務，其中，不同的數據交換子任務使用不同的數據交換執行器實例完成數據交換；以及

請求模塊，用于為所述多個數據交換子任務中的各個數據交換子任務申請對應的系統資源，以執行對應的數據交換執行器實例來完成各數據交換子任務。

8.根據權利要求7所述的系統，其中，所述請求模塊包括：

獲取單元，用于獲取預先指定的完成所述數據交換任務所需要的擬定系統資源；以及

請求單元，用于基于所述擬定系統資源，為所述多個數據交換子任務中的每個數據交換子任務申請對應的系統資源。

9.根據權利要求7或8所述的系統，其中，所述系統還包括：

啟動模塊，用于根據申請到的系統資源，啟動對應的數據交換執行器實例。

10.根據權利要求7所述的系統，其中，所述解析模塊還用于：

根據預先指定的并行度解析所述配置參數，其中，所述并行度用于限定能夠并行運行的所述多個數據交換子任務的個數。

11.根據權利要求7所述的系統，其中，所述數據交換任務所針對的數據交換雙方為異構數據源。

12.根據權利要求7所述的系統，其中，所述數據交換執行器實例在實現數據交換的過程中：

數據的讀操作和寫操作是分開執行的；和/或

利用內存隊列進行數據傳輸。

13.一種計算系統，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

其中，當所述一個或多個程序被所述一個或多個處理器執行時，使得所述一個或多個處理器實現權利要求1至6中任一項所述的數據交換方法。

14.一種計算機可讀介質，其上存儲有可執行指令，該指令被處理器執行時使處理器實現權利要求1至6中任一項所述的數據交換方法。