[發明專利]定時任務的分布式調用系統

有效

• 申請號: 202011273479.8
• 申請日: 2020-11-13
• 公開（公告）號: CN112416581B
• 公開（公告）日: 2022-02-18
• 發明（設計）人: 肖向徐
• 申請（專利權）人: 五八同城信息技術有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/48;H04L43/08;H04L43/10;H04L67/10;H04L67/133
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 呂俊秀

本發明提供了一種定時任務的分布式調用系統，該系統包括：客戶端集群，包括多個客戶端節點，用于獲取任務注冊信息并向服務器節點發送，還發送心跳信息，將用戶的操作指令發送至服務器節點；服務器集群，包括多個服務器節點，用于創建定時任務；在到達定時任務觸發時間時，確定任務執行節點，由任務執行節點執行定時任務；提供任務執行監控接口，接收客戶端節點的操作指令并執行對定時任務的操作；ZooKeeper集群，用于保存客戶端節點和服務器節點的狀態信息；MongoDB集群，用于保存任務注冊信息，并保存定時任務對應的任務執行節點和服務器節點的標識。本發明避免了單點故障，節省了本地服務資源，實現了對任務執行過程的監管。

技術領域

本發明涉及計算機技術領域，特別是涉及一種定時任務的分布式調用系統。

背景技術

現有技術中，在配置定時任務時，一般是通過Spring注解@Scheduled方式配置定時任務，例如：配置的定時任務為@Scheduled(cron＝0 0 0/1**？)，即每小時執行一次定時任務，配置完成的定時任務在服務器本地執行。

由于任務執行過程是不可見的，對于任務的執行進度以及執行是否因異常終止等情況無法控制預感知；而且由于任務在本地執行，即任務的執行與應用在相同JRE(JavaRuntime Environment，Java運行環境)中執行，對應用本身性能的影響無法控制，大概率會出現因定時任務出現異常導致應用服務性能急劇下降的情況；在定時任務執行過程中，對于批量數據處理，不能人工干預；而且由于任務在本地創建并在本地所有節點共同執行，導致不能充分利用集群資源。

綜上，通過Spring注解@Scheduled方式配置的定時任務存在著以下缺陷：容易出現單點故障；消耗本地服務資源；任務執行過程難以監管；不能充分利用集群資源。

發明內容

鑒于上述問題，提出了本發明實施例以便提供一種克服上述問題或者至少部分地解決上述問題的一種定時任務的分布式調用系統。

依據本發明的第一方面，提供了一種定時任務的分布式調用系統，包括：

客戶端集群，包括多個客戶端節點，客戶端節點用于獲取任務注冊信息，向服務器節點發送與所在客戶端集群標識對應的任務注冊信息，并向服務器節點發送心跳信息，接收用戶對定時任務的操作指令，并將所述操作指令發送至服務器節點；

服務器集群，包括多個服務器節點，用于接收所述任務注冊信息，并創建與所述任務注冊信息對應的定時任務，將所述任務注冊信息保存至MongoDB集群；根據所述心跳信息確定客戶端節點的狀態信息，將所述客戶端節點的狀態信息和心跳信息保存至ZooKeeper集群，并將服務器節點的狀態信息保存至ZooKeeper集群；在到達所述定時任務觸發時間時，確定狀態信息為可用狀態的一個服務器節點或客戶端節點，作為任務執行節點，并將所述定時任務發送至所述任務執行節點，由所述任務執行節點執行所述定時任務；提供任務執行監控接口，通過所述任務執行監控接口接收客戶端節點的操作指令，并根據所述操作指令執行對定時任務的操作；

ZooKeeper集群，用于保存所述客戶端集群中多個客戶端節點的狀態信息和心跳信息，并保存多個服務器節點的狀態信息；

MongoDB集群，用于保存所述任務注冊信息，并保存定時任務對應的任務執行節點和服務器節點的標識。

可選的，所述任務執行監控接口包括Console可視化操作平臺和/或監控應用程序編程接口API，服務器節點用于根據通過Console可視化操作平臺或監控API接收到的所述操作指令，執行與所述操作指令對應的操作。

可選的，所述與所述操作指令對應的操作包括創建定時任務、觸發定時任務的執行、暫停定時任務的執行、重啟定時任務、刪除定時任務、顯示定時任務分析報表、獲取并顯示定時任務的執行進度，以及獲取并顯示定時任務所在任務執行節點的性能指標中的至少一種。