（一）吨娜、JobStore接口

??Quartz中的Scheduler調(diào)度器脓匿、Job任務(wù)、Trigger觸發(fā)器在前面都已經(jīng)介紹了萌壳，但是未曾提過(guò)這些數(shù)據(jù)是存放在哪里的亦镶。要知道，就算不進(jìn)行持久化袱瓮，這些信息也應(yīng)該有個(gè)地方進(jìn)行存儲(chǔ)的缤骨。Quartz提供了兩種不同類型的存儲(chǔ)方式，內(nèi)存存儲(chǔ)和數(shù)據(jù)庫(kù)存儲(chǔ)尺借。這兩種方式都是基于org.quartz.spi.JobStore接口來(lái)實(shí)現(xiàn)的绊起。

我們先看一下下面這個(gè)圖，這是從Eclipse上截取的：

clipboard.png

• org.quartz.spi.JobStore 是任務(wù)存儲(chǔ)的頂層接口類
• org.quartz.simpl.RAMJobStore 是內(nèi)存存儲(chǔ)機(jī)制實(shí)現(xiàn)類
• org.quartz.impl.jdbcjobstore.JobStoreSupport 是基于JDBC數(shù)據(jù)庫(kù)存儲(chǔ)的抽象類
• org.quartz.impl.jdbcjobstore.JobStoreCMT 是受應(yīng)用容器管理事務(wù)的數(shù)據(jù)庫(kù)存儲(chǔ)實(shí)現(xiàn)類
• org.quartz.impl.jdbcjobstore.JobStoreTX 是不受應(yīng)用容器事務(wù)管理的數(shù)據(jù)庫(kù)存儲(chǔ)實(shí)現(xiàn)類

??org.quartz.spi.JobStore作為任務(wù)存儲(chǔ)的頂層接口類燎斩，他定義了很多的接口方法虱歪，總共可歸納為四類，調(diào)度器類栅表、任務(wù)類笋鄙、觸發(fā)器類和之前未提到的Calendar日期這一類，Calendar主要是配合觸發(fā)器一起設(shè)置一些特殊的觸發(fā)時(shí)間而使用的怪瓶。在項(xiàng)目開(kāi)發(fā)中萧落，我們無(wú)需調(diào)用JobStore實(shí)現(xiàn)類中的方法，但是了解還是很有必要的洗贰，因?yàn)榭梢宰屛覀冊(cè)陧?xiàng)目應(yīng)用中選擇更加適合的存儲(chǔ)類型找岖。如何框架提供的存儲(chǔ)機(jī)制不能滿足要求，還可以自定義其他的存儲(chǔ)方式敛滋，比如文件系統(tǒng)存儲(chǔ)许布，如果真這么干，那就需求自己實(shí)現(xiàn)JobStore接口绎晃，并且實(shí)現(xiàn)大約40個(gè)接口方法蜜唾，可以參考RAMJobStore類來(lái)看看框架內(nèi)部具體做了什么再去實(shí)現(xiàn)自己的存儲(chǔ)類。

（二）庶艾、JobStore接口的幾種實(shí)現(xiàn)類

??接下來(lái)我們了解一下上圖中提到的幾種存儲(chǔ)方式袁余。

（1）、使用RAMJobStore內(nèi)存存儲(chǔ)數(shù)據(jù)

Quartz默認(rèn)的存儲(chǔ)機(jī)制就是使用內(nèi)存進(jìn)行存儲(chǔ)的落竹，我們先看一下Quartz的jar包中的默認(rèn)配置文件quartz.properties，

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#

org.quartz.scheduler.instanceName = DefaultQuartzScheduler
org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false

org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

org.quartz.jobStore.misfireThreshold = 60000

org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

