[發明專利]一種統一任務調度系統

在審

• 申請號: 202011623543.0
• 申請日: 2020-12-31
• 公開（公告）號: CN112685161A
• 公開（公告）日: 2021-04-20
• 發明（設計）人: 代存折;李妃軍;劉國強
• 申請（專利權）人: 杭州當虹科技股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 杭州橙知果專利代理事務所(特殊普通合伙) 33261
• 代理人: 杜放

1.一種統一任務調度系統，其特征是，包括任務啟動模塊、任務停止模塊、群組模塊、調度模塊、機器模塊；

任務啟動模塊用于發送啟動各類任務請求，與群組模塊連接；

任務停止模塊用于攜帶任務id發送停止任務請求，與群組模塊連接；

群組模塊用于定義各類任務的調度規則，與調度模塊連接；

調度模塊用于根據規則轉發任務，與機器模塊連接；

機器模塊用于執行及記錄任務。

2.根據權利要求1所述的一種統一任務調度系統，其特征是，所述任務啟動模塊用于啟動任務信息，由調用端服務觸發，附帶任務類型、任務所需性能值、任務內容向群組模塊發送http請求；所述任務停止模塊用于停止當前任務，由調用端服務觸發，附帶任務啟動模塊記錄的任務id向群組模塊發送http請求。

3.根據權利要求2所述的一種統一任務調度系統，其特征是，所述群組模塊為整個任務調度系統的入口，在整個系統運行前，需要先定義如下信息：

第一：任務類型，即整個任務調度系統支持的任務類型；

第二：調度指標，分兩類：任務數、機器性能值；

第三：調度算法，分兩類：負載均衡、最多優先。

4.根據權利要求3所述的一種統一任務調度系統，其特征是，所述任務數是指每個機器模塊運行的最大任務數量；所述機器性能值代表機器模塊承受的一個量化的值，這個值是由機器的配置計算得出，公式：為cpu核數-內存大小，在任務啟動模塊中需要計算出當前任務所需要的性能值進行任務下發，以cpu和內存兩個指標中哪個先到達就代表此機器已被用完。

5.根據權利要求3所述的一種統一任務調度系統，其特征是，所述負載均衡是指把任務平均下發至機器模塊中；所述最多優先是指先一臺機器占用滿再去下發至另外一臺。

6.根據權利要求3或4或5所述的一種統一任務調度系統，其特征是，完成以上定義后，系統開始接收任務啟動模塊及任務停止模塊的請求，不同的請求處理邏輯不同：

(1)接收到任務啟動模塊請求后，先根據傳遞的type參數來獲取在群組模塊中定義的信息，包括調度指標、調度算法，然后和任務啟動模塊傳遞的參數一起合并轉發至調度模塊；

(2)接收到任務停止模塊請求后直接攜帶其傳遞的任務id轉發至調度模塊。

7.根據權利要求6所述的一種統一任務調度系統，其特征是，所述調度模塊在接收到群組模塊轉發的啟動和停止請求時處理邏輯不同：

(a)接收到群組模塊轉發的任務啟動請求后，需要先根據任務類型查詢機器模塊是否有匹配的任務機器，再根據調度指標查詢是否有空余機器，最后根據調度算法得出最優機器，調用機器模塊中的啟動任務進行下發，任務下發成功后調度模塊需要生成本次任務的一個唯一標識，采用隨機UUID方式，與機器模塊中真實運行的任務id、機器信息進行關聯存儲并響應至任務啟動模塊；

(b)接收到群組模塊轉發的任務停止請求后，根據傳遞的任務id，按照調度模塊存儲的信息直接查詢到任務所在的機器信息，隨后調用機器模塊中的停止任務即可。

8.根據權利要求7所述的一種統一任務調度系統，其特征是，所述機器模塊是指真正運行任務的機器，是支持動態無限橫向擴展的模塊，每個機器模塊都需要關聯一個群組模塊，這樣就會直接擁有任務類型、最大任務數、最大性能值，另外機器模塊需要額外存儲動態信息，動態信息用于調度模塊進行查詢使用。

9.根據權利要求8所述的一種統一任務調度系統，其特征是，具體查詢如下：

(i)查詢是否有空閑機器的判斷標準：當前運行任務數量或當前任務所占性能值是否到達群組模塊定義的上限；

(ii)查詢最優機器的算法：得出空閑機器集合后，按照剩余任務數量或剩余性能值進行升序或降序排列取第一個。

10.根據權利要求9所述的一種統一任務調度系統，其特征是，所述機器模塊在接收啟動和停止任務時的處理邏輯也不同：

(A)接收到啟動任務請求后，執行真正的任務啟動，然后根據當前所屬的群組模塊中配置的調度算法進行數據累加；

(B)接收到停止任務請求后，執行真正的任務停止，然后根據當前所屬的群組模塊中配置的調度算法進行數據縮減。