spring学习笔记(26)spring整合Quartz2持久化稳健任务调度

在《Quartz任务调度(3)存储与持久化操作配置详细解析 》一文中，我们通过配置quartz.properties属性文件实现了Quartz的数据库持久化操作。现在整合spring的原理，就是相当于把我们在属性文件中的配置属性整合进SchedulerFactoryBean中，来生成我们的Scheduler类。

这里需要特别注意的是，我们通过Bean配置生成的JobDetail和CronTrigger或SimpleTrigger不能被序列化，因而不能持久化到数据库中，如果想要使用持久化任务调度，我们需要编程式创建Quartz的Job等相关实现类。下面是我们的配置实例：

spring容器配置

<bean id="quartzDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource" >
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://127.0.0.1:3306/quartz"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</bean>

<!-- quartz持久化存储  -->
<bean name="quartzScheduler"
class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="dataSource">
<ref bean="quartzDataSource" />
</property>
<property name="applicationContextSchedulerContextKey" value="applicationContext" />
<property name="quartzProperties">
<props>
<!-- JobStore 配置 -->
<prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>
<!-- 数据表设置 -->
<prop key="org.quartz.jobStore.tablePrefix">QRTZ_</prop>
<prop key="org.quartz.jobStore.dataSource">myDatadource</prop>
</props>
</property>
</bean>

在连接数据前，我们需要先在数据库中创建好对应的表格，在我开始提到的文章内有相关的sql语句。此外，关于quartzProperties还有很多配置属性，如配置线程池、集群等，在我开头提到的那篇文章内都有详细说明。

测试类配置

package tool.job;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.ObjectAlreadyExistsException;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class pickNewsJob implements Job {

@Override
public void execute(JobExecutionContext jec) throws JobExecutionException {
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
System.out.println("在" + sdf.format(new Date()) + "更新日志");
}

public static void main(String args[]) throws SchedulerException {
JobDetail jobDetail = JobBuilder.newJob(pickNewsJob.class)
.withIdentity("job1", "jgroup1").build();
SimpleTrigger simpleTrigger = TriggerBuilder
.newTrigger()
.withIdentity("trigger1")
.withSchedule(
SimpleScheduleBuilder
.repeatSecondlyForTotalCount(10, 2)).startNow()
.build();
try{
ApplicationContext ac = new ClassPathXmlApplicationContext("spring/spring-task.xml");
Scheduler scheduler = (Scheduler) ac.getBean("quartzScheduler");
scheduler.scheduleJob(jobDetail, simpleTrigger);
scheduler.start();
}catch ( ObjectAlreadyExistsException e) {
resumeJob();
}
}
/**
*根据数据库中的记录 恢复异常中断的任务
*/
public static void resumeJob() throws SchedulerException {
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
// ①获取调度器中所有的触发器组
List<String> triggerGroups = scheduler.getTriggerGroupNames();
// ②重新恢复在tgroup1组中，名为trigger1触发器的运行
for (int i = 0; i < triggerGroups.size(); i++) {
List<String> triggers = scheduler.getTriggerGroupNames();
for (int j = 0; j < triggers.size(); j++) {
Trigger tg = scheduler.getTrigger(new TriggerKey(triggers
.get(j), triggerGroups.get(i)));
// ②-1:根据名称判断
if (tg instanceof SimpleTrigger
&& tg.getDescription().equals("jgroup1.DEFAULT")) {//由于我们之前测试没有设置触发器所在组，所以默认为DEFAULT
// ②-1:恢复运行
scheduler.resumeJob(new JobKey(triggers.get(j),
triggerGroups.get(i)));
}
}
}
scheduler.start();

}
}

在这里，如果我们测试时在运行中断后再重复运行，会出现ObjectAlreadyExistsException异常，原因是我们创建的JobDetail和Trigger等的名字和数据库中已有记录冲突，新的任务尝试持久到数据库失败。在程序中，我的处理方法是先捕捉异常，然后调用恢复任务方法，来重新执行异常中断的任务。

源码下载

本例源码可到我的github仓库https://github.com/jeanhao/spring的springQuartz文件夹下载