spring schedule 动态配置执行时间

引言

之前saas平台实现动态修改定时任务的时间，都是通过xx-job这样的框架来实现，这样我们可以单独一个服务来管理我们整个saas平台的定时任务，但是最近给银行做的一个小项目，需要本地化部署，所以我不想弄很多的服务，并且他们并没有要求修改以后即时生效，所以我直接采用了 spring schedule结合mysql动态配置执行时间。

之前我们用的schedule通过注解的方式，只能用静态的corn表达式，如果想实现动态的需要实现SchedulingConfigurer，并且通过注解@EnableScheduling。如下：

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;             }         });       } }

这样我们就可以动态的修改task的执行时间，生效时间为，上一个任务的执行周期，也可以满足我们现在需求，这样就可以实习项目更加的灵活！