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

在審

• 申請號: 202011198034.8
• 申請日: 2020-10-30
• 公開（公告）號: CN113760491A
• 公開（公告）日: 2021-12-07
• 發明（設計）人: 謝建雨;王偉
• 申請（專利權）人: 北京沃東天駿信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種任務調度系統，其特征在于，包括：數據庫和至少一個任務子系統，各所述任務子系統部署于集群服務器中，各所述任務子系統分別包括任務調度模塊；

其中，在所述任務調度模塊中注冊有至少一種調度任務的任務處理單元，在所述任務處理單元中注冊有對應調度任務的任務處理邏輯；

所述任務調度模塊，用于當檢測到預設觸發邏輯被業務端調用時，將接收到的所述業務端發送的調度任務的任務信息添加到數據庫中；以及，將讀取到的所述數據庫中的調度任務的任務信息發送給任務處理單元，以使所述任務處理單元基于所述任務處理邏輯執行任務處理操作，并將生成的任務處理數據進行輸出；其中，所述預設觸發邏輯用于觸發調度任務的任務信息的添加操作。

2.根據權利要求1所述的系統，其特征在于，所述任務調度模塊，具體用于：

通過單線程執行器服務，基于預設時間間隔讀取所述數據庫中的調度任務的任務信息，將調度任務的任務信息封裝為可運行對象后提交給多線程執行器服務；

通過多線程執行器服務，基于數據庫的排他機制將所述可運行對象發送給任務處理單元；其中，所述數據庫的排他機制用于控制讀取到所述調度任務的任務信息的多個任務調度模塊中的唯一多線程執行器服務執行可運行對象的發送操作。

3.根據權利要求2所述的系統，其特征在于，所述任務調度模塊，還用于：

在讀取到數據庫中的調度任務的任務信息之后，將所述調度任務的任務信息與所述任務調度模塊中注冊的任務處理單元中的任務信息進行匹配，將匹配成功的調度任務的任務信息作為可封裝為可運行對象的任務信息。

4.根據權利要求1所述的系統，其特征在于，所述任務調度模塊，還用于：

在檢測到任務子系統啟動時，獲取所述任務調度模塊上的任務接口中的調度任務的任務信息以及任務調度接口中封裝有調度任務的任務處理邏輯的實例bean類，并基于所述任務信息和所述bean類將調度任務注冊在任務處理單元中。

5.根據權利要求4所述的系統，其特征在于，所述任務子系統還包括統計分析模塊，相應的，所述任務調度模塊還用于：將所述任務處理數據發送給統計分析模塊，所述統計分析模塊，用于對接收到的各所述任務調度模塊發送的任務處理數據進行異步統計分析，將生成的統計分析結果進行輸出。

6.根據權利要求5所述的系統，其特征在于，所述任務處理邏輯包含調用數據上報邏輯的調用操作，相應的，所述任務調度模塊，具體用于：

在所述任務處理單元執行任務處理操作的過程中，當檢測到所述數據上報邏輯被所述任務處理邏輯調用時，將生成的與所述數據上報邏輯對應的任務處理數據發送給統計分析模塊；其中，所述數據上報邏輯用于觸發統計分析模塊對任務處理單元發送的任務處理數據執行接收操作。

7.根據權利要求5所述的系統，其特征在于，所述bean類還封裝有調度任務的數據統計邏輯，相應的，所述統計分析模塊，還用于：

基于所述bean類，將所述調度任務的數據統計邏輯注冊在統計分析模塊中，以使所述統計分析模塊基于所述數據統計邏輯，對接收到的任務處理數據進行統計分析處理，并將生成的統計分析結果進行輸出。

8.根據權利要求7所述的系統，其特征在于，所述統計分析結果包括任務總覽數據和/或校驗成功信息，相應的，所述統計分析模塊，具體用于：

當所述數據統計邏輯包括基于時間窗口的統計邏輯時，基于獲取到的與所述時間窗口對應的任務處理數據，生成基于時間窗口維度的任務總覽數據，并將所述任務總覽數據進行輸出；

和/或，

當所述數據統計邏輯包括基于任務維度的統計邏輯時，獲取與調度任務對應的任務處理數據中的處理狀態數據，并將所述處理狀態數據與所述調度任務對應的狀態校驗標準進行匹配，如果匹配成功，則生成所述調度任務的校驗成功信息，并將所述校驗成功信息進行輸出。

9.根據權利要求4所述的系統，其特征在于，所述任務子系統是基于springboot-starter機制構建的。