本文目录：
- 定时任务概述、原理
- 基于注解（@Scheduled）的定时任务
- 基于接口（SchedulingConfigurer）的定时任务
- 可更改时间的定时任务
一、定时任务概述、原理
概述:开发中经常会使用到定时任务，顾名思义,定时任务就是定时执行的方法,即定时执行的代码。比如，为了减少服务器或者数据库的压力，我们会将一些对服务器或者数据库等有压力的高频操作，改为定时去执行，例如每晚凌晨0点同步A系统的数据到B系统，每2小时统计用户的积分情况，每周一给支付宝用户推送上周收入支出数据报表等。一 般情况下，很多业务处理会定时在凌晨处理，因为避开了户使用高峰期，服务器资源充足，而且对用户影响小。
原理：spring在初始化bean后，通过“postProcessAfterInitialization”拦截到所有的用到“@Scheduled”注解的方法，并解析相应的的注解参数，放入“定时任务列表”等待后续处理;之后再“定时任务列表”中统一执行相应的定时任务(任务为顺序执行，先执行cron，之后再执行fixedRate)。
二、基于注解（@Scheduled）的定时任务
需要注意的是@Scheduled默认是串行的，单线程，当开启多个任务时，任务的执行时机会受上一个任务执行时间的影响。
@Configuration
@EnableScheduling //开启定时任务
public class ScheduleTask {
//每10秒执行一次
@Scheduled(cron = "0/10 * * * * ?")
private void configureTasks() {
System.out.println("我是一个定时任务");
}
}
@Scheduled 除了cron还提供另外三种种方式: fixedRate，fixedDelay，initialDelay
1、cron表达式可以定制化执行任务，但是执行的方式是与fixedDelay相近的，也是会按照上一次方法结束时间开始算起。
2、fixedDelay控制方法执行的间隔时间，是以上一次方法执行完开始算起，如上一次方法执行阻塞住了，那么直到上一次执行完，并间隔给定的时间后，执行下一次。
@Configuration
@EnableScheduling //开启定时任务
public class ScheduleTask {
//每10秒执行一次
@Scheduled(fixedDelay = 10000)
private void configureTasks() {
System.out.println("我是一个定时任务");
}
}
3、fixedRate是按照一定的速率执行，是从上一次方法执行开始的时间算起，如果上一次方法阻塞住了，下一次也是不会执行，但是在阻塞这段时间内累计应该执行的次数，当不再阻塞时，一下子把这些全部执行掉，而后再按照固定速率继续执行。
@Configuration
@EnableScheduling //开启定时任务
public class ScheduleTask {
//每10秒执行一次
@Scheduled(fixedRate = 10000)
private void configureTasks() {
System.out.println("我是一个定时任务");
}
}
4、initialDelay = 10000 表示在容器启动后，延迟10秒后再执行一次定时器。
@Configuration
@EnableScheduling //开启定时任务
public class ScheduleTask {
//容器启动后,延迟10秒后再执行一次定时器,以后每10秒再执行一次该定时器。
@Scheduled(initialDelay = 10000, fixedRate = 10000)
private void configureTasks() {
System.out.println("我是一个定时任务");
}
}
三、基于接口（SchedulingConfigurer）的定时任务
有些程序员可能发现，使用@Scheduled 注解很方便，但缺点是当我们调整了执行周期的时候，需要重启应用才能生效，这多少有些不方便。为了达到实时生效的效果，那么可以使用接口来完成定时任务。
下面案例从数据中获取执行周期时间，然后动态执行定时任务：
@Configuration
@EnableScheduling //开启定时任务
public class DynamicScheduleTask implements SchedulingConfigurer {
//从数据获取任务执行周期
@Autowired
private MyBatisMapper myBatisMapper;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.addTriggerTask(
//1.添加任务内容(Runnable)
() -> System.out.println("执行动态定时任务: " + LocalDateTime.now().toLocalTime()),
//2.设置执行周期(Trigger)
triggerContext -> {
//2.1从数据库获取执行周期
String cron = myBatisMapper.getCron();
//2.2 返回执行周期(Date)
return new CronTrigger(cron).nextExecutionTime(triggerContext);
}
);
}
}
数据库表数据如下：
现在，我们启动测试看看
执行动态定时任务: 17:17:00.008999
执行动态定时任务: 17:17:20.002501
执行动态定时任务: 17:17:30.001786
执行动态定时任务: 17:17:40.005512
执行动态定时任务: 17:17:50.005870
执行动态定时任务: 17:18:00.002189
执行动态定时任务: 17:18:10.001910
我们可以看到每10秒执行一次任务。那么现在要求每5秒执行一次，该怎么做呢？这个时候我们只需要修改下数据库数据即可，无需重启。
现在，我们再看看控制台打印的是什么？
执行动态定时任务: 17:18:30.000902
执行动态定时任务: 17:18:40.001392
执行动态定时任务: 17:18:45.005027
执行动态定时任务: 17:18:50.001367
执行动态定时任务: 17:18:55.001356
执行动态定时任务: 17:19:00.001582
执行动态定时任务: 17:19:05.005676
执行动态定时任务: 17:19:10.001258
执行动态定时任务: 17:19:15.005272
成功每5秒执行一次。是不是很有成就感，哈哈
四、可更改时间的定时任务
案例如下：
package com.nobody.task;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
/**
* @Description 可动态更改时间的定时任务
* @Author Mr.nobody
* @Date 2021/3/4
* @Version 1.0.0
*/
@Component
public class ChangeTimeScheduledTask implements SchedulingConfigurer {
private static final Logger LOGGER = LoggerFactory.getLogger(ChangeTimeScheduledTask.class);
// cron表达式，我们动态更改此属性的值即可更改定时任务的执行时间
private String expression = "0/5 * * * * *";
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
// 定时任务要执行的方法
Runnable task = () -> LOGGER.info(">>> configureTasks ...");
// 调度实现的时间控制
Trigger trigger = triggerContext -> {
CronTrigger cronTrigger = new CronTrigger(expression);
return cronTrigger.nextExecutionTime(triggerContext);
};
taskRegistrar.addTriggerTask(task, trigger);
}
public String getExpression() {
return expression;
}
public void setExpression(String expression) {
this.expression = expression;
}
}
接口调用：
package com.nobody.controller;
import com.nobody.task.ChangeTimeScheduledTask;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @Description
* @Author Mr.nobody
* @Date 2021/3/4
* @Version 1.0.0
*/
@RestController
@RequestMapping("demo")
public class DemoController {
private ChangeTimeScheduledTask changeTimeScheduledTask;
public DemoController(final ChangeTimeScheduledTask changeTimeScheduledTask) {
this.changeTimeScheduledTask = changeTimeScheduledTask;
}
@GetMapping
public String testChangeTimeScheduledTask() {
changeTimeScheduledTask.setExpression("0/10 * * * * *");
return "ok";
}
}
启动服务，没调用接口之前，定时任务是每5秒执行一次
2021-03-04 14:02:10.001 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
2021-03-04 14:02:15.001 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
2021-03-04 14:02:20.002 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
2021-03-04 14:02:25.001 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
然后我们调用接口，改变定时任务的时间，结果变为每10秒执行一次。
2021-03-04 14:02:30.005 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
2021-03-04 14:02:35.002 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
2021-03-04 14:02:40.001 INFO 6836 --- [TaskScheduler-1] com.nobody.task.ChangeTimeScheduledTask : >>> configureTasks ...
完！