??主要看org.quartz.jobStore.class這個(gè)屬性货抄，屬性值org.quartz.simpl.RAMJobStore就是內(nèi)存存儲(chǔ)機(jī)制的實(shí)現(xiàn)類述召。如果需要使用別的存儲(chǔ)機(jī)制朱转，那就將此值替換為別的實(shí)現(xiàn)類即可。
??使用內(nèi)存存儲(chǔ)的優(yōu)點(diǎn)是任務(wù)的存儲(chǔ)和讀取的速度極快积暖，和數(shù)據(jù)庫(kù)持久化相比差別還是非常大的藤为，而且框架搭建簡(jiǎn)單，開(kāi)箱即用夺刑。它的缺點(diǎn)是當(dāng)Quartz程序或應(yīng)用程序停止了缅疟，伴隨在內(nèi)存中的數(shù)據(jù)也會(huì)被回收，任務(wù)等數(shù)據(jù)就永久丟失了遍愿。
??使用內(nèi)存存儲(chǔ)時(shí)存淫，注意配置文件中只需要保留基本的線程池配置和jobStore的實(shí)現(xiàn)類等幾個(gè)簡(jiǎn)單的屬性就行。如果使用了實(shí)現(xiàn)類中沒(méi)有的屬性沼填，啟動(dòng)的時(shí)候會(huì)報(bào)錯(cuò)桅咆，當(dāng)然錯(cuò)誤提示也很明顯。這里主要想提醒一下之前已經(jīng)使用了持久化配置坞笙，現(xiàn)在想體驗(yàn)一下內(nèi)存存儲(chǔ)的朋友們岩饼。

（2）、使用數(shù)據(jù)庫(kù)存儲(chǔ)數(shù)據(jù)

??通過(guò)上面的類圖可以看出薛夜，JobStoreTX和JobStoreCMT都是JobStoreSupport抽象類的實(shí)現(xiàn)類籍茧，JobStoreSupport是基于JDBC實(shí)現(xiàn)了一些基本的功能的抽象類。如果想要自己實(shí)現(xiàn)一套關(guān)于JDBC存儲(chǔ)方式梯澜，那么可以繼承此抽象類寞冯。

我們先看一下Quartz支持哪些數(shù)據(jù)庫(kù)：
·Oracle
·MySQL
·Microsoft SQL Server 2000
·HSQLDB
·PostgreSQL
·DB2
·Cloudscape/Derby
·Pointbase
·Informix
·Firebird
。腊徙。简十。等等，總之兼容JDBC驅(qū)動(dòng)的關(guān)系型數(shù)據(jù)庫(kù)都可以撬腾。

??了解了哪些數(shù)據(jù)庫(kù)可以使用螟蝙，接下來(lái)就是創(chuàng)建數(shù)據(jù)庫(kù)了，Quartz提供了各種數(shù)據(jù)庫(kù)的腳本民傻，腳本中有創(chuàng)建表和索引的sql胰默，但是沒(méi)有創(chuàng)建數(shù)據(jù)庫(kù)的sql，需要自己先創(chuàng)建數(shù)據(jù)庫(kù)漓踢，然后執(zhí)行創(chuàng)建表和索引的腳本牵署。腳本的創(chuàng)建已經(jīng)在@一、Quartz集成-下載和安裝章節(jié)中的第三節(jié)講過(guò)喧半，這里不再重復(fù)講述奴迅。

下面介紹一下各個(gè)表的含義：

??表的前綴默認(rèn)都是QRTZ_ 開(kāi)始，我們先了解一下這個(gè)表前綴有什么用暇检。假設(shè)項(xiàng)目中需要有兩套調(diào)度器實(shí)例产阱，我們想分別持久化這兩個(gè)實(shí)例信息，此時(shí)就需要兩套上面的表块仆。為了區(qū)分表名稱构蹬，就在前面加上表前綴。比如：

??org.quartz.jobStore.tablePrefix=QRTZ1_
??org.quartz.jobStore.tablePrefix=QRTZ2_

??QRTZ1_ 和QRTZ2_分別是兩套表的前綴悔据，分別配置在不同的quartz.properties中庄敛，然后根據(jù)兩個(gè)配置文件分別初始化調(diào)度實(shí)例。

數(shù)據(jù)庫(kù)創(chuàng)建好了蜜暑，下面先使用JobStoreTX存儲(chǔ)機(jī)制铐姚，我們接著往下看：

1、JobStoreTX

