Spring整合Quartz开发代码实例

我们使用Spring整合Quartz开发，本实例采用数据库模式的demo。

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" xsi:schemaLocation="
http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util.xsd">

<!--加载数据库连接的配置文件-->
<!--<context:property-placeholder location="jdbc.properties"></context:property-placeholder>-->
<!-- c3p0：数据源配置 -->
<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?Unicode=true&amp;characterEncoding=UTF-8"/>
<property name="user" value="root"/>
<property name="password" value="root"/>
<property name="initialPoolSize" value="3"/>
<property name="minPoolSize" value="2"/>
<property name="maxPoolSize" value="10"/>
<property name="maxIdleTime" value="60"/>
<property name="acquireRetryDelay" value="1000"/>
<property name="acquireRetryAttempts" value="10"/>
<property name="preferredTestQuery" value="SELECT 1"/>
</bean>

<bean id="quartzScheduler" lazy-init="false" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="dataSource" ref="dataSource"></property>
<property name="configLocation" value="quartz.properties"></property>
<!--  <property name="triggers"></property>-->
</bean>

</beans>

public class SimpleJob extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
System.out.println(new Date()+"执行SimpleJob");
}

}

public class ApplicationContextTest {

public static Scheduler scheduler;

public static void main(String[] args) throws Exception {

ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationcontext-trigger.xml");
scheduler = (Scheduler) applicationContext.getBean("quartzScheduler");
//SimpleJob simpleJob = new SimpleJob();

scheduler.start();

//从数据库中获取相应的job及调度信息
//JobDetail jobDetail = scheduler.getJobDetail(new JobKey("trigger1", "trigger1"));
//resumeJob(jobDetail.getKey().getName(), jobDetail.getKey().getGroup());
//添加job执行
addJob("trigger1", "trigger1", "job1", "job2", "0/20 * * * * ?", SimpleJob.class, new HashMap<>());
Thread.sleep(60 * 1000);
//重新设置调度时间
System.out.println("重新设置调度时间");
rescheduleJob("trigger1","trigger1","0/10 * * * * ?");

Thread.sleep(60 * 1000);
//暂停调度
System.out.println("暂停调度");
pauseJob("trigger1","trigger1");

Thread.sleep(60 * 1000);
System.out.println("恢复调度");
resumeJob("trigger1","trigger1");

Thread.sleep(60 * 1000);
System.out.println("删除调度");
removeJob("trigger1","trigger1");
Thread.sleep(60 * 1000);

System.out.println(scheduler);
}

/**
* 添加job执行
*
* @param triggerKeyName
* @param triggerKeyGroup
* @param jobName
* @param jobGroup
* @param cronExpression
* @param jobClass
* @param jobData
* @return
* @throws Exception
*/
public static boolean addJob(String triggerKeyName, String triggerKeyGroup, String jobName, String jobGroup, String cronExpression,
Class<? extends Job> jobClass, Map<String, Object> jobData) throws Exception {

JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(triggerKeyName, triggerKeyGroup).build();

Trigger trigger = TriggerBuilder.newTrigger().withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)).withIdentity(triggerKeyName, triggerKeyGroup).build();
if (jobData != null && jobData.size() > 0) {
JobDataMap jobDataMap = jobDetail.getJobDataMap();
jobDataMap.putAll(jobData);  // JobExecutionContext context.getMergedJobDataMap().get("mailGuid");
}

scheduler.scheduleJob(jobDetail, trigger);

//    if (!scheduler.isShutdown()) {
//      scheduler.start();
//    }

return true;

}

/**
* 重新设置job执行
* @param triggerKeyName
* @param triggerKeyGroup
* @param cronExpression
* @return
* @throws SchedulerException
*/
public static boolean rescheduleJob(String triggerKeyName, String triggerKeyGroup, String cronExpression) throws SchedulerException {
TriggerKey triggerKey = TriggerKey.triggerKey(triggerKeyName, triggerKeyGroup);

if (scheduler.checkExists(triggerKey)) {
Trigger trigger = TriggerBuilder.newTrigger().withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)).withIdentity(triggerKey).build();
scheduler.rescheduleJob(triggerKey, trigger);
}

return true;
}

/**
* 删除job
* @param triggerKeyName
* @param triggerKeyGroup
* @return
* @throws SchedulerException
*/
public static boolean removeJob(String triggerKeyName, String triggerKeyGroup) throws SchedulerException {
// TriggerKey : name + group

TriggerKey triggerKey = TriggerKey.triggerKey(triggerKeyName, triggerKeyGroup);

boolean result = false;
if (scheduler.checkExists(triggerKey)) {
result = scheduler.unscheduleJob(triggerKey);
}

return result;
}

/**
* 暂停job
* @param triggerKeyName
* @param triggerKeyGroup
* @return
* @throws SchedulerException
*/
public static boolean pauseJob(String triggerKeyName, String triggerKeyGroup) throws SchedulerException {
// TriggerKey : name + group

TriggerKey triggerKey = TriggerKey.triggerKey(triggerKeyName, triggerKeyGroup);

boolean result = false;
if (scheduler.checkExists(triggerKey)) {
scheduler.pauseTrigger(triggerKey);
result = true;

} else {

}
return result;
}

/**
* 重启job
* @param triggerKeyName
* @param triggerKeyGroup
* @return
* @throws SchedulerException
*/
public static boolean resumeJob(String triggerKeyName, String triggerKeyGroup) throws SchedulerException {

TriggerKey triggerKey = TriggerKey.triggerKey(triggerKeyName, triggerKeyGroup);

boolean result = false;
if (scheduler.checkExists(triggerKey)) {
scheduler.resumeTrigger(triggerKey);
result = true;

} else {

}
return result;
}
}

quart.properties正常配置信息，然后点击运行即可。

本实例中当运行的任务在暂停的情况下，一旦重新恢复，会将暂停期间的任务运行如图：

源码链接：  https://github.com/albert-liu435/springquartz

以上就是本文的全部内容，希望对大家的学习有所帮助

您可能感兴趣的文章:

• spring整合Quartz框架过程详解
• 浅谈SpringBoot集成Quartz动态定时任务
• Spring整合Quartz定时任务并在集群、分布式系统中的应用
• SpringBoot与Quartz集成实现分布式定时任务集群的代码实例
• 详解Quartz 与 Spring框架集成的三种方式
• springboot Quartz动态修改cron表达式的方法
• Springboot整个Quartz实现动态定时任务的示例代码
• Quartz+Spring Boot实现动态管理定时任务