SpringBoot项目中使用@Scheduled读取动态参数

application.propertites：

read.timer.parmas= 0 0 / 1 * * * *

@Component

public class ScheduledService {

Logger logger= LoggerFactory.getLogger(ScheduledService. class );

     @Scheduled (cron = "${read.timer.parmas}" )

     public void readConfigTable(){

         logger.info( "*****.read.timer.parmas" );

     }

}

@SpringBootApplication

@EnableScheduling   //必须

public class DataApplication {

   public static void main(String[] args) {

         SpringApplication.run(DataApplication. class ,args);

     }

}

@Component

@EnableScheduling

public class TestScheduledParams implements SchedulingConfigurer{

     Logger logger= LoggerFactory.getLogger(TestScheduledParams. class );

     public static   String DEFAULT_CORN= "0/3 * * * * *" ;

     //##动态传参要给默认值。

     public static String corn=DEFAULT_CORN;

     @Override

     public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

         taskRegistrar.addTriggerTask( new Runnable() {

             @Override

             public void run() {

                // logger.info("定时任务逻辑");

             }

         }, new Trigger() {

             @Override

             public Date nextExecutionTime(TriggerContext triggerContext) {

                 //任务触发，可修改任务的执行周期

                 CronTrigger cronTrigger = new CronTrigger(corn);

                 Date date = cronTrigger.nextExecutionTime(triggerContext);

                 return date;

             }

         });

     }

}

TestScheduledParams.corn= "0/20 * * * * *"

package cn.com.suntree.cmp.service;

import cn.com.suntree.cmp.utils.CommonUtil;

import lombok.extern.log4j.Log4j2;

import org.apache.commons.lang3.StringUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.Trigger;

import org.springframework.scheduling.TriggerContext;

import org.springframework.scheduling.annotation.SchedulingConfigurer;

import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import org.springframework.scheduling.support.CronTrigger;

import org.springframework.stereotype.Component;

import redis.clients.jedis.Jedis;

import java.util.Date;

@Component

@Log4j2

public class MyDynamicTask implements SchedulingConfigurer { //实现SchedulingConfigurer 接口

     @Autowired

     CommonUtil commonUtil;

     @Autowired

     TaskService taskService;

     private static String cron;

     @Override

     public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { //重写该方法

         scheduledTaskRegistrar.addTriggerTask(doTask(), getTrigger());

     }

     private Runnable doTask() {

         return new Runnable() {

             @Override

             public void run() {

                 log.info( "-------------------------------执行" +cron);

                 taskService.monDay(); //真正需要运行的逻辑代码

             }

         };

     }

     private Trigger getTrigger() {

         return new Trigger() {

             @Override

             public Date nextExecutionTime(TriggerContext triggerContext) {

                 // 触发器

                 CronTrigger trigger = new CronTrigger(getCron());

                 return trigger.nextExecutionTime(triggerContext);

             }

         };

     }

     public String getCron() {

         Jedis jedis = commonUtil.getJedis();

         String newCron =  jedis.get( "cron" ); //可以改成配置到数据库中

         if (StringUtils.isEmpty(newCron)) {

             jedis.set( "cron" , "0 30 0 ? * Mon" );

             return "0 30 0 ? * Mon" ;

         }

         if (!newCron.equals(cron)) {

             log.info( new StringBuffer( "Cron has been changed to:'" ).append(newCron).append( "'. Old cron was:'" ).append(cron).append( "'" ).toString());

             cron = newCron;

         }

         return cron;

     }

}