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

有效

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

1.一種定時任務的分布式調用系統，其特征在于，包括：

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

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

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

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

2.根據權利要求1所述的系統，其特征在于，所述任務執行監控接口包括Console可視化操作平臺和/或監控應用程序編程接口API，服務器節點用于根據通過Console可視化操作平臺或監控API接收到的所述操作指令，執行與所述操作指令對應的操作。

3.根據權利要求2所述的系統，其特征在于，所述與所述操作指令對應的操作包括創建定時任務、觸發定時任務的執行、暫停定時任務的執行、重啟定時任務、刪除定時任務、顯示定時任務分析報表、獲取并顯示定時任務的執行進度，以及獲取并顯示定時任務所在任務執行節點的性能指標中的至少一種。

4.根據權利要求2所述的系統，其特征在于，所述Console可視化操作平臺還用于在定時任務的執行過程中檢測到異常問題時進行告警。

5.根據權利要求1所述的系統，其特征在于，所述定時任務包括本地定時任務或遠程定時任務；

所述確定狀態信息為可用狀態的一個服務器節點或客戶端節點，作為任務執行節點，包括：

若根據所述任務注冊信息確定定時任務為本地定時任務且為指定客戶端節點執行，則確定所述指定客戶端節點為任務執行節點；

若根據所述任務注冊信息確定定時任務為本地定時任務且為服務器節點執行，則從所述多個服務器節點中確定狀態信息為可用狀態的一個服務器節點，作為任務執行節點；

若根據所述任務注冊信息確定定時任務為遠程定時任務，則確定所述定時任務對應的客戶端集群標識，并從所述客戶端集群標識對應的多個客戶端節點中確定一個狀態信息為可用狀態的客戶端節點，作為任務執行節點。

6.根據權利要求5所述的系統，其特征在于，所述ZooKeeper集群還用于：在服務器節點處于不可用狀態時，將該服務器節點作為第一服務器節點，觸發對所述第一服務器節點中的定時任務的重新分配指令；

所述服務器集群中的其他服務器節點還用于：若接收到所述ZooKeeper集群觸發的對所述第一服務器節點中的定時任務的重新分配指令，則從MongoDB集群中確定所述第一服務器節點對應的遠程定時任務，并重新創建所述定時任務，對重新創建的遠程定時任務進行調度。

7.根據權利要求5所述的系統，其特征在于，所述服務器節點還用于：

在將指定客戶端節點作為任務執行節點時，若根據心跳信息確定任務執行節點處于不可用狀態時，標記定時任務的執行進度，并在任務執行節點恢復可用狀態時，將所述定時任務的執行進度發送至所述任務執行節點，由所述任務執行節點從所述執行進度開始執行所述定時任務。