Spring整合Quartz分布式調(diào)度的示例代碼

前言

為了保證應(yīng)用的高可用和高并發(fā)性，一般都會部署多個節(jié)點；對于定時任務(wù)，如果每個節(jié)點都執(zhí)行自己的定時任務(wù)，一方面耗費了系統(tǒng)資源，

另一方面有些任務(wù)多次執(zhí)行，可能引發(fā)應(yīng)用邏輯問題，所以需要一個分布式的調(diào)度系統(tǒng)，來協(xié)調(diào)每個節(jié)點執(zhí)行定時任務(wù)。

Spring整合Quartz

Quartz是一個成熟的任務(wù)調(diào)度系統(tǒng)，Spring對Quartz做了兼容，方便開發(fā)，下面看看具體如何整合：

1.Maven依賴文件

<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相關(guān)庫、quartz庫以及mysql驅(qū)動庫，注：分布式調(diào)度需要用到數(shù)據(jù)庫，這里選用mysql；

2.配置job

提供了兩種方式來配置job，分別是：MethodInvokingJobDetailFactoryBean和JobDetailFactoryBean

2.1MethodInvokingJobDetailFactoryBean

要調(diào)用特定bean的一個方法的時候使用，具體配置如下：

<bean id="firstTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> 
  <property name="targetObject" ref="firstService" /> 
  <property name="targetMethod" value="service" /> 
</bea>

2.2JobDetailFactoryBean

這種方式更加靈活，可以設(shè)置傳遞參數(shù)，具體如下：

<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定義的任務(wù)類，繼承QuartzJobBean，實現(xiàn)executeInternal方法；jobDataMap用來給job傳遞數(shù)據(jù)

3.配置調(diào)度使用的觸發(fā)器

同樣提供了兩種觸發(fā)器類型：SimpleTriggerFactoryBean和CronTriggerFactoryBean

重點看CronTriggerFactoryBean，這種類型更加靈活，具體如下：

<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的相關(guān)信息存儲在內(nèi)存里，每個節(jié)點存儲各自的，互相隔離，配置如下：

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
 <property name="triggers">
  <list>
  <ref bean="firstCronTrigger" />
  </list>
 </property>
 </bean>

4.2數(shù)據(jù)庫方式

job的相關(guān)信息存儲在數(shù)據(jù)庫中，所有節(jié)點共用數(shù)據(jù)庫，每個節(jié)點通過數(shù)據(jù)庫來通信，保證一個job同一時間只會在一個節(jié)點上執(zhí)行，并且

如果某個節(jié)點掛掉，job會被分配到其他節(jié)點執(zhí)行，具體配置如下：

<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ù)表相關(guān)信息，可以到官網(wǎng)下載gz包，sql文件在路徑：docs\dbTables下，里面提供了主流數(shù)據(jù)庫的sql文件；

configLocation配置的quartz.properties文件在quartz.jar的org.quartz包下，里面提供了一些默認的數(shù)據(jù)，比如org.quartz.jobStore.class

org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore

這里需要將quartz.properties拷貝出來做一些修改，具體修改如下：

org.quartz.scheduler.instanceId: AUTO
org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.isClustered: true
org.quartz.jobStore.clusterCheckinInterval: 1000

5.相關(guān)類

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

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ù)庫中；

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，同時添加相關(guān)配置文件，啟動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í)行任務(wù)，但是同一任務(wù)同一時間只會在一個節(jié)點執(zhí)行，并且只有在執(zhí)行結(jié)束后才有可能分配到其他節(jié)點；

3.如果間隔時間小于任務(wù)執(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秒，而任務(wù)執(zhí)行需要6秒，觀察日志可以發(fā)現(xiàn)，任務(wù)還沒有結(jié)束，新的任務(wù)已經(jīng)開始，這種情況可能引發(fā)應(yīng)用的邏輯問題，其實就是任務(wù)能不能支持串行的問題；

4.@DisallowConcurrentExecution注解保證任務(wù)的串行

在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)，任務(wù)只有在end以后，才會開始新的任務(wù)，實現(xiàn)了任務(wù)的串行化；

總結(jié)

本文旨在對Spring+Quartz分布式調(diào)度有一個直觀的了解，通過實際的使用來解決問題，當然可能還有很多疑問比如它是如何調(diào)度的，數(shù)據(jù)庫如果掛了會怎么樣等等，還需要做更加深入的了解。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習有所幫助，也希望大家多多支持億速云。