林炳文Evankaka原创作品。转载请注明出处http://blog.csdn.net/evankaka

      在上文【Quartz】Quartz存储与持久化-基于quartz.properties的配置 ，是通过配置quartz.properties文件的方式来实现持久化的。本文将通过Spring配置的方式来实现存储与持久化。

本文工程免费下载

1、同上文一样，要先创建相关的数据表，并新建一个JAVA工程，并导入相关的包，整个工程目录 如下：

2、创建Job类

package com.mucfc;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class MyJob implements Job{private static final Logger logger = Logger.getLogger(MyJob.class);  @Overridepublic void execute(JobExecutionContext context)throws JobExecutionException {System.out.println("Hello quzrtz  "+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss ").format(new Date()));}}

3、创建一个调度类

package com.mucfc;
import java.text.ParseException;
import java.util.List;import org.apache.commons.lang.StringUtils;
import org.quartz.CronScheduleBuilder;
import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
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.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.stereotype.Component;
@Component
public class QuartzTest {@Autowiredprivate Scheduler scheduler;private static String JOB_GROUP_NAME = "ddlib";private static String TRIGGER_GROUP_NAME = "ddlibTrigger";/*** 开始一个simpleSchedule()调度*/public void startSchedule() {try {// 1、创建一个JobDetail实例，指定QuartzJobDetail jobDetail = JobBuilder.newJob(MyJob.class)// 任务执行类.withIdentity("job1_1", "jGroup1")// 任务名，任务组.build();// 2、创建TriggerSimpleScheduleBuilder builder = SimpleScheduleBuilder.simpleSchedule()// 设置执行次数.repeatSecondlyForTotalCount(10);Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1_1", "tGroup1").startNow().withSchedule(builder).build();// 3、创建Schedulerscheduler.start();// 4、调度执行scheduler.scheduleJob(jobDetail, trigger);try {Thread.sleep(60000);} catch (InterruptedException e) {e.printStackTrace();}scheduler.shutdown();} catch (SchedulerException e) {e.printStackTrace();}}/*** 从数据库中找到已经存在的job，并重新开户调度*/public  void resumeJob() {try {// ①获取调度器中所有的触发器组List<String> triggerGroups = scheduler.getTriggerGroupNames();// ②重新恢复在tgroup1组中，名为trigger1_1触发器的运行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("tgroup1.trigger1_1")) {// ②-1:恢复运行scheduler.resumeJob(new JobKey(triggers.get(j),triggerGroups.get(i)));}}}scheduler.start();} catch (Exception e) {e.printStackTrace();}}
}

4、beans.xml文件配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/context   http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/task  http://www.springframework.org/schema/task/spring-task-3.0.xsd"><!-- 自动扫描注解的bean --><context:component-scan base-package="com.mucfc"/><context:property-placeholder location="classpath:jdbc.properties" /><bean id="quartzDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource" ><!-- <property name="driverClass" value="${quartz.driverClassName}"/><property name="jdbcUrl" value="${quartz.url}"/><property name="user"  value="${quartz.username}"/><property name="password" " value="${quartz.password}"/><property name="minPoolSize"  value="${quartz.minPoolSize}"/><property name="initialPoolSize" value="${quartz.initialPoolSize}"/> --> <property name="driverClassName" value="${quartz.driverClassName}"/>  <property name="url" value="${quartz.url}"/>  <property name="username" value="${quartz.username}"/>  <property name="password" value="${quartz.password}"/>   </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><prop key="org.quartz.scheduler.instanceName">CRMscheduler</prop><prop key="org.quartz.scheduler.instanceId">AUTO</prop><!-- 线程池配置 --><prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop><prop key="org.quartz.threadPool.threadCount">20</prop><prop key="org.quartz.threadPool.threadPriority">5</prop><prop key="org.quartz.jobStore.misfireThreshold">120000</prop><!-- JobStore 配置 --><prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop><!-- 集群配置 --><prop key="org.quartz.jobStore.isClustered">true</prop><prop key="org.quartz.jobStore.clusterCheckinInterval">15000</prop><prop key="org.quartz.jobStore.maxMisfiresToHandleAtATime">1</prop>                 <!-- 数据表设置 --><prop key="org.quartz.jobStore.tablePrefix">qrtz_</prop><prop key="org.quartz.jobStore.dataSource">qzDS</prop></props>       </property></bean>  
</beans>

其中数据源jdbc.properties：

############quartz db########################  
quartz.driverClassName=com.mysql.jdbc.Driver  
quartz.url=jdbc:mysql://127.0.0.1:3306/quartz?useUnicode=true  
quartz.username=root
quartz.password=christmas258@
quartz.minPoolSize=7  
quartz.initialPoolSize=12

5、测试类

package com.mucfc;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test {public static void main(String[] args) {ApplicationContext context=new ClassPathXmlApplicationContext("beans.xml");QuartzTest quartzTest=context.getBean("quartzTest",QuartzTest.class);quartzTest.startSchedule();//quartzTest.resumeJob();}}

输出结果：

查看数据表

停止程序，语句改成：

 //quartzTest.startSchedule();
quartzTest.resumeJob();

然后就可以发现任务接着运行了，运行完成完之后自动从数据表中删除：

      林炳文Evankaka原创作品。转载请注明出处http://blog.csdn.net/evankaka

本文工程免费下载