[發(fā)明專利]一種任務(wù)執(zhí)行的方法及裝置

有效

• 申請?zhí)枺?/td>: 201610134447.7
• 申請日: 2016-03-10
• 公開（公告）號: CN107179940B
• 公開（公告）日: 2020-06-19
• 發(fā)明（設(shè)計）人: 葉愷;王嘯;瞿紅衛(wèi);高詩林
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京晉德允升知識產(chǎn)權(quán)代理有限公司 11623
• 代理人: 楊移

1.一種任務(wù)執(zhí)行的方法，其特征在于，包括：

第一服務(wù)器創(chuàng)建任務(wù)；

所述第一服務(wù)器將所述任務(wù)拆分為若干任務(wù)分片，并將各任務(wù)分片的執(zhí)行狀態(tài)標(biāo)記為已拆分狀態(tài)，其中每個任務(wù)分片對應(yīng)至少一個數(shù)據(jù)；

所述第一服務(wù)器將全部或部分任務(wù)分片分發(fā)給各第二服務(wù)器，使各第二服務(wù)器對接收到的任務(wù)分片進(jìn)行處理；

所述第一服務(wù)器處理未分發(fā)的任務(wù)分片；

所述第一服務(wù)器接收各第二服務(wù)器返回的針對各自接收到的任務(wù)分片的執(zhí)行消息；

所述第一服務(wù)器根據(jù)所述執(zhí)行消息，對各任務(wù)分片的執(zhí)行狀態(tài)進(jìn)行更新；

所述第一服務(wù)器接收各第二服務(wù)器返回的各執(zhí)行結(jié)果；

根據(jù)經(jīng)更新的各任務(wù)分片的執(zhí)行狀態(tài)，所述第一服務(wù)器將所述各執(zhí)行結(jié)果以及所述第一服務(wù)器自身處理任務(wù)分片所得到的本地結(jié)果進(jìn)行合并，得到最終結(jié)果。

2.如權(quán)利要求1所述的方法，其特征在于，第一服務(wù)器創(chuàng)建任務(wù)，具體包括：

第一服務(wù)器接收用戶發(fā)送的業(yè)務(wù)請求；

根據(jù)所述業(yè)務(wù)請求，創(chuàng)建相應(yīng)的任務(wù)，并將所述任務(wù)的執(zhí)行狀態(tài)標(biāo)記為初始狀態(tài)。

3.如權(quán)利要求1所述的方法，其特征在于，所述第一服務(wù)器將全部或部分任務(wù)分片分發(fā)給各第二服務(wù)器，具體包括：

將對應(yīng)的數(shù)據(jù)未保存在所述第一服務(wù)器本地的任務(wù)分片分發(fā)給各第二服務(wù)器；

所述第一服務(wù)器處理未分發(fā)的任務(wù)分片，具體包括：

所述第一服務(wù)器處理對應(yīng)的數(shù)據(jù)保存在所述第一服務(wù)器本地的任務(wù)分片。

4.如權(quán)利要求1所述的方法，其特征在于，所述第一服務(wù)器接收各第二服務(wù)器返回的各執(zhí)行結(jié)果，具體包括：

接收各執(zhí)行結(jié)果，并將接收到的各執(zhí)行結(jié)果對應(yīng)的任務(wù)分片的執(zhí)行狀態(tài)標(biāo)記為待合并狀態(tài)。

5.如權(quán)利要求1所述的方法，其特征在于，根據(jù)經(jīng)更新的各任務(wù)分片的執(zhí)行狀態(tài)，所述第一服務(wù)器將所述各執(zhí)行結(jié)果以及所述第一服務(wù)器自身處理任務(wù)分片所得到的本地結(jié)果進(jìn)行合并，具體包括：

讀取所述各執(zhí)行結(jié)果與本地結(jié)果；

根據(jù)預(yù)設(shè)的合并規(guī)則，將所述各執(zhí)行結(jié)果與所述本地結(jié)果進(jìn)行合并，并將所述各任務(wù)分片的執(zhí)行狀態(tài)標(biāo)記為已合并狀態(tài)。

6.一種任務(wù)執(zhí)行的方法，其特征在于，包括：

第二服務(wù)器接收第一服務(wù)器發(fā)送的任務(wù)分片；其中，所述任務(wù)分片是所述第一服務(wù)器創(chuàng)建任務(wù)后，將所述任務(wù)進(jìn)行拆分得到的；

所述第二服務(wù)器執(zhí)行所述任務(wù)分片，得到執(zhí)行結(jié)果；

所述第二服務(wù)器將執(zhí)行所述任務(wù)分片對應(yīng)的執(zhí)行消息發(fā)送給所述第一服務(wù)器，使得所述第一服務(wù)器根據(jù)接收到的所述執(zhí)行消息，將記錄的所述任務(wù)分片的執(zhí)行狀態(tài)進(jìn)行更新；

所述第二服務(wù)器將所述執(zhí)行結(jié)果返回給所述第一服務(wù)器，使得所述第一服務(wù)器在獲取到所述執(zhí)行結(jié)果后，根據(jù)經(jīng)更新的各任務(wù)分片的執(zhí)行狀態(tài)，將所述執(zhí)行結(jié)果、其他第二服務(wù)器返回的執(zhí)行結(jié)果以及所述第一服務(wù)器執(zhí)行未分發(fā)的任務(wù)分片后得到的本地結(jié)果進(jìn)行合并，得到最終結(jié)果。

7.一種任務(wù)執(zhí)行的裝置，其特征在于，包括：

創(chuàng)建模塊，用于創(chuàng)建任務(wù)；

拆分模塊，用于將所述任務(wù)拆分為若干任務(wù)分片，并將各任務(wù)分片的執(zhí)行狀態(tài)標(biāo)記為已拆分狀態(tài)，其中每個任務(wù)分片對應(yīng)至少一個數(shù)據(jù)；

分發(fā)模塊，用于將全部或部分任務(wù)分片分發(fā)給各第二服務(wù)器，使各第二服務(wù)器對接收到的任務(wù)分片進(jìn)行處理；

處理模塊，用于所述裝置處理未分發(fā)的任務(wù)分片；

接收模塊，用于接收各第二服務(wù)器返回的針對各自接收到的任務(wù)分片的執(zhí)行消息，之后接收各第二服務(wù)器返回的各執(zhí)行結(jié)果，并根據(jù)所述執(zhí)行消息對各任務(wù)分片的執(zhí)行狀態(tài)進(jìn)行更新；

合并模塊，用于根據(jù)經(jīng)更新的各任務(wù)分片的執(zhí)行狀態(tài)，將所述各執(zhí)行結(jié)果以及所述裝置自身處理任務(wù)分片所得到的本地結(jié)果進(jìn)行合并，得到最終結(jié)果。

8.如權(quán)利要求7所述的裝置，其特征在于，所述創(chuàng)建模塊具體用于，所述裝置接收用戶發(fā)送的業(yè)務(wù)請求；根據(jù)所述業(yè)務(wù)請求，創(chuàng)建相應(yīng)的任務(wù)，并將所述任務(wù)的執(zhí)行狀態(tài)標(biāo)記為初始狀態(tài)。