??TX就是事務(wù)的意思肛捍，此存儲(chǔ)機(jī)制用于Quartz獨(dú)立于應(yīng)用容器的事務(wù)管理隐绵，如果是Tomcat容器管理的數(shù)據(jù)源，那我們定義的事務(wù)也不會(huì)傳播給Quartz框架內(nèi)部拙毫。通俗的講就是不管我們的Service服務(wù)本身業(yè)務(wù)代碼是否執(zhí)行成功依许，只要代碼中調(diào)用了Quartz API的數(shù)據(jù)庫(kù)操作，那任務(wù)狀態(tài)就永久持久化了缀蹄，就算業(yè)務(wù)代碼拋出運(yùn)行時(shí)異常任務(wù)狀態(tài)也不會(huì)回滾到之前的狀態(tài)峭跳。

下面介紹一下使用JobStoreTX配置步驟，所有的配置都是在quartz.properties中完成：

• 第一步配置org.quartz.jobStore.class屬性：

org.quartz.jobStore.class= org.quartz.impl.jdbcjobstore.JobStoreTX

• 第二步配置驅(qū)動(dòng)代理缺前，以Mysql為例：

org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate

下面列出一個(gè)可用的數(shù)據(jù)庫(kù)代理類表格蛀醉，方便大家使用，如果表格中沒(méi)有列出你想要的代理類衅码，那就使用標(biāo)準(zhǔn)的 JDBC 代理：org.quartz.impl.jdbcjobstore.StdDriverDelegate

• 第三步配置數(shù)據(jù)源：

org.quartz.jobStore.dataSource=qzDS
org.quartz.dataSource.qzDS.driver= com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL= jdbc:mysql://localhost:3306/testDB
org.quartz.dataSource.qzDS.user= root
org.quartz.dataSource.qzDS.password= admin
org.quartz.dataSource.qzDS.maxConnection= 20

??這里要注意兩點(diǎn)：
??第一是org.quartz.dataSource.qzDS.URL屬性名末尾的URL字符串必須是大寫拯刁，如果寫成org.quartz.dataSource.qzDS.url ，那初始化調(diào)度實(shí)例時(shí)就會(huì)報(bào)錯(cuò)逝段。

??第二是注意org.quartz.jobStore.dataSource屬性垛玻，這個(gè)屬性的意思是給數(shù)據(jù)源起一個(gè)名字。這里屬性值配置的是“qzDS”奶躯，你也可以配置成別的任意字符串帚桩，比如：“abc”，如果真這么做嘹黔，那就需要將org.quartz.dataSource.qzDS.driver和其他配置的“qzDS”更換為“abc”账嚎，配置：

org.quartz.jobStore.dataSource=abc
org.quartz.dataSource.abc.driver= com.mysql.jdbc.Driver
org.quartz.dataSource.abc.URL= jdbc:mysql://localhost:3306/testDB
org.quartz.dataSource.abc.user= root
org.quartz.dataSource.abc.password= admin
org.quartz.dataSource.abc.maxConnection= 20

??那么Quartz為什么設(shè)計(jì)要org.quartz.jobStore.dataSource屬性呢？
??這個(gè)屬性主要的目的就是在同一個(gè)數(shù)據(jù)庫(kù)中需要使用多套Quartz，一般大家只需要一套數(shù)據(jù)源就可以完成業(yè)務(wù)工作郭蕉，除非有一些特別的需求乏悄。比如SaaS模式下可以對(duì)不同公司的任務(wù)調(diào)度進(jìn)行管理等。

下面提供一個(gè)拿去就能用的配置文件恳不，改一下數(shù)據(jù)源、用戶名和密碼即可：

org.quartz.scheduler.instanceName=DefaultQuartzScheduler

org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount=20
org.quartz.threadPool.threadPriority=5
org.quartz.jobStore.misfireThreshold=60000

org.quartz.jobStore.class= org.quartz.impl.jdbcjobstore.JobStoreTX

org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate

org.quartz.jobStore.tablePrefix=qrtz_
org.quartz.jobStore.dataSource=qzDS

org.quartz.dataSource.qzDS.driver= com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL= jdbc:mysql://localhost:3306/testDB
org.quartz.dataSource.qzDS.user= root
org.quartz.dataSource.qzDS.password= admin
org.quartz.dataSource.qzDS.maxConnection= 20

