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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。