quartz之动态定时器实现
生活随笔
收集整理的這篇文章主要介紹了
quartz之动态定时器实现
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
Spring整合Quartz
創建工程需要的
a、quartz調度框架是有內置表的
進入quartz的官網http://www.quartz-scheduler.org/，
點擊Downloads，
下載后在目錄\docs\dbTables下有常用數據庫創建quartz表的腳本，例如：“tables_mysql.sql”
導入quartz調度框架自帶的表
詳情見下
b、導入pom依賴
<mysql.verion>5.1.44</mysql.verion><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version><scope>runtime</scope> </dependency><dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz-jobs</artifactId><version>2.2.1</version> </dependency> <!--引入druid依賴--><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.10</version></dependency> <!--配置逆向生成--><resources><!--解決mybatis-generator-maven-plugin運行時沒有將XxxMapper.xml文件放入target文件夾的問題--><resource><directory>src/main/java</directory><includes><include>**/*.xml</include></includes></resource><!--解決mybatis-generator-maven-plugin運行時沒有將jdbc.properites文件放入target文件夾的問題--><resource><directory>src/main/resources</directory><includes><include>*.properties</include><include>*.xml</include><include>*.yml</include></includes></resource></resources><plugin><groupId>org.mybatis.generator</groupId><artifactId>mybatis-generator-maven-plugin</artifactId><version>1.3.2</version><dependencies><!--使用Mybatis-generator插件不能使用太高版本的mysql驅動 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency></dependencies><configuration><overwrite>true</overwrite></configuration></plugin>DruidConnectionProvider.java（數據源拓展類）
package com.zxp.quartz02.util;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-05 19:11*/import com.alibaba.druid.pool.DruidDataSource; import org.quartz.SchedulerException; import org.quartz.utils.ConnectionProvider;import java.sql.Connection; import java.sql.SQLException;/* #============================================================================ # JDBC #============================================================================ org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate org.quartz.jobStore.useProperties:false org.quartz.jobStore.dataSource:qzDS #org.quartz.dataSource.qzDS.connectionProvider.class:org.quartz.utils.PoolingConnectionProvider org.quartz.dataSource.qzDS.connectionProvider.class:com.javaxl.q03.quartz.DruidConnectionProvider org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver org.quartz.dataSource.qzDS.URL:jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8 org.quartz.dataSource.qzDS.user:root org.quartz.dataSource.qzDS.password:root org.quartz.dataSource.qzDS.maxConnections:30 org.quartz.dataSource.qzDS.validationQuery: select 0 */ /*** [Druid連接池的Quartz擴展類]** @ProjectName: []* @Author: [xuguang]* @CreateDate: [2015/11/10 17:58]* @Update: [說明本次修改內容] BY[xuguang][2015/11/10]* @Version: [v1.0]*/ public class DruidConnectionProvider implements ConnectionProvider {/** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~** 常量配置，與quartz.properties文件的key保持一致(去掉前綴)，同時提供set方法，Quartz框架自動注入值。** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~*///JDBC驅動public String driver;//JDBC連接串public String URL;//數據庫用戶名public String user;//數據庫用戶密碼public String password;//數據庫最大連接數public int maxConnection;//數據庫SQL查詢每次連接返回執行到連接池，以確保它仍然是有效的。public String validationQuery;private boolean validateOnCheckout;private int idleConnectionValidationSeconds;public String maxCachedStatementsPerConnection;private String discardIdleConnectionsSeconds;public static final int DEFAULT_DB_MAX_CONNECTIONS = 10;public static final int DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION = 120;//Druid連接池private DruidDataSource datasource;/** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~** 接口實現** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~*/public Connection getConnection() throws SQLException {return datasource.getConnection();}public void shutdown() throws SQLException {datasource.close();}public void initialize() throws SQLException{if (this.URL == null) {throw new SQLException("DBPool could not be created: DB URL cannot be null");}if (this.driver == null) {throw new SQLException("DBPool driver could not be created: DB driver class name cannot be null!");}if (this.maxConnection < 0) {throw new SQLException("DBPool maxConnectins could not be created: Max connections must be greater than zero!");}datasource = new DruidDataSource();try{datasource.setDriverClassName(this.driver);} catch (Exception e) {try {throw new SchedulerException("Problem setting driver class name on datasource: " + e.getMessage(), e);} catch (SchedulerException e1) {}}datasource.setUrl(this.URL);datasource.setUsername(this.user);datasource.setPassword(this.password);datasource.setMaxActive(this.maxConnection);datasource.setMinIdle(1);datasource.setMaxWait(0);datasource.setMaxPoolPreparedStatementPerConnectionSize(this.DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION);if (this.validationQuery != null) {datasource.setValidationQuery(this.validationQuery);if(!this.validateOnCheckout)datasource.setTestOnReturn(true);elsedatasource.setTestOnBorrow(true);datasource.setValidationQueryTimeout(this.idleConnectionValidationSeconds);}}/** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~** 提供get set方法** ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~*/public String getDriver() {return driver;}public void setDriver(String driver) {this.driver = driver;}public String getURL() {return URL;}public void setURL(String URL) {this.URL = URL;}public String getUser() {return user;}public void setUser(String user) {this.user = user;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public int getMaxConnection() {return maxConnection;}public void setMaxConnection(int maxConnection) {this.maxConnection = maxConnection;}public String getValidationQuery() {return validationQuery;}public void setValidationQuery(String validationQuery) {this.validationQuery = validationQuery;}public boolean isValidateOnCheckout() {return validateOnCheckout;}public void setValidateOnCheckout(boolean validateOnCheckout) {this.validateOnCheckout = validateOnCheckout;}public int getIdleConnectionValidationSeconds() {return idleConnectionValidationSeconds;}public void setIdleConnectionValidationSeconds(int idleConnectionValidationSeconds) {this.idleConnectionValidationSeconds = idleConnectionValidationSeconds;}public DruidDataSource getDatasource() {return datasource;}public void setDatasource(DruidDataSource datasource) {this.datasource = datasource;} }generatorConfig.xml
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN""http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd" > <generatorConfiguration><!-- 引入配置文件 --><properties resource="jdbc.properties"/><!--指定數據庫jdbc驅動jar包的位置--><classPathEntry location="E:\\initPath\\mvn_repository\\mysql\\mysql-connector-java\\5.1.44\\mysql-connector-java-5.1.44.jar"/><!-- 一個數據庫一個context --><context id="infoGuardian"><!-- 注釋 --><commentGenerator><property name="suppressAllComments" value="true"/><!-- 是否取消注釋 --><property name="suppressDate" value="true"/> <!-- 是否生成注釋代時間戳 --></commentGenerator><!-- jdbc連接 --><jdbcConnection driverClass="${jdbc.driver}"connectionURL="${jdbc.url}" userId="${jdbc.username}" password="${jdbc.password}"/><!-- 類型轉換 --><javaTypeResolver><!-- 是否使用bigDecimal， false可自動轉化以下類型（Long, Integer, Short, etc.） --><property name="forceBigDecimals" value="false"/></javaTypeResolver><!-- 01 指定javaBean生成的位置 --><!-- targetPackage：指定生成的model生成所在的包名 --><!-- targetProject：指定在該項目下所在的路徑 --><javaModelGenerator targetPackage="com.zxp.quartz02.model"targetProject="src/main/java"><!-- 是否允許子包，即targetPackage.schemaName.tableName --><property name="enableSubPackages" value="false"/><!-- 是否對model添加構造函數 --><property name="constructorBased" value="true"/><!-- 是否針對string類型的字段在set的時候進行trim調用 --><property name="trimStrings" value="false"/><!-- 建立的Model對象是否 不可改變 即生成的Model對象不會有 setter方法，只有構造方法 --><property name="immutable" value="false"/></javaModelGenerator><!-- 02 指定sql映射文件生成的位置 --><sqlMapGenerator targetPackage="com.zxp.quartz02.mapper"targetProject="src/main/java"><!-- 是否允許子包，即targetPackage.schemaName.tableName --><property name="enableSubPackages" value="false"/></sqlMapGenerator><!-- 03 生成XxxMapper接口 --><!-- type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper對象 --><!-- type="MIXEDMAPPER",生成基于注解的Java Model 和相應的Mapper對象 --><!-- type="XMLMAPPER",生成SQLMap XML文件和獨立的Mapper接口 --><javaClientGenerator targetPackage="com.zxp.quartz02.mapper"targetProject="src/main/java" type="XMLMAPPER"><!-- 是否在當前路徑下新加一層schema,false路徑com.oop.eksp.user.model， true:com.oop.eksp.user.model.[schemaName] --><property name="enableSubPackages" value="false"/></javaClientGenerator><!-- 配置表信息 --><table schema="" tableName="t_schedule_trigger" domainObjectName="ScheduleTrigger"enableCountByExample="false" enableDeleteByExample="false"enableSelectByExample="false" enableUpdateByExample="false"><property name="useActualColumnNames" value="true" /></table><table schema="" tableName="t_schedule_trigger_param" domainObjectName="ScheduleTriggerParam"enableCountByExample="false" enableDeleteByExample="false"enableSelectByExample="false" enableUpdateByExample="false"><property name="useActualColumnNames" value="true" /></table></context> </generatorConfiguration>jdbc.properties
jdbc.driver=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8 jdbc.username=root jdbc.password=123c、在項目中添加quartz.properties文件(這樣就不會加載自帶的properties文件)
此文件的內容主要分為：scheduler，ThreadPool，JobStore，plugin，Datasources等部分，覆蓋properties文件的目的是覆蓋默認的數據源，更換為druid的數據配置
quartz.properties（更改默認數據源）
quartz默認采用的連接池是c3p0,現在流行Druid連接池有監控平臺，需要手動換源。
d、自定義MyJobFactory，解決spring不能在quartz中注入bean的問題
package com.zxp.quartz02.quartz;import lombok.extern.slf4j.Slf4j; import org.quartz.spi.TriggerFiredBundle; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.AutowireCapableBeanFactory; import org.springframework.scheduling.quartz.AdaptableJobFactory; import org.springframework.stereotype.Component;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-04 11:45*/ @Component @Slf4j public class MyJobFactory extends AdaptableJobFactory {//這個由Spring自動注入@Autowiredprivate AutowireCapableBeanFactory autowireCapableBeanFactory;//重寫Job任務對象的創建實例方法@Overrideprotected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {Object jobInstance = super.createJobInstance(bundle);//通過以下方式，解決Job任務無法使用Spring中的Bean問題autowireCapableBeanFactory.autowireBean(jobInstance);return jobInstance;} }e、創建調度器schedule，交給spring進行管理
QuartzConfiguration：quartz調度框架與spring框架整合的配置類，主要是要將org.quartz.Scheduler交給spring進行管理
package com.zxp.quartz02.quartz;import org.quartz.Scheduler; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.PropertiesFactoryBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.ClassPathResource; import org.springframework.scheduling.quartz.SchedulerFactoryBean;import java.io.IOException; import java.util.Properties;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-04 11:46*/ @Configuration public class QuartzConfiguration {@Autowiredprivate MyJobFactory myJobFactory;//創建調度器工廠@Beanpublic SchedulerFactoryBean schedulerFactoryBean(){//1.創建SchedulerFactoryBean//2.加載自定義的quartz.properties配置文件//3.設置MyJobFactorySchedulerFactoryBean factoryBean=new SchedulerFactoryBean();try {factoryBean.setQuartzProperties(quartzProperties());factoryBean.setJobFactory(myJobFactory);return factoryBean;} catch (IOException e) {throw new RuntimeException(e);}}@Beanpublic Properties quartzProperties() throws IOException {PropertiesFactoryBean propertiesFactoryBean=new PropertiesFactoryBean();propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));propertiesFactoryBean.afterPropertiesSet();return propertiesFactoryBean.getObject();}@Bean(name="scheduler")public Scheduler scheduler(){return schedulerFactoryBean().getScheduler();} }以上Spring整合Quartz整合完畢
h、自定義任務表與quartz內置表的區分
自定義的業務表
quartz內置表
f、創建自定義任務以及 & g、更新quartz中的任務
yml配置
ScheduleTriggerParamMapper
*** 查詢出當前任務類對應所需的參數* @param triggerId* @return*/List<ScheduleTriggerParam> queryScheduleParamLst(Integer triggerId);ScheduleTriggerParamMapper.xml
<select id="queryScheduleParamLst" resultType="com.zxp.quartz02.model.ScheduleTriggerParam">select <include refid="Base_Column_List"/>from t_schedule_trigger_param where schedule_trigger_id=#{triggerId}</select>ScheduleTriggerParamService
package com.zxp.quartz02.service;import com.zxp.quartz02.model.ScheduleTriggerParam;import java.util.List;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-05 18:43*/public interface ScheduleTriggerParamService {public List<ScheduleTriggerParam> queryScheduleParamLst(Integer triggerId) ; }ScheduleTriggerParamServiceImpl
package com.zxp.quartz02.service.impl;import com.zxp.quartz02.mapper.ScheduleTriggerParamMapper; import com.zxp.quartz02.model.ScheduleTriggerParam; import com.zxp.quartz02.service.ScheduleTriggerParamService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service;import java.util.List;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-05 18:46*/ @Service public class ScheduleTriggerParamServiceImpl implements ScheduleTriggerParamService {@Autowiredprivate ScheduleTriggerParamMapper scheduleTriggerParamMapper;@Overridepublic List<ScheduleTriggerParam> queryScheduleParamLst(Integer triggerId) {return scheduleTriggerParamMapper.queryScheduleParamLst(triggerId);} }ScheduleTriggerMapper
/*** 查詢觸發器中包含的所有任務* @return*/List<ScheduleTrigger> queryScheduleTriggerLst();ScheduleTriggerMapper.xml
<select id="queryScheduleTriggerLst" resultType="com.zxp.quartz02.model.ScheduleTrigger">select <include refid="Base_Column_List"/>from t_schedule_trigger</select>ScheduleTriggerServiceImpl
package com.zxp.quartz02.service.impl;import com.zxp.quartz02.mapper.ScheduleTriggerMapper; import com.zxp.quartz02.mapper.ScheduleTriggerParamMapper; import com.zxp.quartz02.model.ScheduleTrigger; import com.zxp.quartz02.model.ScheduleTriggerParam; import org.quartz.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service;import java.util.List;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-05 18:40*/ @Service public class ScheduleTriggerServiceImpl {@Autowiredprivate ScheduleTriggerMapper scheduleTriggerMapper;@Autowiredprivate ScheduleTriggerParamMapper scheduleTriggerParamMapper;@Autowiredprivate Scheduler scheduler;@Scheduled(cron = "0/10 * * * * ?")public void refreshScheduler(){try {List<ScheduleTrigger> scheduleTriggers =scheduleTriggerMapper.queryScheduleTriggerLst();if(null!=scheduleTriggers){for (ScheduleTrigger scheduleTrigger : scheduleTriggers) {String cron = scheduleTrigger.getCron(); //表達式String jobName = scheduleTrigger.getJob_name(); //任務名稱String jobGroup = scheduleTrigger.getJob_group(); //任務分組String status = scheduleTrigger.getStatus(); //任務狀態//JobName+JobGroup=Primary Key//根據jobName和jobGroup生成TriggerKeyTriggerKey triggerKey =TriggerKey.triggerKey(jobName, jobGroup);//根據TriggerKey到Scheduler調度器中獲取觸發器CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(triggerKey);if(null==cronTrigger){if(status.equals("0"))continue;System.out.println("創建調度器");//創建任務詳情JobDetail jobDetail=JobBuilder.newJob((Class<? extends Job>) Class.forName(jobName)).withIdentity(jobName,jobGroup).build();//往Job任務中傳遞參數JobDataMap jobDataMap = jobDetail.getJobDataMap();List<ScheduleTriggerParam> params =scheduleTriggerParamMapper.queryScheduleParamLst(scheduleTrigger.getId());for (ScheduleTriggerParam param : params) {jobDataMap.put(param.getName(),param.getValue());}//創建表達式調度器CronScheduleBuilder cronSchedule =CronScheduleBuilder.cronSchedule(cron);//創建TriggercronTrigger=TriggerBuilder.newTrigger().withIdentity(jobName,jobGroup).withSchedule(cronSchedule).build();//將jobDetail和Trigger注入到scheduler調度器中scheduler.scheduleJob(jobDetail,cronTrigger);}else{//System.out.println("Quartz 調度任務中已存在該任務");if(status.equals("0")){JobKey jobKey = JobKey.jobKey(jobName, jobGroup);scheduler.deleteJob(jobKey);continue;}//調度器中的表達式String cronExpression =cronTrigger.getCronExpression();if(!cron.equals(cronExpression)){//創建表達式調度器CronScheduleBuilder cronSchedule =CronScheduleBuilder.cronSchedule(cron);//重構cronTrigger=cronTrigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(cronSchedule).build();//刷新調度器scheduler.rescheduleJob(triggerKey,cronTrigger);}}}}} catch (Exception e) {e.printStackTrace();}} }Quartz02Application
package com.zxp.quartz02;import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.transaction.annotation.EnableTransactionManagement;@MapperScan("com.zxp.quartz02.mapper") @EnableTransactionManagement @EnableScheduling @SpringBootApplication public class Quartz02Application {public static void main(String[] args) {SpringApplication.run(Quartz02Application.class, args);}}案例
讀取數據庫中表達式啟動定時任務1（每5s執行）
更改定時任務狀態（啟用/禁用），定時任務1停止
MyJob
讀取數據庫中表達式啟動定時任務2（每5s執行），在對應作業類中打印定時任務2攜帶的參數
MyJob1
讀取數據庫中表達式啟動定時任務3（每20s執行改成每5s執行），更改數據庫定時任務表達式，定時任務3對應執行策略相應發生改變。
升級案例—簡單版頁面
解決模板[索引]可能不存在，也可能不被任何配置的模板解析器訪問 在pom中添加
<resource><directory>src/main/resources</directory></resource>要用Thymeleaf模板首先去yml文件配置
spring:thymeleaf:cache: falseService層
ScheduleTriggerService
ScheduleTriggerServiceImpl
package com.zxp.quartz02.service.impl;import com.zxp.quartz02.mapper.ScheduleTriggerMapper; import com.zxp.quartz02.mapper.ScheduleTriggerParamMapper; import com.zxp.quartz02.model.ScheduleTrigger; import com.zxp.quartz02.model.ScheduleTriggerParam; import com.zxp.quartz02.service.ScheduleTriggerService; import org.quartz.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service;import java.util.List;/*** @author笑笑* @site www.xiaoxiao.com* @company* @create 2020-01-05 18:40*/ @Service public class ScheduleTriggerServiceImpl implements ScheduleTriggerService {@Autowiredprivate ScheduleTriggerMapper scheduleTriggerMapper;@Autowiredprivate ScheduleTriggerParamMapper scheduleTriggerParamMapper;@Autowiredprivate Scheduler scheduler;@Scheduled(cron = "0/10 * * * * ?")public void refreshScheduler(){try {List<ScheduleTrigger> scheduleTriggers =scheduleTriggerMapper.queryScheduleTriggerLst();if(null!=scheduleTriggers){for (ScheduleTrigger scheduleTrigger : scheduleTriggers) {String cron = scheduleTrigger.getCron(); //表達式String jobName = scheduleTrigger.getJob_name(); //任務名稱String jobGroup = scheduleTrigger.getJob_group(); //任務分組String status = scheduleTrigger.getStatus(); //任務狀態//JobName+JobGroup=Primary Key//根據jobName和jobGroup生成TriggerKeyTriggerKey triggerKey =TriggerKey.triggerKey(jobName, jobGroup);//根據TriggerKey到Scheduler調度器中獲取觸發器CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(triggerKey);if(null==cronTrigger){if(status.equals("0"))continue;System.out.println("創建調度器");//創建任務詳情JobDetail jobDetail=JobBuilder.newJob((Class<? extends Job>) Class.forName(jobName)).withIdentity(jobName,jobGroup).build();//往Job任務中傳遞參數JobDataMap jobDataMap = jobDetail.getJobDataMap();List<ScheduleTriggerParam> params =scheduleTriggerParamMapper.queryScheduleParamLst(scheduleTrigger.getId());for (ScheduleTriggerParam param : params) {jobDataMap.put(param.getName(),param.getValue());}//創建表達式調度器CronScheduleBuilder cronSchedule =CronScheduleBuilder.cronSchedule(cron);//創建TriggercronTrigger= TriggerBuilder.newTrigger().withIdentity(jobName,jobGroup).withSchedule(cronSchedule).build();//將jobDetail和Trigger注入到scheduler調度器中scheduler.scheduleJob(jobDetail,cronTrigger);}else{//System.out.println("Quartz 調度任務中已存在該任務");if(status.equals("0")){JobKey jobKey = JobKey.jobKey(jobName, jobGroup);scheduler.deleteJob(jobKey);continue;}//調度器中的表達式String cronExpression =cronTrigger.getCronExpression();if(!cron.equals(cronExpression)){//創建表達式調度器CronScheduleBuilder cronSchedule =CronScheduleBuilder.cronSchedule(cron);//重構cronTrigger=cronTrigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(cronSchedule).build();//刷新調度器scheduler.rescheduleJob(triggerKey,cronTrigger);}}}}} catch (Exception e) {e.printStackTrace();}}@Overridepublic ScheduleTrigger selectByPrimaryKey(Integer id) {return scheduleTriggerMapper.selectByPrimaryKey(id);}@Overridepublic int updateByPrimaryKeySelective(ScheduleTrigger record) {return scheduleTriggerMapper.updateByPrimaryKeySelective(record);}@Overridepublic List<ScheduleTrigger> queryScheduleTriggerList() {return scheduleTriggerMapper.queryScheduleTriggerLst();} }Controller層
QuartzController
頁面
list.html
edit.html
<!DOCTYPE html> <html xmlns:th="http://www.thymeleaf.org"> <head><meta charset="UTF-8"><title>定時任務修改界面</title> </head> <body> <h1>修改定時任務</h1> <form th:action="@{/quartz/edit}" method="post"><input type="hidden" name="id" th:value="${schedule.id}" />任務表達式： <input width="300px" type="text" name="cron" th:value="${schedule.cron}" /></br>job工作類： <input width="300px" type="text" name="job_name" th:value="${schedule.job_name}" /></br>job分組：<input width="300px" type="text" name="job_group" th:value="${schedule.job_group}" /></br><input type="submit" value="確定"/> </form> </body> </html>
功能就不演示了與上方基本一致。
總結
以上是生活随笔為你收集整理的quartz之动态定时器实现的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 服务器的svnserver修改密码
- 下一篇： xjad反编译遇到break MISSI