[發明專利]異步任務調度方法、服務器及存儲介質

有效

• 申請號: 201711114514.X
• 申請日: 2017-11-13
• 公開（公告）號: CN107957903B
• 公開（公告）日: 2020-11-10
• 發明（設計）人: 張小松;李小軍;沈陽
• 申請（專利權）人: 中國平安財產保險股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 深圳市君勝知識產權代理事務所(普通合伙) 44268
• 代理人: 王永文;劉文求

1.一種異步任務調度方法，其特征在于，包括如下步驟：

使用開源異步任務調度工具搭建異步調度框架，在所述異步調度框架的配置文件中配置異步任務所需的各項配置參數；

進行異步任務處理時，從待處理任務表中抓取預設量的任務并處理；將處理成功的任務轉移至成功表，失敗的任務轉移至失敗表，需重試的任務退回至待處理任務表；

在待處理任務表中設置批次號對待處理任務進行隔離，多臺服務器根據批次號分別抓取對應的待處理任務；用批次號來篩選待處理任務，一臺服務器抓取一個批次號的待處理任務；

進行多線程處理時，為異步任務配置一線程池，將一批次抓取的多個待處理任務分給線程池中不同的線程進行處理，并輸出處理結果；

所述在待處理任務表中設置批次號對待處理任務進行隔離，多臺服務器根據批次號分別抓取對應的待處理任務的步驟包括：

在待處理任務表中增加批次號的字段；

抓取待處理任務前，生成一個遞增且唯一的數字作為批次號；

將批次號填充到待處理任務表的本次需要抓取的記錄項中；被抓取后處理異常的任務，在記錄項中記錄批次號不為空但超過一定時間未處理；

多臺服務器查詢待處理任務表，根據批次號來篩選對應的待處理任務并抓取。

2.根據權利要求1所述的異步任務調度方法，其特征在于，所述配置參數用于表示異步任務的處理方式，包括：

是否需要失敗重試，重試次數，每次抓取待處理任務的數量，是否需要使用多線程，任務調度頻率的大小和線程池的大小。

3.根據權利要求2所述的異步任務調度方法，其特征在于，在所述異步調度框架的配置文件中配置異步任務所需的各項配置參數的步驟中，配置異步任務的每次抓取待處理任務的數量時，通過定時調度程序來定時讀取配置文件并更新到程序中。

4.根據權利要求1述的異步任務調度方法，其特征在于，所述進行異步任務處理時，從待處理任務表中抓取預設量的任務并處理；將處理成功的任務轉移至成功表，失敗的任務轉移至失敗表，需重試的任務退回至待處理任務表的步驟包括：

進行異步任務處理時，從待處理任務表中抓取預設量的任務至處理表中并進行處理；

若處理成功則將該任務轉移至成功表，若處理失敗則根據配置參數判斷是否需要重試；

若不需要重試，則轉移該任務至失敗表中；若需要重試，則將該任務退回至待處理任務表、并將該任務的重試次數加1，返回進行異步任務處理時的步驟。

5.根據權利要求1所述的異步任務調度方法，其特征在于，所述在待處理任務表中增加批次號的字段的步驟之后，還包括：

在產生待處理異步任務之前，將批次號的字段默認為空。

6.根據權利要求1所述的異步任務調度方法，其特征在于，在所述進行多線程處理時，為異步任務配置一線程池，將一批次抓取的多個待處理任務分給線程池中不同的線程進行處理,并輸出處理結果的步驟中，還包括：

在單個任務處理邏輯中設置日志ID，不同線程的日志用ID區分。

7.根據權利要求1所述的異步任務調度方法，其特征在于，在所述進行多線程處理時，為異步任務配置一線程池，將一批次抓取的多個待處理任務分給線程池中不同的線程進行處理,并輸出處理結果的步驟之后，還包括：

檢測任一線程處理完所有任務后，自動廢棄該線程。

8.一種異步任務調度的應用服務器，其特征在于，包括：處理器、存儲器、通信總線；所述存儲器上存儲有可被所述處理器執行的計算機可讀程序；

所述通信總線實現處理器和存儲器之間的連接通信；

所述處理器執行所述計算機可讀程序時實現如權利要求1-7任意一項所述的異步任務調度方法中的步驟。

9.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質存儲有一個或者多個程序，所述一個或者多個程序可被一個或者多個處理器執行，以實現如權利要求1～7任意一項所述的異步任務調度方法中的步驟。