springboot整合Quartz实现动态配置定时任务的方法
前言
在我们日常的开发中，很多时候，定时任务都不是写死的，而是写到数据库中，从而实现定时任务的动态配置，下面就通过一个简单的示例，来实现这个功能。
一、新建一个springboot工程，并添加依赖
org.springframework.boot spring-boot-starter-data-jpa com.h2database h2 runtime org.springframework.boot spring-boot-starter-test test org.quartz-scheduler quartz 2.2.1 slf4j-api org.slf4j org.springframework spring-context-support
二、配置文件application.properties
#服务器端口号 server.port=7902 #是否生成ddl语句 spring.jpa.generate-ddl=false #是否打印sql语句 spring.jpa.show-sql=true #自动生成ddl，由于指定了具体的ddl，此处设置为none spring.jpa.hibernate.ddl-auto=none #使用H2数据库 spring.datasource.platform=h2 #指定生成数据库的schema文件位置 spring.datasource.schema=classpath:schema.sql #指定插入数据库语句的脚本位置 spring.datasource.data=classpath:data.sql #配置日志打印信息 logging.level.root=INFO logging.level.org.hibernate=INFO logging.level.org.hibernate.type.descriptor.sql.BasicBinder=TRACE logging.level.org.hibernate.type.descriptor.sql.BasicExtractor=TRACE logging.level.com.itmuch=DEBUG
三、Entity类
packagecom.chhliu.springboot.quartz.entity;
importjavax.persistence.Column;
importjavax.persistence.Entity;
importjavax.persistence.GeneratedValue;
importjavax.persistence.GenerationType;
importjavax.persistence.Id;
@Entity
publicclassConfig{
@Id
@GeneratedValue(strategy=GenerationType.AUTO)
privateLongid;
@Column
privateStringcron;
/**
*@returntheid
*/
publicLonggetId(){
returnid;
}
……此处省略getter和setter方法……
}
四、任务类
packagecom.chhliu.springboot.quartz.entity;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.scheduling.annotation.EnableScheduling;
importorg.springframework.stereotype.Component;
@Configuration
@Component//此注解必加
@EnableScheduling//此注解必加
publicclassScheduleTask{
privatestaticfinalLoggerLOGGER=LoggerFactory.getLogger(ScheduleTask.class);
publicvoidsayHello(){
LOGGER.info("Helloworld,i'mthekingoftheworld!!!");
}
}
五、Quartz配置类
由于springboot追求零xml配置，所以下面会以配置Bean的方式来实现
packagecom.chhliu.springboot.quartz.entity;
importorg.quartz.Trigger;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.scheduling.quartz.CronTriggerFactoryBean;
importorg.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
importorg.springframework.scheduling.quartz.SchedulerFactoryBean;
@Configuration
publicclassQuartzConfigration{
/**
*attention:
*Details：配置定时任务
*/
@Bean(name="jobDetail")
publicMethodInvokingJobDetailFactoryBeandetailFactoryBean(ScheduleTasktask){//ScheduleTask为需要执行的任务
MethodInvokingJobDetailFactoryBeanjobDetail=newMethodInvokingJobDetailFactoryBean();
/*
*是否并发执行
*例如每5s执行一次任务，但是当前任务还没有执行完，就已经过了5s了，
*如果此处为true，则下一个任务会执行，如果此处为false，则下一个任务会等待上一个任务执行完后，再开始执行
*/
jobDetail.setConcurrent(false);
jobDetail.setName("srd-chhliu");//设置任务的名字
jobDetail.setGroup("srd");//设置任务的分组，这些属性都可以存储在数据库中，在多任务的时候使用
/*
*为需要执行的实体类对应的对象
*/
jobDetail.setTargetObject(task);
/*
*sayHello为需要执行的方法
*通过这几个配置，告诉JobDetailFactoryBean我们需要执行定时执行ScheduleTask类中的sayHello方法
*/
jobDetail.setTargetMethod("sayHello");
returnjobDetail;
}
/**
*attention:
*Details：配置定时任务的触发器，也就是什么时候触发执行定时任务
*/
@Bean(name="jobTrigger")
publicCronTriggerFactoryBeancronJobTrigger(MethodInvokingJobDetailFactoryBeanjobDetail){
CronTriggerFactoryBeantigger=newCronTriggerFactoryBean();
tigger.setJobDetail(jobDetail.getObject());
tigger.setCronExpression("03020**?");//初始时的cron表达式
tigger.setName("srd-chhliu");//trigger的name
returntigger;
}
/**
*attention:
*Details：定义quartz调度工厂
*/
@Bean(name="scheduler")
publicSchedulerFactoryBeanschedulerFactory(TriggercronJobTrigger){
SchedulerFactoryBeanbean=newSchedulerFactoryBean();
//用于quartz集群,QuartzScheduler启动时更新己存在的Job
bean.setOverwriteExistingJobs(true);
//延时启动，应用启动1秒后
bean.setStartupDelay(1);
//注册触发器
bean.setTriggers(cronJobTrigger);
returnbean;
}
}
六、定时查库，并更新任务
packagecom.chhliu.springboot.quartz.entity;
importjavax.annotation.Resource;
importorg.quartz.CronScheduleBuilder;
importorg.quartz.CronTrigger;
importorg.quartz.JobDetail;
importorg.quartz.Scheduler;
importorg.quartz.SchedulerException;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.scheduling.annotation.EnableScheduling;
importorg.springframework.scheduling.annotation.Scheduled;
importorg.springframework.stereotype.Component;
importcom.chhliu.springboot.quartz.repository.ConfigRepository;
@Configuration
@EnableScheduling
@Component
publicclassScheduleRefreshDatabase{
@Autowired
privateConfigRepositoryrepository;
@Resource(name="jobDetail")
privateJobDetailjobDetail;
@Resource(name="jobTrigger")
privateCronTriggercronTrigger;
@Resource(name="scheduler")
privateSchedulerscheduler;
@Scheduled(fixedRate=5000)//每隔5s查库，并根据查询结果决定是否重新设置定时任务
publicvoidscheduleUpdateCronTrigger()throwsSchedulerException{
CronTriggertrigger=(CronTrigger)scheduler.getTrigger(cronTrigger.getKey());
StringcurrentCron=trigger.getCronExpression();//当前Trigger使用的
StringsearchCron=repository.findOne(1L).getCron();//从数据库查询出来的
System.out.println(currentCron);
System.out.println(searchCron);
if(currentCron.equals(searchCron)){
//如果当前使用的cron表达式和从数据库中查询出来的cron表达式一致，则不刷新任务
}else{
//表达式调度构建器
CronScheduleBuilderscheduleBuilder=CronScheduleBuilder.cronSchedule(searchCron);
//按新的cronExpression表达式重新构建trigger
trigger=(CronTrigger)scheduler.getTrigger(cronTrigger.getKey());
trigger=trigger.getTriggerBuilder().withIdentity(cronTrigger.getKey())
.withSchedule(scheduleBuilder).build();
//按新的trigger重新设置job执行
scheduler.rescheduleJob(cronTrigger.getKey(),trigger);
currentCron=searchCron;
}
}
}
六、相关脚本
1、data.sql
insertintoconfig(id,cron)values(1,'00/2***?');#每2分钟执行一次定时任务
2、schema.sql
droptableconfigifexists; createtableconfig( idbigintgeneratedbydefaultasidentity, cronvarchar(40), primarykey(id) );
六、运行测试
测试结果如下：(Quartz默认的线程池大小为10)
03020**? 00/2***? 2017-03-0818:02:00.025INFO5328---[eduler_Worker-1]c.c.s.quartz.entity.ScheduleTask:Helloworld,i'mthekingoftheworld!!! 2017-03-0818:04:00.003INFO5328---[eduler_Worker-2]c.c.s.quartz.entity.ScheduleTask:Helloworld,i'mthekingoftheworld!!! 2017-03-0818:06:00.002INFO5328---[eduler_Worker-3]c.c.s.quartz.entity.ScheduleTask:Helloworld,i'mthekingoftheworld!!! 2017-03-0818:08:00.002INFO5328---[eduler_Worker-4]c.c.s.quartz.entity.ScheduleTask:Helloworld,i'mthekingoftheworld!!!
从上面的日志打印时间来看，我们实现了动态配置，最初的时候，任务是每天20:30执行，后面通过动态刷新变成了每隔2分钟执行一次。
虽然上面的解决方案没有使用Quartz推荐的方式完美，但基本上可以满足我们的需求，当然也可以采用触发事件的方式来实现，例如当前端修改定时任务的触发时间时，异步的向后台发送通知，后台收到通知后，然后再更新程序，也可以实现动态的定时任务刷新
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。