|
1 基本信息
摘要：Quartz是一個(gè)開源的作業(yè)調(diào)度框架，它完全由java寫成，并設(shè)計(jì)用于J2SE和J2EE應(yīng)用中。它提供了巨大的靈活性而不犧牲簡單性。你能夠用它來為執(zhí)行一個(gè)作業(yè)而創(chuàng)建簡單的或復(fù)雜的調(diào)度。它有很多特征，如：數(shù)據(jù)庫支持，集群，插件，EJB作業(yè)預(yù)構(gòu)建，JavaMail及其它，支持cron-like表達(dá)式等等。其中集群配置一般比較復(fù)雜，那么在Quartz中如何配置它的集群特性呢？
作者：武玉厚
查看本文第二部分：http://gocom./modules/newbb/forumtopic19180_9963_40.htm
2 Quartz的集群配置
Quartz是一個(gè)開源的作業(yè)調(diào)度框架，它完全由java寫成，并設(shè)計(jì)用于J2SE和J2EE應(yīng)用中。它提供了巨大的靈活性而不犧牲簡單性。你能夠用它來為執(zhí)行一個(gè)作業(yè)而創(chuàng)建簡單的或復(fù)雜的調(diào)度。它有很多特征，如：數(shù)據(jù)庫支持，集群，插件，EJB作業(yè)預(yù)構(gòu)建，JavaMail及其它，支持cron-like表達(dá)式等等。其中集群配置一般比較復(fù)雜，那么在Quartz中如何配置它的集群特性呢？
2.1 實(shí)現(xiàn)集群的基本原理
目前Quartz最新版本是1.6.0。Quartz是通過借助關(guān)系數(shù)據(jù)庫和JDBC作業(yè)存儲(chǔ)來實(shí)現(xiàn)集群管理的。
1. 原理
集群通過故障切換和負(fù)載平衡的功能，能給調(diào)度器帶來高可用性和伸縮性。目前集群只能工作在JDBC-Jobstore (JobStoreTX 或者JobStoreCMT)方式下，從本質(zhì)上來說，是使集群上的每一個(gè)節(jié)點(diǎn)通過共享同一個(gè)數(shù)據(jù)庫來工作的（Quartz通過啟動(dòng)兩個(gè)維護(hù)線程來維護(hù)數(shù)據(jù)庫狀態(tài)實(shí)現(xiàn)集群管理，一個(gè)是檢測節(jié)點(diǎn)狀態(tài)線程，一個(gè)是恢復(fù)任務(wù)線程）。
負(fù)載平衡是自動(dòng)完成的，集群的每個(gè)節(jié)點(diǎn)會(huì)盡快觸發(fā)任務(wù)。當(dāng)一個(gè)觸發(fā)器的觸發(fā)時(shí)間到達(dá)時(shí)，第一個(gè)節(jié)點(diǎn)將會(huì)獲得任務(wù)（通過鎖定），成為執(zhí)行任務(wù)的節(jié)點(diǎn)。
故障切換的發(fā)生是在當(dāng)一個(gè)節(jié)點(diǎn)正在執(zhí)行一個(gè)或者多個(gè)任務(wù)失敗的時(shí)候。當(dāng)一個(gè)節(jié)點(diǎn)失敗了，其他的節(jié)點(diǎn)會(huì)檢測到并且標(biāo)識(shí)在失敗節(jié)點(diǎn)上正在進(jìn)行的數(shù)據(jù)庫中的任務(wù)。任何被標(biāo)記為可恢復(fù)（任務(wù)詳細(xì)信息的"requests recovery"屬性）的任務(wù)都會(huì)被其他的節(jié)點(diǎn)重新執(zhí)行。沒有標(biāo)記可恢復(fù)的任務(wù)只會(huì)被釋放出來，將會(huì)在下次相關(guān)觸發(fā)器觸發(fā)時(shí)執(zhí)行。
2. 集群管理用到的表
--任務(wù)詳細(xì)信息表
- CREATE TABLE qrtz_job_details
- (
- JOB_NAME VARCHAR2(80) NOT NULL,
- JOB_GROUP VARCHAR2(80) NOT NULL,
- DESCRIPTION VARCHAR2(120) NULL,
- JOB_CLASS_NAME VARCHAR2(128) NOT NULL,
- IS_DURABLE VARCHAR2(1) NOT NULL,
- IS_VOLATILE VARCHAR2(1) NOT NULL,
- IS_STATEFUL VARCHAR2(1) NOT NULL,
- REQUESTS_RECOVERY VARCHAR2(1) NOT NULL, --可恢復(fù)標(biāo)記
- JOB_DATA BLOB NULL,
- PRIMARY KEY (JOB_NAME,JOB_GROUP)
- );
--觸發(fā)器與任務(wù)關(guān)聯(lián)表
- CREATE TABLE qrtz_fired_triggers
- (
- ENTRY_ID VARCHAR2(95) NOT NULL,
- TRIGGER_NAME VARCHAR2(80) NOT NULL,
- TRIGGER_GROUP VARCHAR2(80) NOT NULL,
- IS_VOLATILE VARCHAR2(1) NOT NULL,
- INSTANCE_NAME VARCHAR2(80) NOT NULL,
- FIRED_TIME NUMBER(13) NOT NULL,
- STATE VARCHAR2(16) NOT NULL,
- JOB_NAME VARCHAR2(80) NULL,
- JOB_GROUP VARCHAR2(80) NULL,
- IS_STATEFUL VARCHAR2(1) NULL,
- REQUESTS_RECOVERY VARCHAR2(1) NULL, --可恢復(fù)標(biāo)記
- PRIMARY KEY (ENTRY_ID)
- );
--調(diào)度器狀態(tài)表
- TABLE qrtz_scheduler_state
- (
- INSTANCE_NAME VARCHAR2(80) NOT NULL, --調(diào)度器實(shí)例ID
- LAST_CHECKIN_TIME NUMBER(13) NOT NULL, --上次檢查時(shí)間
- CHECKIN_INTERVAL NUMBER(13) NOT NULL, --檢查時(shí)間間隔
- RECOVERER VARCHAR2(80) NULL, --恢復(fù)調(diào)度器
- PRIMARY KEY (INSTANCE_NAME)
- );
2.2 集群配置
通過設(shè)置"org.quartz.jobStore.isClustered"屬性為"true"來激活集群特性。在集群中的每一個(gè)實(shí)例都必須有一個(gè)唯一的"instance id" ("org.quartz.scheduler.instanceId" 屬性), 但是應(yīng)該有相同的"scheduler instance name" ("org.quartz.scheduler.instanceName")，也就是說集群中的每一個(gè)實(shí)例都必須使用相同的quartz.properties 配置文件。除了以下幾種例外，配置文件的內(nèi)容其他都必須相同：
不同的線程池大小，
不同的"org.quartz.scheduler.instanceId"屬性值（這個(gè)可以很容易做到，設(shè)定為"AUTO"即可）。
注意: 永遠(yuǎn)不要在不同的機(jī)器上運(yùn)行集群，除非他們的時(shí)鐘是使用某種形式的同步服務(wù)（守護(hù)）非常有規(guī)律的運(yùn)行（時(shí)鐘必須在一分一秒內(nèi)）來達(dá)到同步。還有: 永遠(yuǎn)不要觸發(fā)一個(gè)非集群的實(shí)例，如果其他的實(shí)例正在同一個(gè)數(shù)據(jù)庫表上運(yùn)行。你將使你的數(shù)據(jù)嚴(yán)重腐蝕，出現(xiàn)非預(yù)期行為。
示例及詳細(xì)配置說明，請參照附錄Quartz配置文件說明。
3 附錄
3.1 Quartz配置文件說明
3.1.1 Quartz配置文件基本說明
文件名稱：默認(rèn)文件名稱quartz.properties，可以通過更改系統(tǒng)屬性“org.quartz.properties”來加載自定義的配置。
格式：屬性文件
3.1.2 Quartz配置文件詳細(xì)說明
3.1.2.1 Scheduler主要屬性的配置
- # Scheduler主要屬性的一般定義模式如下：
- #
- # org.quartz.scheduler.instanceName = SCHED_NAME
- # org.quartz.scheduler.instanceId = INSTANCE_ID
- # org.quartz.scheduler.threadName = THREAD_NAME
- # org.quartz.scheduler.rmi.export = false
- # org.quartz.scheduler.rmi.proxy = false
- # org.quartz.scheduler.rmi.registryHost = localhost
- # org.quartz.scheduler.rmi.registryPort = 1099
- # org.quartz.scheduler.rmi.createRegistry = never
- # org.quartz.scheduler.userTransactionURL = USER_TX_LOCATION
- # org.quartz.scheduler.wrapJobExecutionInUserTransaction = JOBS_IN_USER_TX
- # org.quartz.scheduler.idleWaitTime = IDLE_WAIT_TIME
- # org.quartz.scheduler.dbFailureRetryInterval = DB_FAILURE_RETRY_INTERVAL
- # org.quartz.scheduler.classLoadHelper.class = CLASS_LOAD_HELPER_CLASS
- # org.quartz.context.key.SOME_KEY = SOME_VALUE
下面是具體說明：
3.1.2.2 線程池（ThreadPool）的配置
下面是具體說明：
- # 定制一個(gè)線程池的一般模式如下：
- #
- # org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
- # org.quartz.threadPool.threadCount = THREAD_COUNT
- # org.quartz.threadPool.threadPriority = THREAD_PRIO
- #
- # 簡單線程池（SimpleThreadPool）的選項(xiàng)參數(shù)：
- #
- # org.quartz.threadPool.makeThreadsDaemons = DAEMON_THREADS
- # org.quartz.threadPool.threadsInheritGroupOfInitializingThread = INHERIT_GRP
- # org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = INHERIT_LDR
- #
- # or
- #
- # org.quartz.threadPool.class = com.mycompany.goo.FooThreadPool
- # org.quartz.threadPool.somePropOfFooThreadPool = someValue
- #
查看本文第二部分：http://gocom./modules/newbb/forumtopic19180_9963_40.htm
|