2开呐、JobStoreCMT

??CMT的全稱是Container Managed Transactions烟勋，表示容器管理事務(wù)，也就是讓應(yīng)用容器托管事務(wù)筐付。這里假設(shè)應(yīng)用容器是Tomcat卵惦，并且項(xiàng)目和Quartz都是使用Tomcat配置的數(shù)據(jù)源，那么項(xiàng)目和Quartz的代碼中就可以共用同一個(gè)事務(wù)瓦戚，不管是業(yè)務(wù)代碼還是Quartz內(nèi)部拋出異常沮尿，Service服務(wù)內(nèi)的所有數(shù)據(jù)操作都會(huì)回滾到原始狀態(tài)。JobStoreCMT和JobStoreTX最大的區(qū)別是JobStoreCMT需要配置兩個(gè)數(shù)據(jù)源较解，一個(gè)是受應(yīng)用容器管理的數(shù)據(jù)源畜疾，還有一個(gè)是不受應(yīng)用容器管理的數(shù)據(jù)源。
??這里需要想一想為什么需要兩個(gè)數(shù)據(jù)源印衔？
??我個(gè)人的理解是不受應(yīng)用容器管理的數(shù)據(jù)源用來(lái)由Quartz內(nèi)部進(jìn)行"增刪改查"啡捶，假如一個(gè)觸發(fā)器已失效，那么Quartz框架內(nèi)部就會(huì)自動(dòng)刪除這個(gè)觸發(fā)器并提交事務(wù)奸焙，而無(wú)需開(kāi)發(fā)人員的項(xiàng)目代碼來(lái)處理瞎暑，全由Quartz內(nèi)部管理。

下面介紹一下使用JobStoreCMT配置步驟与帆，所有的配置都是在quartz.properties中完成：

• 第一步配置org.quartz.jobStore.class屬性：

org.quartz.jobStore.class= org.quartz.impl.jdbcjobstore.JobStoreCMT

• 第二步配置驅(qū)動(dòng)代理了赌，以Mysql為例，其它代理類參考上面表格：

org.quartz.jobStore.driverDelegateClass= org.quartz.impl.jdbcjobstore.StdJDBCDelegate

• 第三步配置兩個(gè)數(shù)據(jù)源：
  第一個(gè)：配置不受應(yīng)用容器管理的數(shù)據(jù)源：

org.quartz.jobStore.nonManagedTXDataSource = qzDS
org.quartz.dataSource.qzDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL = jdbc:mysql://localhost:3306/testDB
org.quartz.dataSource.qzDS.user = root
org.quartz.dataSource.qzDS.password = admin
org.quartz.dataSource.qzDS.maxConnections = 10

?nonManagedTXDataSource就是非管理事務(wù)數(shù)據(jù)源的意思玄糟。

?第二個(gè)：配置受應(yīng)用容器管理的數(shù)據(jù)源：

org.quartz.dataSource.dataSource=myDS
org.quartz.dataSource.jndiURL = jdbc/mysql
org.quartz.dataSource.myDS.jndiAlwaysLookup = DB_JNDI_ALWAYS_LOOKUP
org.quartz.dataSource.myDS.java.naming.factory.initial = org.apache.naming.java.javaURLContextFactory
org.quartz.dataSource.myDS.java.naming.provider.url = http://localhost:8080
org.quartz.dataSource.myDS.java.naming.security.principal = root
org.quartz.dataSource.myDS.java.naming.security.credentials = admin

??注意：配置之前大家可能需要去了解學(xué)習(xí)一下JNDI+應(yīng)用容器（Tomcat等）如何配置數(shù)據(jù)源勿她，本文就不講述如何配置了。

下面解釋一下受應(yīng)用容器管理的數(shù)據(jù)源配置屬性的含義：

• org.quartz.dataSource.NAME.jndiURL
  受應(yīng)用服務(wù)器管理的DataSource的JNDI URL
• org.quartz.dataSource.NAME.java.naming.factory.initial
  JNDI InitialContextFactory的類名稱
