[發明專利]任務調度方法、裝置、設備、系統及存儲介質

在審

• 申請號: 202011205564.0
• 申請日: 2020-11-02
• 公開（公告）號: CN112231089A
• 公開（公告）日: 2021-01-15
• 發明（設計）人: 黃朝翔
• 申請（專利權）人: 廣州市網星信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種任務調度方法，其特征在于，應用于分布式調度系統中的第一調度器，所述分布式調度系統中包含存儲服務和至少兩個調度器，所述方法包括：

從所述存儲服務獲取當前調度事件對應的已被占用的調度序號中的最大序號，其中，所述已被占用的調度序號按順序依次遞增；

向所述存儲服務發送第一序號的占用請求，并在接收到所述存儲服務返回的占用成功消息時，將所述第一序號設定為所述第一調度器對應的第一調度序號，其中，所述第一序號為所述最大序號的下一個序號；

基于所述第一調度序號分配相應的任務。

2.根據權利要求1所述的方法，其特征在于，所述基于所述第一調度序號分配相應的任務，包括：

獲取第一待分配任務對應的第一身份信息；

采用預設哈希算法計算所述第一身份信息對應的第一哈希值；

若所述第一哈希值與所述第一調度序號相匹配，則將所述第一待分配任務確定為所述第一調度器對應的目標任務；

分配所述目標任務。

3.根據權利要求2所述的方法，其特征在于，所述第一身份信息為整數值；

所述采用預設哈希算法計算所述第一身份信息對應的第一哈希值，包括：

計算所述第一身份信息與所述當前調度事件對應的調度器總數相除后的第一余數，根據所述第一余數確定第一哈希值。

4.根據權利要求3所述的方法，其特征在于，還包括：

每隔第一預設時長向所述存儲服務上報所述第一調度器對應的第一服務的第一健康狀態信息。

5.根據權利要求4所述的方法，其特征在于，還包括：

從所述存儲服務獲取所述當前調度事件對應的所有調度器的健康狀態信息記錄；

根據所述健康狀態信息記錄確定當前處于健康狀態的調度器數量；

所述獲取第一待分配任務對應的第一身份信息，包括：

判斷所述當前處于健康狀態的調度器數量是否等于所述當前調度事件對應的調度器總數，若等于，則獲取第一待分配任務對應的第一身份信息。

6.根據權利要求5所述的方法，其特征在于，在所述判斷所述當前處于健康狀態的調度器數量是否等于所述當前調度事件對應的調度器總數之后，還包括：

若不等于，則重復執行從所述存儲服務獲取當前調度事件對應的已被占用的調度序號中的最大序號的相關步驟。

7.根據權利要求5所述的方法，其特征在于，所述根據所述健康狀態信息記錄確定當前處于健康狀態的調度器數量，包括：

統計所述健康狀態信息記錄中最近的第二預設時長內收到的健康狀態信息對應的協調器的數量，得到當前處于健康狀態的調度器數量，其中，所述第二預設時長大于或等于所述第一預設時長。

8.根據權利要求1所述的方法，其特征在于，所述存儲服務由文本系統或緩存服務器提供。

9.一種任務調度裝置，其特征在于，集成于分布式調度系統中的第一調度器，所述分布式調度系統中包含存儲服務和至少兩個調度器，所述裝置包括：

最大序號獲取模塊，用于從所述存儲服務獲取當前調度事件對應的已被占用的調度序號中的最大序號，其中，所述已被占用的調度序號按順序依次遞增；

占用請求發送模塊，用于向所述存儲服務發送第一序號的占用請求，并在接收到所述存儲服務返回的占用成功消息時，將所述第一序號設定為所述第一調度器對應的第一調度序號，其中，所述第一序號為所述最大序號的下一個序號；

任務分配模塊，用于基于所述第一調度序號分配相應的任務。

10.一種調度器設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1-8任一項所述的方法。

11.一種分布式調度系統，包括存儲服務和至少兩個如權利要求10所述的調度器設備。

12.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現如權利要求1-8中任一所述的方法。