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

在審

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

本申請提供一種定時任務資源動態調度方法及相關設備，其中，所述方法包括：首先獲取處理定時任務的第一處理速率，當第一處理速率小于預設的速率時對分片資源重新進行分配，并將得到的分片策略發送給注冊中心，通過注冊中心對微服務容器進行分片，從而使微服務容器對定時任務進行處理，以達到預設的速率。使得在處理定時任務的過程中可以按需調整分片資源，實時生效，無需重啟微服務容器的微服務，并且可以通過多次調整達到資源利用最優化。

技術領域

本申請涉及數據處理技術領域，尤其涉及一種定時任務資源動態調度方法及相關裝置。

背景技術

Elastic-Job是ddframe中dd-job的作業模塊中分離出來的分布式彈性作業框架，該框架的分片(一個分片代表一個線程)原理可水平切分總體任務為多個子任務，并調度到不同節點執行，從而最大限度的利用資源。Elastic-Job consol為該框架提供的監控模塊，可支持基礎的作業監控功能。Elastic-Job可以解決資源分配問題，但是無法支持動態調配資源，在業務高峰期需調整分片后重啟服務器，降低了解決問題的實效。

基于此，需要一種定時任務資源動態調度方法以滿足業務高峰期的處理需求。

發明內容

有鑒于此，本申請的目的在于提出一種定時任務資源動態調度方法及相關設備。

基于上述目的，本申請提供了定時任務資源動態調度方法，包括：

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

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

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

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

進一步的，所述方法還包括：

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

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

進一步的，所述為所述任務隊列重新分配分片資源，得到分片策略，包括：

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

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

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

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

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

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

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

進一步的，所述第一處理速率通過Elastic-Job作業監控獲取。

進一步的，所述獲取任務隊列中的定時任務的第一處理速率，包括：

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