• org.quartz.dataSource.NAME.java.naming.provider.url
  連接到JNDI的URL
• org.quartz.dataSource.NAME.java.naming.security.principal
  連接到 JNDI 的用戶名
• org.quartz.dataSource.NAME.java.naming.security.credential
  連接到 JNDI 的用戶憑證密碼

（三）茶凳、如何選擇使用哪種存儲(chǔ)機(jī)制嫂拴？

1、什么情況下使用RAMJobStore內(nèi)存存儲(chǔ)方式呢贮喧？

??根據(jù)開(kāi)發(fā)中的使用經(jīng)驗(yàn)筒狠，發(fā)現(xiàn)有些任務(wù)是隨著項(xiàng)目啟動(dòng)而啟動(dòng)的，就算項(xiàng)目關(guān)閉或系統(tǒng)宕機(jī)箱沦，那也沒(méi)關(guān)系辩恼，因?yàn)轫?xiàng)目重新啟動(dòng)后此任務(wù)又會(huì)隨之啟動(dòng)。如果項(xiàng)目中只存在這類任務(wù)，那么就可以用內(nèi)存存儲(chǔ)灶伊。隨著項(xiàng)目啟動(dòng)有幾種常用的實(shí)現(xiàn)方式疆前，第一種是通過(guò)實(shí)現(xiàn)ServletContextListener監(jiān)聽(tīng)器接口，然后在接口實(shí)現(xiàn)類的contextInitialized()方法中編寫啟動(dòng)Job的硬編碼聘萨；第二種是通過(guò)Quartz的XML配置文件啟動(dòng)任務(wù)竹椒。

2、什么情況下使用JobStoreTX數(shù)據(jù)庫(kù)存儲(chǔ)方式呢米辐？

??第一篇文章@一胸完、Quartz集成-下載和安裝中的配置就用到了JobStoreTX，那個(gè)配置文件是我在實(shí)際開(kāi)發(fā)中使用的翘贮，使用這種存儲(chǔ)方式的情況很多赊窥。使用這種方式需要注意的是，如果在一個(gè)Service服務(wù)中需要?jiǎng)?chuàng)建一個(gè)Job狸页，那么請(qǐng)把創(chuàng)建Job的代碼編寫在服務(wù)代碼的最后面锨能，確保業(yè)務(wù)代碼運(yùn)行成功并且沒(méi)有拋異常再去啟動(dòng)Job，如果啟動(dòng)Job失敗的時(shí)候請(qǐng)拋出一個(gè)運(yùn)行時(shí)異常使業(yè)務(wù)代碼進(jìn)行回滾芍耘。
例子：

@Transactional
public void demoService(TaskStore taskStore) {
    // 先執(zhí)行插入業(yè)務(wù)操作
    taskStoreService.insert(taskStore);

    // 再執(zhí)行更新業(yè)務(wù)操作
    taskDetailService.update(taskDetail);

    // 最后啟動(dòng)定時(shí)任務(wù)
    QuartzUtils.addJob("testName", DemoJob.class, "0 * * * * * ?");
}

??注意例子中的addJob()方法中捕獲了異常后進(jìn)行重新封裝再拋出運(yùn)行時(shí)異常的址遇，目的是Quartz內(nèi)部錯(cuò)誤時(shí)確保業(yè)務(wù)代碼回滾。

3斋竞、什么情況下使用JobStoreCMT數(shù)據(jù)庫(kù)存儲(chǔ)方式呢傲隶？

??JobStoreCMT和JobStoreTX的區(qū)別前文已經(jīng)介紹了，在實(shí)際開(kāi)發(fā)的過(guò)程中我還沒(méi)有在項(xiàng)目中使用過(guò)此種方式窃页。一般情況下都是使用的JobStoreTX跺株。如果大家的項(xiàng)目中有著嚴(yán)格的事務(wù)管理，那么建議使用JobStoreCMT存儲(chǔ)方式脖卖。

到此乒省，Quartz的持久化和配置管理說(shuō)完了。如果大家有什么問(wèn)題畦木，請(qǐng)?jiān)谙路搅粞孕淇福x謝！