Quartz cluster timed task processing system and method

Abstract

The invention discloses a Quartz cluster timed task processing system and method and relates to the field of timed task processing in a cluster environment through the Internet. The method comprises the steps that multiple nodes are sequentially initialized, each node creates a change monitor and makes registration to a zookeeper cluster, and all node information in a Quartz cluster is acquired; when a master node is not available, a master node is reselected, the master node sends a synchronization message to the zookeeper cluster and registers a timed task, and the remaining nodes synchronize the node information; when the node information of a certain node is changed, the changed information is sent to the zookeeper cluster, and the remaining nodes receive the changed node information and perform synchronization; and the changed node changes a corresponding instruction. Through the processing system and method, time rules are convenient to change, it is ensured that the timed task can be normally executed after the node, where the timed task is located, in the Quartz cluster is in crash, and the influence of clock non-synchronization on different node states is avoided.

Description

Technical field [0001] The invention relates to the field of Internet processing timing tasks in a cluster environment, in particular to a Quartz cluster timing task processing system and method. Background technique [0002] Quartz is another open source project of the OpenSymphony open source organization in the field of Job scheduling. It can be combined with J2EE (Java 2 Platform Enterprise Edition) or J2SE (Java 2 Standard Edition, java2 Standard Edition) applications, or it can be used alone. Jobs can be made into standard Java components or EJBs. Quartz itself supports clusters, but clusters are implemented based on DB (Database). For business systems, high availability of cluster tasks is required, and Quartz's own cluster is based on DB to control jobs (timed tasks) for lock control. This approach has the following defects: [0003] 1. Because the cluster uses the same DB, it is inconvenient to change the time rule, and the DB time rule description needs to be changed sy...

AI Technical Summary

Problems solved by technology

[0003] 1. Since the cluster uses the same DB, it is inconvenient to change the time rule, and the DB time rule description needs to be changed synchronously

[0004] 2. In the Quartz cluster, when the server executing the scheduled task crashes, the scheduled task running on the server will not be able to execute normally

[0005] 3. In the Quartz cluster, when the timing task is not on the same server (that is, not on the same node), the node may affect the status of other nodes because the clock is not synchronized.

Images