Spring Quartz 動態配置定時任務

阿新 • • 發佈：2019-02-19

1、Quartz在Spring中的簡單配置
Spring配置檔案quartz.xml：
Java程式碼

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN""http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="scheduleInfoService"class="com.erry.tntops.web.task.ScheduleInfoService"

>
<property name="scheduler" ref="schedulerFactory"/>
</bean>
<bean id="jobDetail"class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject" ref="scheduleInfoService"/>
<property name="targetMethod"

value="test"/>
<property name="concurrent" value="false"/>
</bean>
<bean id="cronTrigger"class="org.springframework.scheduling.quartz.CronTriggerBean" >
<property name="jobDetail" ref="jobDetail"/>
<property name="cronExpression"

>
<value>0/10 * * * * ?</value>
</property>
</bean>
<bean id="schedulerFactory"class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref local="cronTrigger"/>
</list>
</property>
</bean>
</beans>

在上面的配置中設定：
① targetMethod: 指定需要定時執行scheduleInfoAction中的test()方法
② concurrent：對於相同的JobDetail，當指定多個Trigger時, 很可能第一個job完成之前，第二個job就開始了。指定concurrent設為false，多個job不會併發執行，第二個job將不會在第一個job完成之前開始。
③ cronExpression：0/10 * * * * ?表示每10秒執行一次，具體可參考附表。
④ triggers：通過再新增其他的ref元素可在list中放置多個觸發器。
scheduleInfoAction中的simpleJobTest()方法
注意：此方法沒有引數，如果scheduleInfoAction有兩個方法test()和test(String argument)，則spring只會去執行無參的test().
Java程式碼

publicvoid test() {
log.warn("uh oh, Job is scheduled !'" + "' Success...");
}

2、Quartz在Spring中動態設定cronTrigger方法一
（1）、Spring配置檔案quartz.xml：
Java程式碼

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN""http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="scheduleInfoAction"class="com.erry.tntops.web.task.ScheduleInfoAction">
<property name="scheduler" ref="schedulerFactory"/>
<property name="emsService" ref="emsService"/>
</bean>
<bean id="jobDetail"class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject" ref="scheduleInfoAction"/>
<property name="targetMethod" value="reScheduleJob"/>
<property name="concurrent" value="false"/>
</bean>
<bean id="cronTrigger"class="com.erry.tntops.web.task.InitCronTrigger">
<property name="jobDetail" ref="jobDetail"/>
<property name="cronExpression">
<value>0/10 * * * * ?</value>
</property>
</bean>
<bean id="schedulerFactory"class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref local="cronTrigger"/>
</list>
</property>
</bean>
</beans>

（2）、類ScheduleInfoAction：
Java程式碼

import org.apache.log4j.Logger;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.springframework.scheduling.quartz.CronTriggerBean;
import java.text.ParseException;
import java.util.Date;
publicclass ScheduleInfoAction{
Logger logger = Logger.getLogger(ScheduleInfoAction.class);
private Scheduler scheduler;
// 設值注入，通過setter方法傳入被呼叫者的例項scheduler
publicvoid setScheduler(Scheduler scheduler) {
this.scheduler = scheduler;
}
private EmsService emsService;
publicvoid setEmsService(EmsService emsService){
this.emsService = emsService;
}
publicvoid reScheduleJob() throws SchedulerException {
// 執行時可通過動態注入的scheduler得到trigger，注意採用這種注入方式在有的專案中會有問題，如果遇到注入問題，可以採取在執行方法時候，獲得bean來避免錯誤發生。
CronTriggerBean trigger = (CronTriggerBean) scheduler.getTrigger("cronTrigger", Scheduler.DEFAULT_GROUP);
logger.info("*********** trigger: " + trigger);
String dbCronExpression = getCronExpressionFromDB();
logger.info("*********** dbCronExpression: " + dbCronExpression);
String originConExpression = trigger.getCronExpression();
logger.info("*********** originConExpression: " + originConExpression);
// 判斷從DB中取得的任務時間(dbCronExpression)和現在的quartz執行緒中的任務時間(originConExpression)是否相等
// 如果相等，則表示使用者並沒有重新設定資料庫中的任務時間，這種情況不需要重新rescheduleJob
if(!originConExpression.equalsIgnoreCase(dbCronExpression)){
try{
trigger.setCronExpression(dbCronExpression);
scheduler.rescheduleJob("cronTrigger", Scheduler.DEFAULT_GROUP, trigger);
} catch (ParseException e) {
logger.error("------------------- ParseException Error! -------------------");
e.printStackTrace();
logger.error("-------------------------------------------------------------");
}
}
//執行task
logger.info("task start time: " + new Date());
System.out.println("Task test success!");
logger.info(" task end time: " + new Date());
}
private String getCronExpressionFromDB(){
String sql = "select CRON from t_test_task_trigger where available = 1 and trigger_name = 'cronTrigger'";
return emsService.getCron(sql);
}
}

