定时组件quartz系列<二>quartz的集群原理

1、基本信息：

Quartz是一个开源的作业调度框架，它完全由java写成，并设计用于J2Se和J2EE应用中。它提供了巨大的灵活性而不牺牲简单性。你能够用它 来为执行一个作业而创建简单的或复杂的调度。它有很多特征，如：数据库支持，集群，插件，EJB作业预构建，JavaMail及其它，支持cron- like表达式等等。其中集群配置一般比较复杂，那么在Quartz中如何配置它的集群特性呢？

2 Quartz的集群配置：
2.1 实现集群的基本原理
Quartz是通过借助关系数据库和JDBC作业存储来实现集群管理的。







--触发器与任务关联表



--调度器状态表



2.2 集群配置
通
过设置"org.quartz.jobStore.isClustered"属性为"true"来激活集群特性。在集群中的每一个实例都必须有一
个唯一的"instance id" ("org.quartz.scheduler.instanceId" 属性),
但是应该有相同的"scheduler instance name"
("org.quartz.scheduler.instanceName")，也就是说集群中的每一个实例都必须使用相同的
quartz.properties 配置文件。除了以下几种例外，配置文件的内容其他都必须相同：
 不同的线程池大小，

 不同的"org.quartz.scheduler.instanceId"属性值（这个可以很容易做到，设定为"AUTO"即可）。

 注意:
永远不要在不同的机器上运行集群，除非他们的时钟是使用某种形式的同步服务（守护）非常有规律的运行（时钟必须在一分一秒内）来达到同步。还有:
永远不要触发一个非集群的实例，如果其他的实例正在同一个数据库表上运行。你将使你的数据严重腐蚀，出现非预期行为。

 示例及详细配置说明，请参照附录Quartz配置文件说明。

3 附录
3.1 Quartz配置文件说明
3.1.1 Quartz配置文件基本说明
3.1.2 Quartz配置文件详细说明
3.1.2.1 Scheduler主要属性的配置





3.1.2.2 线程池（ThreadPool）的配置





3.1.2.3 任务存储（JobStore）的配置









3.1.2.4 数据源的配置


上面显示了两种数据源定义方式：一个数据源可以用给定的数据库连接信息创建，也可以是利用应用服务器管理生成的JNDI数据源的逻辑映射。





3.1.2.5 Scheduler插件的配置



配置插件的简单示例：


3.1.3 示例



附件：创建数据库：

[sql] view plain copy





DROP TABLE IF EXISTS QRTZ_JOB_LISTENERS;

DROP TABLE IF EXISTS QRTZ_TRIGGER_LISTENERS;

DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;

DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;

DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;

DROP TABLE IF EXISTS QRTZ_LOCKS;

DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;

DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;

DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;

DROP TABLE IF EXISTS QRTZ_TRIGGERS;

DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;

DROP TABLE IF EXISTS QRTZ_CALENDARS;

CREATE TABLE QRTZ_JOB_DETAILS

(

JOB_NAME VARCHAR(200) NOT NULL,

JOB_GROUP VARCHAR(200) NOT NULL,

DESCRIPTION VARCHAR(250) NULL,

JOB_CLASS_NAME VARCHAR(250) NOT NULL,

IS_DURABLE VARCHAR(1) NOT NULL,

IS_VOLATILE VARCHAR(1) NOT NULL,

IS_STATEFUL VARCHAR(1) NOT NULL,

REQUESTS_RECOVERY VARCHAR(1) NOT NULL,

JOB_DATA BLOB NULL,

PRIMARY KEY (JOB_NAME,JOB_GROUP)

);

CREATE TABLE QRTZ_JOB_LISTENERS

(

JOB_NAME VARCHAR(200) NOT NULL,

JOB_GROUP VARCHAR(200) NOT NULL,

JOB_LISTENER VARCHAR(200) NOT NULL,

PRIMARY KEY (JOB_NAME,JOB_GROUP,JOB_LISTENER),

FOREIGN KEY (JOB_NAME,JOB_GROUP)

REFERENCES QRTZ_JOB_DETAILS(JOB_NAME,JOB_GROUP)

);

CREATE TABLE QRTZ_TRIGGERS

