[發明專利]一種定時任務的執行方法、裝置、計算機設備及存儲介質

在審

• 申請號: 201911301277.7
• 申請日: 2019-12-17
• 公開（公告）號: CN111078413A
• 公開（公告）日: 2020-04-28
• 發明（設計）人: 李愷;何柄融;許煜彬;王偉
• 申請（專利權）人: 深圳前海環融聯易信息科技服務有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54;G06F16/25;G06F16/21
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 武志峰

1.一種定時任務的執行方法，其特征在于，包括：

設置多個哈希槽，并對所述多個哈希槽進行編號；

將每臺服務器與其中的一部分哈希槽進行關聯，且每臺服務器關聯的哈希槽不相同；

當需要對定時任務進行執行時，獲取定時任務中各條數據的主鍵字段，并通過所述主鍵字段對所述哈希槽的總數量進行取模計算，得到取模結果；

根據所述取模結果確定對應哈希槽的編號，并基于所述編號確定對應哈希槽關聯的服務器，再將相應的數據分配至對應的服務器進行處理；

通過Redis數據庫記錄參與所述定時任務的服務器的總數量；

在Redis數據庫中記錄處理完對應數據的服務器的數量，并判斷所述服務器的總數量與處理完對應數據的服務器的數量是否相等；

若相等，則結束當前定時任務，并將所述Redis數據庫中記錄的服務器的總數量以及處理完對應數據的服務器的數量均重置為0；

若不相等，則繼續等待未處理完對應數據的服務器完成當前定時任務。

2.根據權利要求1所述的定時任務的執行方法，其特征在于，所述將每臺服務器與其中的一部分哈希槽進行關聯，且每臺服務器關聯的哈希槽不相同，包括：

將所述哈希槽的總數量除以服務器的總數量，得到每臺服務器關聯的哈希槽的數量；

依次從所有哈希槽中取出對應數量的哈希槽分配至每臺服務器，并將每臺服務器與分配的哈希槽進行關聯。

3.根據權利要求1所述的定時任務的執行方法，其特征在于，所述當需要對定時任務的各條數據進行處理時，獲取各條數據的主鍵字段，并通過所述主鍵字段對所述哈希槽的總數量進行取模計算，得到取模結果包括：

根據哈希算法計算各條數據的主鍵字段對應的哈希值；

通過所述哈希值對所述哈希槽的總數量進行取模計算，得到取模結果。

4.根據權利要求1所述的定時任務的執行方法，其特征在于，還包括：

當當前定時任務未執行完成并且增加新的服務器時，則等待當前定時任務執行完成；

在當前定時任務執行完成后，更新服務器的總數量，并基于更新后的服務器的總數量重新分配哈希槽。

5.根據權利要求4所述的定時任務的執行方法，其特征在于，還包括：

當執行下一次定時任務時，在所述Redis數據庫中重新設置參與定時任務的服務器的總數量。

6.根據權利要求3所述的定時任務的執行方法，其特征在于，所述哈希算法為CRC16算法。

7.根據權利要求4所述的定時任務的執行方法，其特征在于，所述在Redis數據庫中記錄處理完對應數據的服務器的數量，包括：

當一服務器處理完對應數據時，則在所述Redis數據庫中將處理完對應數據的服務器的數量加1。

8.一種定時任務的執行裝置，包括：

編號單元，用于設置多個哈希槽，并對所述多個哈希槽進行編號；

關聯單元，用于將每臺服務器與其中的一部分哈希槽進行關聯，且每臺服務器關聯的哈希槽不相同；

獲取單元，用于當需要對定時任務進行執行時，獲取定時任務中各條數據的主鍵字段，并通過所述主鍵字段對所述哈希槽的總數量進行取模計算，得到取模結果；

分配單元，用于根據所述取模結果確定對應哈希槽的編號，并基于所述編號確定對應哈希槽關聯的服務器，再將相應的數據分配至對應的服務器進行處理；

記錄單元，用于通過Redis數據庫記錄參與所述定時任務的服務器的總數量；

判斷單元，用于在Redis數據庫中記錄處理完對應數據的服務器的數量，并判斷所述服務器的總數量與處理完對應數據的服務器的數量是否相等；

第一重置單元，用于若相等，則結束當前定時任務，并將所述Redis數據庫中記錄的服務器的總數量以及處理完對應數據的服務器的數量均重置為0；

等待單元，用于若不相等，則繼續等待未處理完對應數據的服務器完成當前定時任務。