3、Quartz在Spring中動態設定cronTrigger方法二
在2中我們已經能夠實現動態配置cronException，但是我們依然需要設定一個預設的cronException：
Java程式碼

<property name="cronExpression">
<value>0/10 * * * * ?</value>
</property>

如果我們拿掉它，則容器（如Jboss）會報錯。
實際上我們希望容器啟動時就去資料庫獲得dbCronException,而不需要再初始化一個cronException。觀察CronTriggerBean，需要初始化cronException，我們可以建立類InitCronTrigger繼承CronTriggerBean，從DB中獲得資料初始化cronException，這樣問題就解決了。
（1）、Spring配置檔案quartz.xml：
Java程式碼

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN""http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="scheduleInfoAction"class="wym.task.ScheduleInfoAction">
<property name="scheduler" ref="schedulerFactory"/>
<property name="emsService" ref="EmsService"/>
</bean>
<bean id="jobDetail"class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject" ref="scheduleInfoAction"/>
<property name="targetMethod" value="reScheduleJob"/>
<property name="concurrent" value="false"/>
</bean>
<bean id="cronTrigger"class="wym.task.InitCronTrigger">
<property name="jobDetail" ref="jobDetail"/>
<property name="emsService" ref="EmsService"/>
</bean>
<bean id="schedulerFactory"class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref local="cronTrigger"/>
</list>
</property>
</bean>
</beans>

（2）、類InitCronTrigger
注意：在注入scheduleInfoManager屬性的時候，我們可以去讀取DB任務時間（之所以放在setter方法中，是因為需要在設定scheduleInfoManager後進行getCronExpressionFromDB()，否則，也可以①②邏輯把放在類的建構函式中）.
注意InitializingCronTrigger必須extends CronTriggerBean.
Java程式碼

import com.erry.tntops.ems.service.EmsService;
import org.springframework.scheduling.quartz.CronTriggerBean;
import java.io.Serializable;
import java.text.ParseException;
publicclass InitCronTrigger extends CronTriggerBean implements Serializable {
private EmsService emsService;
publicvoid setEmsService(EmsService emsService) throws ParseException {
this.emsService = emsService;
String cronException = getCronExceptionDB();
setCronExpression(cronException);
}
private String getCronExceptionDB(){
String sql = "select CRON from t_test_task_trigger where available = 1 and trigger_name = 'cronTrigger'";
System.out.println("*****" + sql);
return emsService.getCron(sql);
}
}

Spring Quartz 動態配置定時任務

Spring Quartz 動態配置定時任務

Spring Quartz動態管理定時任務及相關問題總結

Spring-boot整合Quartz，3、動態配置定時任務

springboot整合Quartz實現動態配置定時任務

springboot動態配置定時任務2種方式，整合Quartz多執行緒併發執行多個定時任務配置

Spring Boot 中配置定時任務，實現多線程操作

Spring+Quartz框架實現定時任務（集群，分布式）

spring mvc中配置定時任務，事務等

Spring+Quartz+Hibernate做定時任務時不能獲得Session的解決方法

34. springboot動態配置定時任務（通過資料庫配置）

SpringBoot整合quartz動態建立定時任務實現以及踩過的坑

1 springboot之動態配置定時任務

springboot動態配置定時任務時間

spring quartz動態實現對任務的增刪改查（可傳引數）

spring boot 中配置定時任務job

動態配置定時任務(Mysql+重啟服務後重新載入任務)

基於spring+quartz的分散式定時任務框架

spring 註解方式配置定時任務

Quartz+Spring Boot實現動態管理定時任務

Spring 動態管理定時任務（使用quartz）只是管理啟動時間不能做啟動和暫停

Spring Quartz 動態配置定時任務

相關推薦