[發(fā)明專利]一種Quartz集群定時(shí)任務(wù)處理系統(tǒng)及方法

有效

• 申請?zhí)枺?/td>: 201711370060.2
• 申請日: 2017-12-19
• 公開（公告）號: CN108255592B
• 公開（公告）日: 2020-12-08
• 發(fā)明（設(shè)計(jì)）人: 田付強(qiáng)
• 申請（專利權(quán)）人: 武漢市烽視威科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京捷誠信通專利事務(wù)所(普通合伙) 11221
• 代理人: 王衛(wèi)東

1.一種Quartz集群定時(shí)任務(wù)處理系統(tǒng)，其特征在于，包括zookeeper集群以及多個(gè)節(jié)點(diǎn)，多個(gè)節(jié)點(diǎn)形成Quartz集群，每個(gè)節(jié)點(diǎn)包括：

配置加載模塊，其用于加載所有節(jié)點(diǎn)的節(jié)點(diǎn)信息配置和zookeeper集群連接配置，監(jiān)聽節(jié)點(diǎn)信息配置變更；

任務(wù)管理模塊，其用于對其所在節(jié)點(diǎn)的定時(shí)任務(wù)進(jìn)行注冊、注銷、啟動和停止；

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

選舉模塊，其用于在Quartz集群無主節(jié)點(diǎn)的情況，選出一個(gè)新的主節(jié)點(diǎn)執(zhí)行定時(shí)任務(wù)；

控制臺模塊，其用于查看所有節(jié)點(diǎn)的定時(shí)任務(wù)、管理定時(shí)任務(wù)和查看節(jié)點(diǎn)的運(yùn)行狀態(tài)；

Quartz集群中只存在一個(gè)主節(jié)點(diǎn)，所述主節(jié)點(diǎn)執(zhí)行的定時(shí)任務(wù)為節(jié)點(diǎn)任務(wù)和Quartz集群任務(wù)，其他節(jié)點(diǎn)執(zhí)行的定時(shí)任務(wù)僅為節(jié)點(diǎn)任務(wù)。

2.如權(quán)利要求1所述的Quartz集群定時(shí)任務(wù)處理系統(tǒng)，其特征在于：所述節(jié)點(diǎn)信息包括節(jié)點(diǎn)的基本信息和定時(shí)任務(wù)信息，所述節(jié)點(diǎn)的基本信息包括節(jié)點(diǎn)名稱、IP、端口和權(quán)重，所述選舉模塊選取的新的主節(jié)點(diǎn)是權(quán)重最高的節(jié)點(diǎn)。

3.如權(quán)利要求1所述的Quartz集群定時(shí)任務(wù)處理系統(tǒng)，其特征在于：所述配置加載模塊還用于觸發(fā)定時(shí)任務(wù)重新加載，以及提供定時(shí)任務(wù)持久化到本地，供所述任務(wù)管理模塊調(diào)用。

4.一種Quartz集群定時(shí)任務(wù)處理方法，其特征在于，基于zookeeper集群以及多個(gè)節(jié)點(diǎn)，多個(gè)所述節(jié)點(diǎn)形成Quartz集群，所述方法包括步驟：

多個(gè)節(jié)點(diǎn)依次初始化并連接zookeeper集群，每個(gè)節(jié)點(diǎn)都創(chuàng)建節(jié)點(diǎn)信息變更監(jiān)聽，向zookeeper集群注冊節(jié)點(diǎn)信息，并獲取Quartz集群中所有已注冊節(jié)點(diǎn)的節(jié)點(diǎn)信息；

當(dāng)Quartz集群中不存在主節(jié)點(diǎn)時(shí)，重新選出主節(jié)點(diǎn)，主節(jié)點(diǎn)向zookeeper集群發(fā)送同步消息，并向調(diào)度工廠注冊定時(shí)任務(wù)，其余節(jié)點(diǎn)根據(jù)zookeeper集群同步節(jié)點(diǎn)信息；

當(dāng)某個(gè)節(jié)點(diǎn)的節(jié)點(diǎn)信息變更時(shí)，該節(jié)點(diǎn)將變更信息發(fā)給zookeeper集群，其余節(jié)點(diǎn)從zookeeper集群中接收變更節(jié)點(diǎn)的節(jié)點(diǎn)信息并同步；同時(shí)，發(fā)生變更的節(jié)點(diǎn)執(zhí)行所述變更相應(yīng)的指令，并把變更后的定時(shí)任務(wù)持久化到本地；

Quartz集群中只存在一個(gè)主節(jié)點(diǎn)，當(dāng)Quartz集群中不存在主節(jié)點(diǎn)時(shí)，選取所有注冊節(jié)點(diǎn)中權(quán)重最高的節(jié)點(diǎn)為主節(jié)點(diǎn)，所述主節(jié)點(diǎn)執(zhí)行的定時(shí)任務(wù)為節(jié)點(diǎn)任務(wù)和Quartz集群任務(wù)，其他節(jié)點(diǎn)執(zhí)行的定時(shí)任務(wù)僅為節(jié)點(diǎn)任務(wù)。

5.如權(quán)利要求4所述的Quartz集群定時(shí)任務(wù)處理方法，其特征在于：每個(gè)節(jié)點(diǎn)初始化包括加載所有節(jié)點(diǎn)的節(jié)點(diǎn)基本信息配置和zookeeper集群連接配置，所述節(jié)點(diǎn)信息包括節(jié)點(diǎn)的基本信息和定時(shí)任務(wù)信息，所述節(jié)點(diǎn)的基本信息包括節(jié)點(diǎn)名稱、IP、端口和權(quán)重。

6.如權(quán)利要求4所述的Quartz集群定時(shí)任務(wù)處理方法，其特征在于：每個(gè)節(jié)點(diǎn)向zookeeper集群注冊該節(jié)點(diǎn)信息時(shí)，如果zookeeper集群存在根節(jié)點(diǎn)，則該節(jié)點(diǎn)作為增加在根節(jié)點(diǎn)下的子節(jié)點(diǎn)；如果zookeeper集群不存在根節(jié)點(diǎn)，則創(chuàng)建根節(jié)點(diǎn)，并且該節(jié)點(diǎn)作為創(chuàng)建根節(jié)點(diǎn)下的子節(jié)點(diǎn)。

7.如權(quán)利要求4-6任一項(xiàng)所述的Quartz集群定時(shí)任務(wù)處理方法，其特征在于：當(dāng)主節(jié)點(diǎn)脫離Quartz集群，則注銷該主節(jié)點(diǎn)的定時(shí)任務(wù)，更新該主節(jié)點(diǎn)的狀態(tài)為不可用，并在其注冊結(jié)點(diǎn)中選取主節(jié)點(diǎn)。

8.如權(quán)利要求7所述的Quartz集群定時(shí)任務(wù)處理方法，其特征在于：所述定時(shí)任務(wù)的變更包括對節(jié)點(diǎn)進(jìn)行修改、增加和刪除；所述變更相應(yīng)的指令包括定時(shí)任務(wù)進(jìn)行注冊、注銷、啟動和停止。