[發明專利]任務調度方法、裝置、系統、介質和電子設備

在審

• 申請號: 201810681211.4
• 申請日: 2018-06-27
• 公開（公告）號: CN108829503A
• 公開（公告）日: 2018-11-16
• 發明（設計）人: 張海濱
• 申請（專利權）人: 泰康保險集團股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;H04L29/08
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王寶筠

1.一種任務調度方法，應用于任務調度裝置，其特征在于，方法包括：

接收需要調度的任務的任務信息，并為所述任務生成任務ID，且設置所述任務的任務狀態為待執行狀態；其中，所述任務信息包括任務類型、corn表達式、執行域名稱編碼和任務執行消息體；

定時掃描任務狀態為待執行狀態的各任務的任務信息，依據各任務的任務信息中的corn表達式中的執行時間，確定需要執行的目標任務；

對于確定的需要執行的目標任務，在所述目標任務的任務執行消息體上填寫消息頭信息，并依據所述目標任務的執行域名稱編碼，確定目標業務域，將所述目標任務發送至對應的目標業務域中的消息交換機；

待所述目標任務發送完成后，依據所述目標任務的任務類型，按照與所述任務類型相對應的預設處理方法，更新所述目標任務。

2.根據權利要求1所述的任務調度方法，其特征在于，所述按照與所述任務類型相對應的預設處理方法，更新所述目標任務包括：

當所述目標任務確定為單次型任務時，將所述目標任務的任務狀態更新為已執行狀態，并記錄所述目標任務的執行時間；

當所述目標任務確定為重復型任務時，將所述目標任務的任務狀態更新為已執行狀態，記錄所述目標任務的執行時間，并依據所述目標任務的任務信息中的corn表達式，生成新的待執行任務，所述新的待執行任務的任務ID與所述目標任務的任務ID相同。

3.根據權利要求2所述的任務調度方法，其特征在于，所述corn表達式包含所述目標任務與下一任務的間隔時間；所述依據所述目標任務的任務信息中的corn表達式，生成新的待執行任務包括：

依據所述目標任務與下一任務的間隔時間，生成所述新的待執行任務的執行時間。

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

依據所述新的待執行任務的執行時間和所述新的待執行任務的corn表達式，生成所述新的待執行任務與其下一任務的間隔時間。

5.根據權利要求1-4任一項所述的任務調度方法，其特征在于，所述依據各任務的任務信息中的corn表達式中的執行時間，確定需要執行的目標任務包括：

依據各任務的任務信息中的corn表達式中的執行時間，確定任務的執行時間在下次掃描時間之前的任務為需要執行的目標任務。

6.根據權利要求1-4任一項所述的任務調度方法，其特征在于，所述依據所述目標任務的執行域名稱編碼，確定目標業務域，將所述目標任務發送至對應的目標業務域中的消息交換機包括：

依據所述目標任務的執行域名稱編碼，確定目標業務域；

確定所述目標業務域對應的消息交換機，以及與所述消息交換機對應的消息隊列；

將所述目標任務發送至對應的消息交換機，并通過所述消息隊列承載所述目標任務中的任務執行消息體。

7.一種任務調度裝置，其特征在于，包括：任務接收模塊、任務掃描模塊、任務分發模塊和任務更新模塊，其中：

所述任務接收模塊用于接收需要調度的任務的任務信息，并為所述任務生成任務ID，設置所述任務的任務狀態為待執行狀態；其中，所述任務信息包括任務類型、corn表達式、執行域名稱編碼和任務執行消息體；

所述任務掃描模塊用于定時掃描所述任務接收模塊中各任務的任務信息，依據各任務的任務信息中的corn表達式中的執行時間，確定需要執行的目的任務，并將所述目的任務的任務信息和任務ID發送至所述任務分發模塊；

所述任務分發模塊用于接收到所述任務掃描模塊發送的目的任務的任務信息和任務ID后，在所述目標任務的任務執行消息體上填寫消息頭信息，并依據所述目標任務的執行域名稱編碼，確定目標業務域，將所述目標任務發送至對應的目標業務域中的消息交換機；以及將完成發送的目標任務的任務信息和任務ID發送至所述任務更新模塊；

所述任務更新模塊用于接收到所述任務分發模塊發送的完成發送的目標任務的任務信息和任務ID后，依據所述目標任務的任務類型，按照與所述任務類型相對應的預設處理方法，更新所述目標任務。