[發(fā)明專利]分布式定時任務執(zhí)行方法、系統(tǒng)、設備及計算機存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202111496790.3
• 申請日: 2021-12-08
• 公開（公告）號: CN114153662A
• 公開（公告）日: 2022-03-08
• 發(fā)明（設計）人: 劉浩
• 申請（專利權）人: 深圳前海微眾銀行股份有限公司
• 主分類號: G06F11/20
• 分類號: G06F11/20;G06F11/30;G06F9/48
• 代理公司: 深圳市世紀恒程知識產(chǎn)權代理事務所 44287
• 代理人: 陳文斌

1.一種分布式定時任務執(zhí)行方法，其特征在于，所述方法應用于分布式服務器集群，所述集群中包含哨兵節(jié)點和若干普通節(jié)點，所述分布式定時任務執(zhí)行方法包括：

檢測到來自配置中心的定時任務觸發(fā)指令，利用所述哨兵節(jié)點通知各所述普通節(jié)點所執(zhí)行的普通實例開始執(zhí)行所述定時任務觸發(fā)指令對應的定時任務，其中，所述哨兵節(jié)點和各所述普通節(jié)點已在所述配置中心完成注冊；

在通過所述普通實例執(zhí)行所述定時任務的過程中，若檢測到所述集群中發(fā)生節(jié)點下線，則確定出下線節(jié)點的哨兵節(jié)點類型或普通節(jié)點類型；

在所述集群中執(zhí)行預設的與所述哨兵節(jié)點類型或普通節(jié)點類型相匹配的容錯策略，以基于執(zhí)行所述容錯策略后的集群將所述定時任務執(zhí)行完成，其中，所述容錯策略包括基于所述哨兵節(jié)點的數(shù)據(jù)補償執(zhí)行和/或基于各所述普通節(jié)點的節(jié)點重新選舉。

2.如權利要求1所述的分布式定時任務執(zhí)行方法，其特征在于，若所述下線節(jié)點為所述哨兵節(jié)點類型，

所述在所述集群中執(zhí)行預設的與所述哨兵節(jié)點類型或普通節(jié)點類型相匹配的容錯策略，以基于執(zhí)行所述容錯策略后的集群將所述定時任務執(zhí)行完成的步驟包括：

使用預設的選舉算法從各所述普通節(jié)點中選舉出新的哨兵節(jié)點；

基于新的哨兵節(jié)點重新激活各所述普通節(jié)點，以利用重新激活后的各所述普通節(jié)點將所述定時任務執(zhí)行完成。

3.如權利要求1所述的分布式定時任務執(zhí)行方法，其特征在于，若所述下線節(jié)點為所述普通節(jié)點類型，

所述在所述集群中執(zhí)行預設的與所述哨兵節(jié)點類型或普通節(jié)點類型相匹配的容錯策略，以基于執(zhí)行所述容錯策略后的集群將所述定時任務執(zhí)行完成的步驟包括：

刪除所述集群中下線的普通節(jié)點在所述配置中心的注冊信息；

通過所述哨兵節(jié)點觸發(fā)針對所述下線的普通節(jié)點的數(shù)據(jù)補償執(zhí)行操作，以補償執(zhí)行所述下線的普通節(jié)點所執(zhí)行的下線普通實例負責處理的分片數(shù)據(jù)，其中，所述分片數(shù)據(jù)為執(zhí)行所述定時任務所需的部分數(shù)據(jù)。

4.如權利要求1所述的分布式定時任務執(zhí)行方法，其特征在于，所述檢測到來自配置中心的定時任務觸發(fā)指令，利用所述哨兵節(jié)點通知各所述普通節(jié)點所執(zhí)行的普通實例開始執(zhí)行所述定時任務觸發(fā)指令對應的定時任務的步驟之前，還包括：

將所述集群中的各所述普通節(jié)點以及所述哨兵節(jié)點注冊到所述配置中心，其中，所述哨兵節(jié)點記錄有各所述普通節(jié)點的節(jié)點名稱；

生成并發(fā)送各所述普通節(jié)點的激活請求命令到所述哨兵節(jié)點，以供所述哨兵節(jié)點按照各所述節(jié)點名稱返回相應的分片數(shù)據(jù)索引至各所述普通節(jié)點，其中，所述分片數(shù)據(jù)索引用于指示各所述普通節(jié)點從數(shù)據(jù)庫中獲取到自身執(zhí)行所述定時任務所需的分片數(shù)據(jù)。

5.如權利要求1所述的分布式定時任務執(zhí)行方法，其特征在于，所述檢測到來自配置中心的定時任務觸發(fā)指令，利用所述哨兵節(jié)點通知各所述普通節(jié)點所執(zhí)行的普通實例開始執(zhí)行所述定時任務觸發(fā)指令對應的定時任務的步驟包括：

利用所述哨兵節(jié)點監(jiān)聽所述配置中心上用于指示定時任務狀態(tài)的狀態(tài)參數(shù)，并在所述哨兵節(jié)點監(jiān)聽所述狀態(tài)參數(shù)的取值變化為當前時間時，將所述狀態(tài)參數(shù)的取值變化作為所述定時任務觸發(fā)指令；

通過所述哨兵節(jié)點將所述狀態(tài)參數(shù)的取值由所述當前時間修改為執(zhí)行參數(shù)，以供各所述普通節(jié)點在監(jiān)聽到所述狀態(tài)參數(shù)的取值變化為所述執(zhí)行參數(shù)后，通過各自所執(zhí)行的普通實例開始執(zhí)行所述定時任務。

6.如權利要求5所述的分布式定時任務執(zhí)行方法，其特征在于，所述通過所述哨兵節(jié)點將所述狀態(tài)參數(shù)的取值由所述當前時間修改為執(zhí)行參數(shù)的步驟之后，還包括：

在各所述普通節(jié)點所執(zhí)行的普通實例內(nèi)使用線程池，以供各所述普通實例基于所述線程池開始執(zhí)行所述定時任務，其中，所述線程池中包含生產(chǎn)線程和消費線程。