[發明專利]分布式計算事務處理方法及裝置

有效

• 申請號: 201310372973.3
• 申請日: 2013-08-23
• 公開（公告）號: CN104424018B
• 公開（公告）日: 2018-02-16
• 發明（設計）人: 方亮
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京三友知識產權代理有限公司11127
• 代理人: 王天堯

1.一種分布式計算事務處理方法，其特征在于，包括：

接收分布式計算事務的執行指令；

根據所述執行指令，查找所述分布式計算事務的流程配置文件；

根據所述流程配置文件，確定所述分布式計算事務中每一執行步驟各自對應的處理器及各處理器的執行順序；

按所述執行順序調用各處理器執行所述分布式計算事務，其中，在調用各處理器執行時，若處理器中包括濾鏡，則運行濾鏡進行數據過濾處理，所述濾鏡為：對一行數據進行計算的處理單元；所述運行濾鏡進行數據過濾處理，包括：根據處理器支持能力的不同，按照順序執行或按照設定并行執行。

2.如權利要求1所述的方法，其特征在于，接收分布式計算事務的執行指令之前，還包括：接收所述分布式計算事務的注冊請求；根據所述注冊請求，注冊所述分布式計算事務的執行指令，并確定所述分布式計算事務的流程配置文件。

3.如權利要求1所述的方法，其特征在于，在查找到所述分布式計算事務的流程配置文件之后，還包括：將所述流程配置文件分發至分布式計算環境；

根據所述流程配置文件，確定所述分布式計算事務中每一執行步驟各自對應的處理器及各處理器的執行順序，包括：根據分發至分布式計算環境中的所述流程配置文件，確定所述分布式計算事務中每一執行步驟各自對應的處理器及各處理器的執行順序。

4.如權利要求1所述的方法，其特征在于，按所述執行順序調用各處理器執行所述分布式計算事務，包括：

若所述分布式計算事務為離線分布式計算事務，則在進行事務處理后，對事務處理結果數據進行存儲；

若所述分布式計算事務為實時分布式計算事務，則在進行事務處理前，獲取事務處理所需輸入參數，在進行事務處理后，輸出事務處理結果數據。

5.如權利要求1至4任一項所述的方法，其特征在于，各處理器中包括：根據分布式計算中異構的服務器或不同的分布式計算環境，采用代理的方式封裝分布式上下文的處理器。

6.一種分布式計算事務處理裝置，其特征在于，包括：

接收模塊，用于接收分布式計算事務的執行指令；

查找模塊，用于根據所述執行指令，查找所述分布式計算事務的流程配置文件；

確定模塊，用于根據所述流程配置文件，確定所述分布式計算事務中每一執行步驟各自對應的處理器及各處理器的執行順序；

執行模塊，用于按所述執行順序調用各處理器執行所述分布式計算事務；

所述執行模塊具體用于：

在調用各處理器執行時，若處理器中包括濾鏡，則運行濾鏡進行數據過濾處理，所述濾鏡為：對一行數據進行計算的處理單元；所述運行濾鏡進行數據過濾處理，包括：根據處理器支持能力的不同，按照順序執行或按照設定并行執行。

7.如權利要求6所述的裝置，其特征在于，還包括：

分發模塊，用于在所述查找模塊查找到所述分布式計算事務的流程配置文件之后，將所述流程配置文件分發至分布式計算環境；

所述確定模塊具體用于：根據分發至分布式計算環境中的所述流程配置文件，確定所述分布式計算事務中每一執行步驟各自對應的處理器及各處理器的執行順序。

8.如權利要求6或7所述的裝置，其特征在于，各處理器中包括：根據分布式計算中異構的服務器或不同的分布式計算環境，采用代理的方式封裝分布式上下文的處理器。