[發明專利]后臺任務執行方法、分布式系統及計算機可讀存儲介質

在審

• 申請號: 202011572963.0
• 申請日: 2020-12-24
• 公開（公告）號: CN112732420A
• 公開（公告）日: 2021-04-30
• 發明（設計）人: 張中文
• 申請（專利權）人: 北京浪潮數據技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 高勇

1.一種后臺任務執行方法，其特征在于，應用于分布式系統中的主管理節點，所述分布式管理系統還包括從管理節點，該方法包括：

獲取后臺任務被劃分后的任務分片并確定所述任務分片的執行順序；

按照所述執行順序執行所述任務分片，并向所述從管理節點發送當前正在執行的任務分片的執行進度信息，以便所述從管理節點在基于所述進度信息判定所述主管理節點故障時按照所述執行順序執行剩余未執行的任務分片。

2.如權利要求1所述的后臺任務執行方法，其特征在于，向所述從管理節點發送當前正在執行的任務分片的執行進度信息，包括：

周期地向所述從管理節點發送心跳信號，以便所述從管理節點在接收到上一個心跳信號后超過預設時長未接收到下一個心跳信號時判定所述主管理節點故障并按照所述執行順序執行剩余未執行的任務分片；

所述心跳信號包括當前正在執行的任務分片的標識，所述預設時長大于所述周期的時長。

3.如權利要求2所述的后臺任務執行方法，其特征在于，按照所述執行順序執行所述任務分片時，還包括：

當當前正在執行的任務分片被執行完后，向所述從管理節點發送剛執行完的任務分片的執行完成進度信息。

4.如權利要求1至3任一項所述的后臺任務執行方法，其特征在于，向所述從管理節點發送當前正在執行的任務分片的執行進度信息，以便所述從管理節點在基于所述進度信息判定所述主管理節點故障時按照所述執行順序執行剩余未執行的任務分片，包括：

向所述分布式系統中的所有從管理節點發送當前正在執行的任務分片的執行進度信息，以便從管理節點在基于所述進度信息判定所述主管理節點故障時通過互發的權重信息確定權重最高的從管理節點且權重最高的從管理節點按照所述執行順序執行剩余未執行的任務分片。

5.一種后臺任務執行方法，其特征在于，應用于分布式系統中的從管理節點，所述分布式系統還包括主管理節點，包括：

獲取后臺任務被劃分后的任務分片并確定任務分片的執行順序；

接收所述主管理節點在按照所述執行順序執行任務分片過程中發送的當前正在執行的任務分片的執行進度信息；

在基于所述任務執行信息判定所述主管理節點故障時按照所述執行順序執行剩余未執行的任務分片。

6.如權利要求5所述的后臺任務執行方法，其特征在于，接收主管理節點在按照所述執行順序執行任務分片過程中發送的當前正在執行的任務分片的執行進度信息，包括：

接收主管理節點在按照所述執行順序執行任務分片過程中周期地發送的心跳信號，所述心跳信號包括當前正在執行的任務分片的標識；

在基于所述任務執行信息判定所述主管理節點故障時按照所述執行順序執行剩余未執行的任務分片，包括：

判斷是否在接收到上一個心跳信號后超過預設時長未接收到下一個心跳信號；

若是，判定所述主管理節點故障并按照所述執行順序執行剩余未執行的任務分片，所述預設時長大于所述周期的時長。

7.如權利要求6所述的后臺任務執行方法，其特征在于，還包括：

接收所述主管理節點在剛執行完任務分片后發送的執行完成進度信息。

8.如權利要求5至7任一項所述的后臺任務執行方法，其特征在于，所述分布式系統中的從管理節點為多個；

在基于所述任務執行信息判定所述主管理節點故障之后，還包括：

向所述分布式系統中的其他從管理節點發送自身的權重信息并接收其他從管理節點發送的權重信息；

基于互發的權重信息判斷自身的權重是否最高，若是，進入按照所述執行順序執行剩余未執行的任務分片的步驟。

9.一種分布式系統，其特征在于，包括用于執行如權利要求1至4任一項所述的后臺任務執行方法的主管理節點和用于執行如權利要求5至8任一項所述的后臺任務執行方法的從管理節點。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執行時實現如權利要求1至8任一項所述后臺任務執行方法的步驟。