[發明專利]定時任務資源動態調度方法及相關裝置

在審

• 申請號: 202210334280.4
• 申請日: 2022-03-30
• 公開（公告）號: CN114942833A
• 公開（公告）日: 2022-08-26
• 發明（設計）人: 劉帥鋒
• 申請（專利權）人: 中國人壽保險股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京風雅頌專利代理有限公司 11403
• 代理人: 金含

1.一種定時任務資源動態調度方法，其特征在于，包括：

獲取任務隊列中的定時任務的第一處理速率；其中，所述定時任務在微服務容器上進行處理；

響應于確定所述第一處理速率小于預設的速率，為所述任務隊列重新分配分片資源，得到分片策略；

將所述分片策略發送給注冊中心，以使所述注冊中心根據所述分片策略對所述微服務容器進行分片；

在分片后的所述微服務容器上對所述定時任務進行處理。

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

獲取在分片后的所述微服務容器上對所述定時任務進行處理的第二處理速率；

響應于確定所述第二處理速率小于預設的速率，為所述任務隊列分配新的微服務容器，以使所述任務隊列中的所述定時任務同時被所述微服務容器和所述新的微服務容器處理。

3.根據權利要求1所述的方法，其特征在于，所述為所述任務隊列重新分配分片資源，得到分片策略，包括：

獲取所述任務隊列的識別碼，根據所述第一處理速率確定分片總數；

根據哈希算法對所述識別碼和所述分片總數進行計算，得到所述任務隊列對應的微服務容器的分片項；根據所述分片總數和所述分片項得到所述分片策略。

4.根據權利要求3所述的方法，其特征在于，所述根據哈希算法對所述識別碼和所述分片總數進行計算，得到所述任務隊列對應的微服務容器的分片項；根據所述分片總數和所述分片項得到所述分片策略，包括：

獲取當前可用的微服務容器，將全部所述分片資源進行編號；

根據負載均衡的原則為全部所述可用的微服務容器分配全部所述分片資源；

將所述識別碼除以所述分片總數得到所述分片項；

根據所述分片資源的編號和所述分片項得到所述分片策略，所述策略包括：將與所述分片項的數值相等的分片資源編號對應的分片資源所在的微服務容器作為處理所述定時任務的微服務容器。

5.根據權利要求1所述的方法，其特征在于，所述第一處理速率通過Elastic-Job作業監控獲取。

6.根據權利要求5所述的方法，其特征在于，所述獲取任務隊列中的定時任務的第一處理速率，包括：

通過所述Elastic-Job作業監控獲取所述任務隊列中已經處理完的定時任務的數量和處理占用的時間；

根據所述已經處理完的定時任務的數量和處理占用的時間得到所述第一處理速率。

7.根據權利要求1所述的方法，其特征在于，所述方法在技術棧HALO框架中運行，所述注冊中心的配置通過Oceanbase數據庫存儲。

8.一種定時任務資源動態調度裝置，其特征在于，包括：

獲取模塊，被配置為獲取任務隊列中的定時任務的第一處理速率；其中，所述定時任務在微服務容器上進行處理；

計算模塊，被配置為響應于確定所述第一處理速率小于預設的速率，為所述任務隊列重新分配分片資源，得到分片策略；

分配模塊，被配置為將所述分片策略發送給注冊中心，以使所述注冊中心根據所述分片策略對所述微服務容器進行分片；

處理模塊，被配置為在分片后的所述微服務容器上對所述定時任務進行處理。

9.一種電子設備，包括存儲器、處理器及存儲在所述存儲器上并可由所述處理器執行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1至7中任意一項所述的方法。

10.一種非暫態計算機可讀存儲介質，所述非暫態計算機可讀存儲介質存儲計算機指令，其特征在于，所述計算機指令用于使計算機執行根據權利要求1至7中任意一項所述的方法。