前言
為了保證應用的高可用和高并發(fā)性，一般都會部署多個節(jié)點；對于定時任務，如果每個節(jié)點都執(zhí)行自己的定時任務，一方面耗費了系統(tǒng)資源，
另一方面有些任務多次執(zhí)行，可能引發(fā)應用邏輯問題，所以需要一個分布式的調(diào)度系統(tǒng)，來協(xié)調(diào)每個節(jié)點執(zhí)行定時任務。
spring整合quartz
quartz是一個成熟的任務調(diào)度系統(tǒng)，spring對quartz做了兼容，方便開發(fā)，下面看看具體如何整合：
1.maven依賴文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
<dependencies> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-core</artifactid> <version>4.3.5.release</version> </dependency> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-context-support</artifactid> <version>4.3.5.release</version> </dependency> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-tx</artifactid> <version>4.3.5.release</version> </dependency> <dependency> <groupid>org.springframework</groupid> <artifactid>spring-jdbc</artifactid> <version>4.3.5.release</version> </dependency> <dependency> <groupid>org.quartz-scheduler</groupid> <artifactid>quartz</artifactid> <version>2.2.3</version> </dependency> <dependency> <groupid>mysql</groupid> <artifactid>mysql-connector-java</artifactid> <version>5.1.29</version> </dependency> </dependencies> |
主要就是spring相關庫、quartz庫以及mysql驅(qū)動庫，注：分布式調(diào)度需要用到數(shù)據(jù)庫，這里選用mysql；
2.配置job
提供了兩種方式來配置job，分別是：methodinvokingjobdetailfactorybean和jobdetailfactorybean
2.1methodinvokingjobdetailfactorybean
要調(diào)用特定bean的一個方法的時候使用，具體配置如下：
|
1
2
3
4
|
<bean id="firsttask" class="org.springframework.scheduling.quartz.methodinvokingjobdetailfactorybean"> <property name="targetobject" ref="firstservice" /> <property name="targetmethod" value="service" /> </bea> |
2.2jobdetailfactorybean
這種方式更加靈活，可以設置傳遞參數(shù)，具體如下：
|
1
2
3
4
5
6
7
8
9
|
<bean id="firsttask" class="org.springframework.scheduling.quartz.jobdetailfactorybean"> <property name="jobclass" value="zh.maven.squartz.task.firsttask" /> <property name="jobdatamap"> <map> <entry key="firstservice" value-ref="firstservice" /> </map> </property></bean> |
jobclass定義的任務類，繼承quartzjobbean，實現(xiàn)executeinternal方法；jobdatamap用來給job傳遞數(shù)據(jù)
3.配置調(diào)度使用的觸發(fā)器
同樣提供了兩種觸發(fā)器類型：simpletriggerfactorybean和crontriggerfactorybean
重點看crontriggerfactorybean，這種類型更加靈活，具體如下：
|
1
2
3
4
5
|
<bean id="firstcrontrigger" class="org.springframework.scheduling.quartz.crontriggerfactorybean"> <property name="jobdetail" ref="firsttask" /> <property name="cronexpression" value="0/5 * * ? * *" /> </bean> |
jobdetail指定的就是在步驟2中配置的job，cronexpression配置了每5秒執(zhí)行一次job；
4.配置quartz調(diào)度器的schedulerfactorybean
同樣提供了兩種方式：內(nèi)存ramjobstore和數(shù)據(jù)庫方式
4.1內(nèi)存ramjobstore
job的相關信息存儲在內(nèi)存里，每個節(jié)點存儲各自的，互相隔離，配置如下：
|
1
2
3
4
5
6
7
|
<bean class="org.springframework.scheduling.quartz.schedulerfactorybean"> <property name="triggers"> <list> <ref bean="firstcrontrigger" /> </list> </property> </bean> |
4.2數(shù)據(jù)庫方式
job的相關信息存儲在數(shù)據(jù)庫中，所有節(jié)點共用數(shù)據(jù)庫，每個節(jié)點通過數(shù)據(jù)庫來通信，保證一個job同一時間只會在一個節(jié)點上執(zhí)行，并且
如果某個節(jié)點掛掉，job會被分配到其他節(jié)點執(zhí)行，具體配置如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
<bean id="datasource" class="com.mchange.v2.c3p0.combopooleddatasource" destroy-method="close"> <property name="driverclass" value="com.mysql.jdbc.driver" /> <property name="jdbcurl" value="jdbc:mysql://localhost:3306/quartz" /> <property name="user" value="root" /> <property name="password" value="root" /> </bean> <bean class="org.springframework.scheduling.quartz.schedulerfactorybean"> <property name="datasource" ref="datasource" /> <property name="configlocation" value="classpath:quartz.properties" /> <property name="triggers"> <list> <ref bean="firstcrontrigger" /> </list> </property> </bean> |
datasource用來配置數(shù)據(jù)源，數(shù)據(jù)表相關信息，可以到官網(wǎng)下載gz包，sql文件在路徑：docs\dbtables下，里面提供了主流數(shù)據(jù)庫的sql文件；
configlocation配置的quartz.properties文件在quartz.jar的org.quartz包下，里面提供了一些默認的數(shù)據(jù)，比如org.quartz.jobstore.class
|
1
|
org.quartz.jobstore.class: org.quartz.simpl.ramjobstore |
這里需要將quartz.properties拷貝出來做一些修改，具體修改如下：
|
1
2
3
4
|
org.quartz.scheduler.instanceid: autoorg.quartz.jobstore.class: org.quartz.impl.jdbcjobstore.jobstoretxorg.quartz.jobstore.isclustered: trueorg.quartz.jobstore.clustercheckininterval: 1000 |
5.相關類
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
public class firsttask extends quartzjobbean { private firstservice firstservice; @override protected void executeinternal(jobexecutioncontext context) throws jobexecutionexception { firstservice.service(); } public void setfirstservice(firstservice firstservice) { this.firstservice = firstservice; }} |
firsttask繼承quartzjobbean，實現(xiàn)executeinternal方法，調(diào)用firstservice
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
public class firstservice implements serializable { private static final long serialversionuid = 1l; public void service() { system.out.println(new simpledateformat("yyyymmdd hh:mm:ss").format(new date()) + "---start firstservice"); try { thread.sleep(2000); } catch (interruptedexception e) { e.printstacktrace(); } system.out.println(new simpledateformat("yyyymmdd hh:mm:ss").format(new date()) + "---end firstservice"); }} |
firstservice需要提供序列化接口，因為需要保存在數(shù)據(jù)庫中；
|
1
2
3
4
5
|
public class app { public static void main(string[] args) { abstractapplicationcontext context = new classpathxmlapplicationcontext("quartz.xml"); }} |
主類用來加載quartz配置文件；
測試分布式調(diào)度
1.同時啟動app兩次，觀察日志：
20180405 14:48:10---start firstservice
20180405 14:48:12---end firstservice
20180405 14:48:15---start firstservice
20180405 14:48:17---end firstservice
其中a1有日志輸出，a2沒有；當停掉a1以后，a2有日志輸出；
2.添加新的job分別新建：secondtask和secondservice，同時添加相關配置文件，啟動app兩次，觀察日志：
a1日志如下：
20180405 15:03:15---start firstservice
20180405 15:03:15---start secondservice
20180405 15:03:17---end firstservice
20180405 15:03:17---end secondservice
20180405 15:03:20---start firstservice
20180405 15:03:22---end firstservice
20180405 15:03:25---start firstservice
20180405 15:03:27---end firstservice
a2日志如下：
20180405 15:03:20---start secondservice
20180405 15:03:22---end secondservice
20180405 15:03:25---start secondservice
20180405 15:03:27---end secondservice
可以發(fā)現(xiàn)a1和a2都有執(zhí)行任務，但是同一任務同一時間只會在一個節(jié)點執(zhí)行，并且只有在執(zhí)行結(jié)束后才有可能分配到其他節(jié)點；
3.如果間隔時間小于任務執(zhí)行時間，比如這里改成sleep(6000)
a1日志如下：
20180405 15:14:40---start firstservice
20180405 15:14:45---start firstservice
20180405 15:14:46---end firstservice
20180405 15:14:50---start firstservice
20180405 15:14:50---start secondservice
20180405 15:14:51---end firstservice
a2日志如下：
20180405 15:14:40---start secondservice
20180405 15:14:45---start secondservice
20180405 15:14:46---end secondservice
20180405 15:14:51---end secondservice
間隔時間是5秒，而任務執(zhí)行需要6秒，觀察日志可以發(fā)現(xiàn)，任務還沒有結(jié)束，新的任務已經(jīng)開始，這種情況可能引發(fā)應用的邏輯問題，其實就是任務能不能支持串行的問題；
4.@disallowconcurrentexecution注解保證任務的串行
在firsttask和secondtask上分別添加@disallowconcurrentexecution注解，日志結(jié)果如下：
a1日志如下：
20180405 15:32:45---start firstservice
20180405 15:32:51---end firstservice
20180405 15:32:51---start firstservice
20180405 15:32:51---start secondservice
20180405 15:32:57---end firstservice
20180405 15:32:57---end secondservice
20180405 15:32:57---start firstservice
20180405 15:32:57---start secondservice
a2日志如下：
20180405 15:32:45---start secondservice
20180405 15:32:51---end secondservice
觀察日志可以發(fā)現(xiàn)，任務只有在end以后，才會開始新的任務，實現(xiàn)了任務的串行化；
總結(jié)
本文旨在對spring+quartz分布式調(diào)度有一個直觀的了解，通過實際的使用來解決問題，當然可能還有很多疑問比如它是如何調(diào)度的，數(shù)據(jù)庫如果掛了會怎么樣等等，還需要做更加深入的了解。
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：http://codingo.xyz/index.php/2018/04/05/quartz1/
