spring schedule实现动态配置执行时间

package com.zqf.marketing.task; 

import com.zqf.db.marketingrobot.sys.model.RobotSysSwitch;

import com.zqf.marketing.sys.service.SwitchService;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

import org.springframework.context.annotation.Lazy;

import org.springframework.scheduling.Trigger;

import org.springframework.scheduling.TriggerContext;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.SchedulingConfigurer;

import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import org.springframework.scheduling.support.CronTrigger;

import org.springframework.stereotype.Service;

import java.util.Date;

/**

  * @author zhenghao

  * @description

  * @date 2019/1/22 21:50

  */

@Lazy ( false )

@Service

@EnableScheduling

public class TestTaskService implements SchedulingConfigurer {

     private static Logger log = LoggerFactory.getLogger(TestTaskService. class );

     @Autowired

     private SwitchService switchService;

     private String SpringDynamicCronTask() {

         String cron = "0/5 * * * * ?" ;

         //从数据库获得配置的corn表达式

         RobotSysSwitch switchById = switchService.getSwitchById(5L);

         cron = switchById.getSwitchFlag();

         log.info(cron);

         return cron;

     }

     @Override

     public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {

         scheduledTaskRegistrar.addTriggerTask( new Runnable() {

             @Override

             public void run() {

                 // 任务逻辑

                 log.info( "task_task_tak" );

             }

         }, new Trigger() {

             @Override

             public Date nextExecutionTime(TriggerContext triggerContext) {

                 String s = SpringDynamicCronTask();

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

                 CronTrigger trigger = new CronTrigger(s);

                 Date nextExec = trigger.nextExecutionTime(triggerContext);

                 return nextExec;

             }

         }); 

     }

}

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

import org.springframework.scheduling.Trigger;

import org.springframework.scheduling.TriggerContext;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.SchedulingConfigurer;

import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import org.springframework.scheduling.support.PeriodicTrigger;

import org.springframework.stereotype.Component;

import java.util.Date;

@Component

@EnableScheduling

public class DynamicScheduleTaskSecond implements SchedulingConfigurer {

     private static final long WEEK_MILLIS = 604800000 ;

     private static final long MIN_MILLIS = 1000 ;

     private static long period = 1000 ;

     static long l = System.currentTimeMillis();

     @Autowired

     SetPeriod setPeriod;

     public static long getPeriod() {

         return period;

     }

     public static void setPeriod( long period) {

         DynamicScheduleTaskSecond.period = period;

     }

     @Override

     public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

         taskRegistrar.addTriggerTask( new Runnable() {

             @Override

             public void run() {

                 try {

                     setPeriod.update(period);

                     System.out.println( "abc" );

                     Long last = System.currentTimeMillis() - l;

                     l = System.currentTimeMillis();

                     System.out.println(last);

                 } catch (Exception e) {

                     e.printStackTrace();

                 }

             }

         }, new Trigger() {

             @Override

             public Date nextExecutionTime(TriggerContext triggerContext) {

                 if (period < MIN_MILLIS || period > WEEK_MILLIS)

                     period = MIN_MILLIS;

                 PeriodicTrigger periodicTrigger = new PeriodicTrigger(period);

                 Date nextExecDate = periodicTrigger.nextExecutionTime(triggerContext);

                 return nextExecDate;

             }

         });

     }

}

import org.springframework.stereotype.Component;

@Component

public class SetPeriod {

     private static Long maxPeriod = 1000l;

     public void update(Long period) {

         maxPeriod += 1000 ;

         setScheduleConfig(maxPeriod);

     }

     public boolean setScheduleConfig(Long period) {

         DynamicScheduleTaskSecond.setPeriod(period);

         return true ;

     }

}

@FunctionalInterface

public interface SchedulingConfigurer {

  /**

   * Callback allowing a {@link org.springframework.scheduling.TaskScheduler

   * TaskScheduler} and specific {@link org.springframework.scheduling.config.Task Task}

   * instances to be registered against the given the {@link ScheduledTaskRegistrar}.

   * @param taskRegistrar the registrar to be configured.

   */

  void configureTasks(ScheduledTaskRegistrar taskRegistrar);

}

public void addTriggerTask(Runnable task, Trigger trigger) {

     this .addTriggerTask( new TriggerTask(task, trigger));

}

public interface Trigger {

     @Nullable

     Date nextExecutionTime(TriggerContext var1);

}