本文将介绍Spring计划任务ScheduledTask的概念、相关引入参数表达式及其使用场景。首先,我们来看一下简单概念介绍。
在Spring 5.0中,我们通过添加@EnableScheduling注解来开始支持计划任务。在需要计划任务的方法上,我们需要添加@Scheduled注解,并在方法上进行声明。
接下来,我们来看一下@EnableScheduling的实现。这个注解是由SchedulingConfiguration类来完成的。以下是相关的代码:
```java
package org.springframework.scheduling.annotation;
import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.context.annotation.Import;
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Import({SchedulingConfiguration.class})
@Documented
public @interface EnableScheduling {
}
```
最后,我们来看一下SchedulingConfiguration类。在这个类中,它负责注册一个ScheduledAnnotationBeanPostProcessor,以便在后续的处理过程中使用。
```java
package org.springframework.scheduling.annotation;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Role;
@Configuration
public class SchedulingConfiguration {
public SchedulingConfiguration() {
}
@Bean(name = {"org.springframework.context.annotation.internalScheduledAnnotationProcessor"})
@Role(2)
public ScheduledAnnotationBeanPostProcessor scheduledAnnotationProcessor() {
return new ScheduledAnnotationBeanPostProcessor();
}
}
```
关于@Scheduled的三个属性:Cron expression、fixedDelay和fixedRate,Cron表达式是一个字符串,字符串以5或6个空格隔开,分为6或7个域,每一个域代表一个含义。Cron有如下两种语法格式:
1. Seconds Minutes Hours DayofMonth Month DayofWeek Year
2. Seconds Minutes Hours DayofMonth Month DayofWeek
每一个域可出现的字符如下:
- Seconds: 可出现`, `- `* `/`四个字符,有效范围为0-59的整数
- Minutes: 可出现`, `- `* `/`四个字符,有效范围为0-59的整数
- Hours: 可出现`, `- `* `/`四个字符,有效范围为0-23的整数
以下是重构后的内容:
- DayofMonth:可出现"、-*/? L W C"八个字符,有效范围为0-31的整数。
- Month:可出现"、-*/"四个字符,有效范围为1-12的整数或JAN-DEC。
- DayofWeek:可出现"、-*/ ? L C #"四个字符,有效范围为1-7的整数或SUN-SAT两个范围。1表示星期天,2表示星期一,依次类推。
- Year:可出现"、-*/"四个字符,有效范围为1970-2099年。
每个域都使用数字,但还可以出现如下特殊字符,它们的含义是:
- ":"表示匹配该域的任意值,假如在Minutes域使用。
- ",":即表示每分钟都会触发事件。
- "?":只能用在DayofMonth和DayofWeek两个域。它也匹配域的任意值,但实际不会。因为DayofMonth和DayofWeek会相互影响。例如想在每月的20日触发调度,不管20日到底是星期几,则只能使用如下写法:13 13 15 20 * ?,其中最后一位只能用?,而不能使用","。如果使用","表示不管星期几都会触发,实际上并不是这样。
- "-":表示范围,例如在Minutes域使用5-20,表示从5分到20分钟每分钟触发一次。
- "/":表示起始时间开始触发,然后每隔固定时间触发一次,例如在Minutes域使用5/20,则意味着5分钟触发一次,而25、45等分别触发一次。
- ",":表示列出枚举值值。例如:在Minutes域使用5,20,则意味着在5和20分每分钟触发一次。
- "L":表示最后,只能出现在DayofWeek和DayofMonth域。如果在DayofWeek域使用5L,意味着在最后的一个星期四触发。
- "W":表示有效工作日(周一到周五),只能出现在DayofMonth域。系统将在离指定日期的最近的有效工作日触发事件。例如:在DayofMonth使用5W,如果5日是星期六,则将在最近的工作日:星期五,即4日触发。如果5日是星期天,则在6日(周一)触发;如果5日在星期一到星期五中的一天,则就在5日触发。另外一点,W的最近寻找不会跨过月份。
- "LW":这两个字符可以连用,表示在某个月最后一个工作日,即最后一个星期五。
#:用于确定每个月第几个星期几,只能出现在DayofMonth域。例如在4#2,表示某月的第二个星期三。
fixedRate和fixedDelay的区别:
fixedDelay非常好理解,它的间隔时间是根据上次的任务结束的时候开始计时的。比如一个方法上设置了fixedDelay=5*1000,那么当该方法某一次执行结束后,开始计算时间,当时间达到5秒,就开始再次执行该方法。
fixedRate理解起来比较麻烦,它的间隔时间是根据上次任务开始的时候计时的。
比如当方法上设置了fiexdRate=5 * 1000, 该执行该方法所花的时间是2秒,那么3秒后就会再次执行该方法。但是这里有个坑,当任务执行时长超过设置的间隔时长,那会是什么结果呢。打个比方,比如一个任务本来只需要花2秒就能执行完成,我所设置的fixedRate=5*1000,但是因为网络问题导致这个任务花了7秒才执行完成。当任务开始时Spring就会给这个任务计时,5秒钟时候Spring就会再次调用这个任务,可是发现原来的任务还在执行,这个时候第二个任务就阻塞了(这里只考虑单线程的情况下,多线程后面再讲),甚至如果第一个任务花费的时间过长,还可能会使第三第四个任务被阻塞。被阻塞的任务就像排队的人一样,一旦前一个任务没了,它就立马执行。
代码示例:
```java
@Scheduled(cron = "0 0/5 * * * ?") // 每隔5分钟执行一次
public void fixedRateTask() {
System.out.println("fixedRateTask executed at " + LocalDateTime.now());
}
@Scheduled(fixedDelay = 5000) // 延迟5秒后执行
public void fixedDelayTask() {
System.out.println("fixedDelayTask executed at " + LocalDateTime.now());
}
```
以下是重构后的代码:
```java
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* @description: 计划任务执行类
* @author: Shenshuaihu
* @version: 1.0
* @data: 2019-05-28 23:29
*/
@Service
public class ScheduledTaskService {
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
/**
* 通过@Scheduled声明改方法是计划任务,使用fixedRate属性每隔固定时间执行
*/
@Scheduled(fixedRate = 5000)
public void reportCurrentTime() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("每隔五秒执行一次 fixedRate" + dateFormat.format(new Date()));
}
/**
* cron 属性可按照指定时间执行 每七秒执行一次
*/
@Scheduled(cron = "0/7 10 * * * ?")
public void fixTimeExecution() {
System.out.println("在指定时间执行 " + dateFormat.format(new Date()));
}
/**
* 通过@Scheduled声明改方法是计划任务,使用fixedDelay属性每隔固定时间执行
* 间隔时间是根据上次任务开始的时候计时的,即使方法执行话时间。
*/
@Scheduled(fixedDelay = 5000)
public void report2CurrentTime() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("每隔五秒执行一次 fixedDelay " + dateFormat.format(new Date()));
}
}
```
计划任务配置类:
```java
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
@Configuration
@ComponentScan(value = "com.ch3.taskscheduler")
@EnableScheduling
public class TaskSchedulerConfig {
}
```
定时计划启动入口:
```java
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
public class SchedulerMain {
public static void main(String[] args) {
AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TaskSchedulerConfig.class);
}
}
```
您好!在SpringBoot中,如果需要查询10W数据来更新定时任务,可以选择用时间参数来限制查询的数量。具体实现方法可以参考王云飞的springboot实战一书。此外,CSDN博客中也有一篇关于springboot如何定时任务的文章,其中提到了使用@Scheduled注解设置定时任务的执行时间,如@Scheduled (cron = "0/5 * * * * *") 每五秒执行一次。如果您需要动态配置定时任务的执行时间,可以使用Quartz库或者Spring Task。