[發(fā)明專利]后臺任務執(zhí)行方法、分布式系統(tǒng)及計算機可讀存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011572963.0
• 申請日: 2020-12-24
• 公開（公告）號: CN112732420A
• 公開（公告）日: 2021-04-30
• 發(fā)明（設計）人: 張中文
• 申請（專利權）人: 北京浪潮數(shù)據(jù)技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京集佳知識產(chǎn)權代理有限公司 11227
• 代理人: 高勇

本發(fā)明公開了一種后臺任務執(zhí)行方法，分布式系統(tǒng)中的主管理節(jié)點和從管理節(jié)點均會接收后臺任務被劃分后的任務分片并確定所述任務分片的執(zhí)行順序，主管理節(jié)點在按照執(zhí)行順序執(zhí)行任務分片的過程中，會向從管理節(jié)點發(fā)送當前正在執(zhí)行的任務分片的執(zhí)行進度信息，若從管理節(jié)點在基于執(zhí)行進度信息判定主管理節(jié)點故障時會按照執(zhí)行順序自動執(zhí)行剩余未執(zhí)行的任務分片?？梢?，通過該種方式，在主管理節(jié)點故障時，從管理節(jié)點能夠自動接管執(zhí)行剩余的任務分片，處理方式簡單可靠，充分發(fā)揮了分布式系統(tǒng)的優(yōu)勢，充分利用了分布式系統(tǒng)的資源。本發(fā)明還公開了一種分布式系統(tǒng)及計算機可讀存儲介質(zhì)，具有與上述后臺任務執(zhí)行方法相同的有益效果。

技術領域

本發(fā)明涉及分布式系統(tǒng)技術領域，特別是涉及一種后臺任務執(zhí)行方法、分布式系統(tǒng)及計算機可讀存儲介質(zhì)。

背景技術

隨著社會信息化的持續(xù)深入，分布式系統(tǒng)也變得日益普及。后臺任務是信息系統(tǒng)內(nèi)不可或缺的功能，現(xiàn)有技術中，后臺任務僅能在分布式系統(tǒng)中的單節(jié)點執(zhí)行，但當執(zhí)行后臺任務的節(jié)點出現(xiàn)故障時，后臺任務執(zhí)行失敗，需要人工介入進行處理，處理難度大且極易出錯，可見，現(xiàn)有技術中的后臺任務執(zhí)行方案無法充分發(fā)揮分布式系統(tǒng)的優(yōu)勢，無法充分利用分布式系統(tǒng)的資源。

發(fā)明內(nèi)容

本發(fā)明的目的是提供一種后臺任務執(zhí)行方法、分布式系統(tǒng)及計算機可讀存儲介質(zhì)，處理方式簡單可靠，充分發(fā)揮了分布式系統(tǒng)的優(yōu)勢，充分利用了分布式系統(tǒng)的資源。

為解決上述技術問題，本發(fā)明提供了一種后臺任務執(zhí)行方法，應用于分布式系統(tǒng)中的主管理節(jié)點，所述分布式管理系統(tǒng)還包括從管理節(jié)點，該方法包括：

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

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

優(yōu)選地，向所述從管理節(jié)點發(fā)送當前正在執(zhí)行的任務分片的執(zhí)行進度信息，包括：

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

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

優(yōu)選地，按照所述執(zhí)行順序執(zhí)行所述任務分片時，還包括：

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

優(yōu)選地，向所述從管理節(jié)點發(fā)送當前正在執(zhí)行的任務分片的執(zhí)行進度信息，以便所述從管理節(jié)點在基于所述進度信息判定所述主管理節(jié)點故障時按照所述執(zhí)行順序執(zhí)行剩余未執(zhí)行的任務分片，包括：

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

為解決上述技術問題，本發(fā)明還提供了一種后臺任務執(zhí)行方法，應用于分布式系統(tǒng)中的從管理節(jié)點，所述分布式系統(tǒng)還包括主管理節(jié)點，包括：

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

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

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

優(yōu)選地，接收主管理節(jié)點在按照所述執(zhí)行順序執(zhí)行任務分片過程中發(fā)送的當前正在執(zhí)行的任務分片的執(zhí)行進度信息，包括：