(

TRIGGER_NAME VARCHAR(200) NOT NULL,

TRIGGER_GROUP VARCHAR(200) NOT NULL,

JOB_NAME VARCHAR(200) NOT NULL,

JOB_GROUP VARCHAR(200) NOT NULL,

IS_VOLATILE VARCHAR(1) NOT NULL,

DESCRIPTION VARCHAR(250) NULL,

NEXT_FIRE_TIME BIGINT(13) NULL,

PREV_FIRE_TIME BIGINT(13) NULL,

PRIORITY INTEGER NULL,

TRIGGER_STATE VARCHAR(16) NOT NULL,

TRIGGER_TYPE VARCHAR(8) NOT NULL,

START_TIME BIGINT(13) NOT NULL,

END_TIME BIGINT(13) NULL,

CALENDAR_NAME VARCHAR(200) NULL,

MISFIRE_INSTR SMALLINT(2) NULL,

JOB_DATA BLOB NULL,

PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),

FOREIGN KEY (JOB_NAME,JOB_GROUP)

REFERENCES QRTZ_JOB_DETAILS(JOB_NAME,JOB_GROUP)

);

CREATE TABLE QRTZ_SIMPLE_TRIGGERS

(

TRIGGER_NAME VARCHAR(200) NOT NULL,

TRIGGER_GROUP VARCHAR(200) NOT NULL,

REPEAT_COUNT BIGINT(7) NOT NULL,

REPEAT_INTERVAL BIGINT(12) NOT NULL,

TIMES_TRIGGERED BIGINT(7) NOT NULL,

PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),

FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)

REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP)

);

CREATE TABLE QRTZ_CRON_TRIGGERS

(

TRIGGER_NAME VARCHAR(200) NOT NULL,

TRIGGER_GROUP VARCHAR(200) NOT NULL,

CRON_EXPRESSION VARCHAR(200) NOT NULL,

TIME_ZONE_ID VARCHAR(80),

PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),

FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)

REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP)

);

CREATE TABLE QRTZ_BLOB_TRIGGERS

(

TRIGGER_NAME VARCHAR(200) NOT NULL,

TRIGGER_GROUP VARCHAR(200) NOT NULL,

BLOB_DATA BLOB NULL,

PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),

FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)

REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP)

);

CREATE TABLE QRTZ_TRIGGER_LISTENERS

(

TRIGGER_NAME VARCHAR(200) NOT NULL,

TRIGGER_GROUP VARCHAR(200) NOT NULL,

TRIGGER_LISTENER VARCHAR(200) NOT NULL,

PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_LISTENER),

FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)

REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP)

);

CREATE TABLE QRTZ_CALENDARS

(

CALENDAR_NAME VARCHAR(200) NOT NULL,

CALENDAR BLOB NOT NULL,

PRIMARY KEY (CALENDAR_NAME)

);

CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS

(

TRIGGER_GROUP VARCHAR(200) NOT NULL,

PRIMARY KEY (TRIGGER_GROUP)

);

CREATE TABLE QRTZ_FIRED_TRIGGERS

(

ENTRY_ID VARCHAR(95) NOT NULL,

TRIGGER_NAME VARCHAR(200) NOT NULL,

TRIGGER_GROUP VARCHAR(200) NOT NULL,

IS_VOLATILE VARCHAR(1) NOT NULL,

INSTANCE_NAME VARCHAR(200) NOT NULL,

FIRED_TIME BIGINT(13) NOT NULL,

PRIORITY INTEGER NOT NULL,

STATE VARCHAR(16) NOT NULL,

JOB_NAME VARCHAR(200) NULL,

JOB_GROUP VARCHAR(200) NULL,

IS_STATEFUL VARCHAR(1) NULL,

REQUESTS_RECOVERY VARCHAR(1) NULL,

PRIMARY KEY (ENTRY_ID)

);

CREATE TABLE QRTZ_SCHEDULER_STATE

(

INSTANCE_NAME VARCHAR(200) NOT NULL,

LAST_CHECKIN_TIME BIGINT(13) NOT NULL,

CHECKIN_INTERVAL BIGINT(13) NOT NULL,

PRIMARY KEY (INSTANCE_NAME)

);

CREATE TABLE QRTZ_LOCKS

(

LOCK_NAME VARCHAR(40) NOT NULL,

PRIMARY KEY (LOCK_NAME)

);

INSERT INTO QRTZ_LOCKS values('TRIGGER_ACCESS');

INSERT INTO QRTZ_LOCKS values('JOB_ACCESS');

INSERT INTO QRTZ_LOCKS values('CALENDAR_ACCESS');

INSERT INTO QRTZ_LOCKS values('STATE_ACCESS');

INSERT INTO QRTZ_LOCKS values('MISFIRE_ACCESS');

commit;