[發明專利]一種Quartz集群定時任務處理系統及方法

有效

• 申請號: 201711370060.2
• 申請日: 2017-12-19
• 公開（公告）號: CN108255592B
• 公開（公告）日: 2020-12-08
• 發明（設計）人: 田付強
• 申請（專利權）人: 武漢市烽視威科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京捷誠信通專利事務所(普通合伙) 11221
• 代理人: 王衛東

一種Quartz集群定時任務處理系統及方法，涉及互聯網在集群環境中處理定時任務領域，方法包括：多個節點依次初始化，每個節點都創建變更監聽，向zookeeper集群注冊，獲取Quartz集群中所有節點信息；當不存在主節點時，重新選出主節點，主節點向zookeeper集群發送同步消息，注冊定時任務，其余節點同步節點信息；當某個節點的節點信息變更時，將變更信息發給zookeeper集群，其余節點接收變更節點信息并同步；發生變更的節點執行變更相應的指令。本發明使時間規則更改方便，確保Quartz集群中定時任務所在節點崩潰后，定時任務能夠正常執行，避免時鐘不同步對不同節點狀態產生的影響。

技術領域

本發明涉及互聯網在集群環境中處理定時任務領域，具體來講涉及一種Quartz集群定時任務處理系統及方法。

背景技術

Quartz是OpenSymphony開源組織在Job scheduling領域又一個開源項目，它可以與J2EE(Java 2 Platform Enterprise Edition，Java2平臺企業版)或J2SE(Java2Standard Edition，java2標準版)應用程序相結合，也可以單獨使用。jobs可以做成標準的Java組件或EJBs。Quartz本身支持集群，但集群基于DB(Database，數據庫)進行實現。對于業務系統，要求集群任務的高可用性，而Quartz自身的集群是基于DB來控制job(定時任務)進行鎖控制，這種方式存在一下幾方面缺陷：

1、由于集群使用同一個DB，時間規則更改不方便，需同步更改DB時間規則描述。

2、Quartz集群中，當執行定時任務的服務器發生崩潰后，運行在該服務器上的定時任務將不能正常執行。

3、Quartz集群中，當定時任務不在同一臺服務器上時(即不在同一個節點)，可能會因為時鐘不同步，而導致該節點對其他節點狀態產生影響。

發明內容

針對現有技術中存在的缺陷，本發明的目的在于提供一種Quartz節點定時任務處理系統及方法，基于zookeeper實現Quartz集群，時間規則更改方便，確保Quartz集群中定時任務所在節點崩潰后，定時任務能夠正常執行，避免時鐘不同步對不同節點狀態產生的影響。

為達到以上目的，本發明采取1.一種Quartz集群定時任務處理系統，包括zookeeper集群以及多個節點，多個節點形成Quartz集群，每個節點包括：

配置加載模塊，其用于加載所有節點的節點信息配置和zookeeper集群連接配置，監聽節點信息配置變更；

任務管理模塊，其用于對其所在節點的定時任務進行注冊、注銷、啟動和停止；

節點管理模塊，其用于把所在節點的節點信息注冊到zookeeper集群，通過zookeeper集群把所述節點信息同步到注冊節點；

選舉模塊，其用于在Quartz集群無主節點的情況，選出一個新的主節點執行定時任務；

控制臺模塊，其用于查看所有節點的定時任務、管理定時任務和查看節點的運行狀態。

在上述技術方案的基礎上，所述節點信息包括節點的基本信息和定時任務信息，所述節點的基本信息包括節點名稱、IP、端口和權重，所述選舉模塊選取的新的主節點是權重最高的節點。

在上述技術方案的基礎上，所述主節點執行的定時任務為節點任務和Quartz集群任務，其他節點執行的定時任務僅為節點任務。

在上述技術方案的基礎上，所述配置加載模塊還用于觸發定時任務重新加載，以及提供定時任務持久化到本地，供所述任務管理模塊調用。

本發明還提供一種Quartz集群定時任務處理方法，基于zookeeper集群以及多個節點，多個所述節點形成Quartz集群，所述方法包括步驟：