[發(fā)明專利]一種密集型任務(wù)分布式智能調(diào)度方法及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202010147487.1
• 申請日: 2020-03-05
• 公開（公告）號: CN111427672A
• 公開（公告）日: 2020-07-17
• 發(fā)明（設(shè)計）人: 姚宏宇
• 申請（專利權(quán)）人: 北京友友天宇系統(tǒng)技術(shù)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京臻之知識產(chǎn)權(quán)代理有限公司 11629
• 代理人: 趙福梅

1.一種密集型任務(wù)分布式智能調(diào)度方法，其特征在于，所述方法應(yīng)用于調(diào)度節(jié)點，包括：

獲得指定任務(wù)；

基于所述指定任務(wù)指示管理節(jié)點運(yùn)行任務(wù)管理，以監(jiān)控所述指定任務(wù)的資源信息；

獲得來自所述管理節(jié)點的資源請求，所述資源請求用于申請資源信息；

發(fā)送所述資源信息至所述管理節(jié)點，所述資源信息用于所述管理節(jié)點指示任務(wù)節(jié)點運(yùn)行所述指定任務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于所述指定任務(wù)指示管理節(jié)點運(yùn)行任務(wù)管理，以監(jiān)控所述指定任務(wù)的資源信息，包括：

對所述指定任務(wù)進(jìn)行解析，獲得解析結(jié)果；

基于解析結(jié)果在管理節(jié)點列表確定管理節(jié)點；

發(fā)送第一通知至管理節(jié)點，所述第一通知用于指示所述管理節(jié)點加載并運(yùn)行任務(wù)管理，以監(jiān)控所述指定任務(wù)的資源信息。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述獲得來自所述管理節(jié)點的資源請求之后，所述方法還包括：

與所述管理節(jié)點建立第一心跳。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，在所述發(fā)送所述資源信息至所述管理節(jié)點之后，所述方法還包括：

與所述任務(wù)節(jié)點建立第二心跳；

獲得來自所述任務(wù)節(jié)點的狀態(tài)信息，所述狀態(tài)信息用于表征所述任務(wù)節(jié)點的資源狀態(tài)。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，在與所述管理節(jié)點建立第一心跳和與所述任務(wù)節(jié)點建立第二心跳之后，所述方法還包括：

基于所述第一心跳和第二心跳判斷所述指定任務(wù)的執(zhí)行是否異常；

當(dāng)判斷為所述指定任務(wù)的執(zhí)行異常時，基于所述指定任務(wù)重新確定管理節(jié)點。

6.一種密集型任務(wù)分布式智能調(diào)度方法，其特征在于，所述方法應(yīng)用于管理節(jié)點，所述方法包括：

確定對應(yīng)指定任務(wù)的資源信息；

發(fā)送資源請求至調(diào)度節(jié)點，所述資源請求用于向調(diào)度節(jié)點申請資源信息；

獲得來自調(diào)度節(jié)點的所述資源信息；

基于資源信息發(fā)送第二通知至任務(wù)節(jié)點，所述第二通知用于指示所述任務(wù)節(jié)點運(yùn)行所述指定任務(wù)。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，在所述發(fā)送資源請求至調(diào)度節(jié)點之后，所述方法還包括：

與所述調(diào)度節(jié)點建立第一心跳。

8.一種密集型任務(wù)分布式智能調(diào)度方法，其特征在于，所述方法應(yīng)用于任務(wù)節(jié)點，所述方法包括：

獲得來自管理節(jié)點的第二通知，所述第二通知用于指示運(yùn)行指定任務(wù)；

加載并運(yùn)行任務(wù)程序，基于任務(wù)程序執(zhí)行所述指定任務(wù)。

9.根據(jù)權(quán)利要求8所述的方法，其特征在于，所述任務(wù)程序還用于與所述管理節(jié)點建立第三心跳，并周期性向所述管理節(jié)點發(fā)送所述指定任務(wù)的運(yùn)行狀態(tài)。

10.一種密集型任務(wù)分布式智能調(diào)度系統(tǒng)，其特征在于，所述系統(tǒng)包括調(diào)度節(jié)點、管理節(jié)點和任務(wù)節(jié)點；

所述調(diào)度節(jié)點，包括：

第一獲得模塊，用于獲得指定任務(wù)；

第一指示模塊，用于基于所述指定任務(wù)指示管理節(jié)點運(yùn)行任務(wù)管理，以監(jiān)控所述指定任務(wù)的資源信息；

所述第一獲得模塊，還用于獲得來自所述管理節(jié)點的資源請求，所述資源請求用于申請資源信息；

第一發(fā)送模塊，發(fā)送所述資源信息至所述管理節(jié)點，所述資源信息用于所述管理節(jié)點指示任務(wù)節(jié)點運(yùn)行所述指定任務(wù)；

所述管理節(jié)點，包括：

第二確定模塊，用于確定對應(yīng)指定任務(wù)的資源信息；

第二發(fā)送模塊，用于發(fā)送資源請求至調(diào)度節(jié)點，所述資源請求用于向調(diào)度節(jié)點申請資源信息；

第二獲得模塊，用于獲得來自調(diào)度節(jié)點的所述資源信息；

所述第二發(fā)送模塊，用于基于資源信息發(fā)送第二通知至任務(wù)節(jié)點，所述第二通知用于指示所述任務(wù)節(jié)點運(yùn)行所述指定任務(wù)；

所述任務(wù)節(jié)點，包括：

第三獲得模塊，用于獲得來自管理節(jié)點的第二通知，所述第二通知用于指示運(yùn)行指定任務(wù)；

執(zhí)行模塊，用于加載并運(yùn)行任務(wù)程序，基于任務(wù)程序執(zhí)行所述指定任務(wù)。