你需要的spring定时任务讲解+案例都在这里

本文目录：

• 定时任务概述、原理

• 基于注解（@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 ...

完！