Java定时任务实现方案(四)—

Spring Task

这篇笔记，我们要来介绍实现Java定时任务的第四个方案，使用Spring Task，以及该方案的优点和缺点。

Spring Task是Spring框架提供的一个轻量级任务调度框架，用于简化任务调度的开放，通过注解或XML配置的方式，可以轻松实现定时任务、异步任务等功能，我们这里主要介绍它的定时任务。

使用

1.添加依赖

既然要使用Spring框架提供的SpringTask，我们就要引入相关的依赖，同时，我们后面要通过自定义注解+AOP的方式实现任务监听，所以也要引入SpringAop的相关依赖

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><version>3.3.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>3.3.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId><version>3.3.0</version></dependency>

2.启用定时任务支持

要使用SpringTask实现定时任务，我们首先要启用定时任务支持，这个我们只需要在Spring应用的启动类上加上@EnableScheduling就可以了。

@SpringBootApplication
@EnableScheduling
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class,args);}
}

3.配置定时任务注册器

我们可以通过配置类，对SpringTask执行定时任务的调度器进行相关的配置和初始化，并注册到Spring容器中，便于统一管理调度任务。

@Configuration
@EnableScheduling
public class SchedulingConfig implements SchedulingConfigurer {/*** 配置定时任务处理方式** @param taskRegistrar 定时任务注册器，用于管理和调度定时任务*/@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {// 创建一个线程池任务调度器ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();//设置线程池大小taskScheduler.setPoolSize(10);// 设置线程名称前缀，便于识别和管理taskScheduler.setThreadNamePrefix("perform-");// 初始化线程池任务调度器taskScheduler.initialize();// 将任务调度器设置到定时任务注册器中，以便统一管理调度任务taskRegistrar.setTaskScheduler(taskScheduler);}
}

4.创建定时任务

接着，我们就可以编写定时任务了，这里我们采用注解的形式提供示例。只需要在外面的定时方法上面加上一个@Scheduled注解，Spring容器就可以帮我们实现定时任务了。这个@Scheduled注解可以设置一些参数便于更灵活的调度任务，例如fixedRate参数可以让我们设置间隔多长时间执行一次、initialDelay参数可以设置第一次执行任务前延迟的时间，fixedDelay参数也可以设置每一次延迟多长时间再执行定时任务。同时，该注解还支持使用cron表达式来灵活的设置任务调度的方式。

@Component
@ConditionalOnProperty(prefix = "scheduled",name = "task.enabled",havingValue = "true")//条件注解控制定时任务的启用和禁用
public class ScheduledTask {/*** 每5s执行一次*/@Scheduled(fixedRate = 5000)@TaskListenerpublic void performTask1(){System.out.println(getTime()+"执行定时任务1");}/*** 每分钟的第10s执行一次*/@Scheduled(cron = "10 * * * * ?")@TaskListenerpublic void performTask2(){System.out.println(getTime()+"执行定时任务2");}/*** 第一次执行任务前的延迟时间1s,后面每隔5s执行一次*/@Scheduled(initialDelay = 1000,fixedDelay = 5000)@TaskListenerpublic void performTask3(){System.out.println(getTime()+"执行定时任务3");}/*** 获取当前系统时间* @return*/public static String getTime(){//获取当前的系统时间LocalDateTime now = LocalDateTime.now();//定义时间格式DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");//格式化时间return now.format(formatter);}
}

这里需要补充的是，我们可以使用条件注解来控制定时任务的启动或禁止。

scheduled:task:enabled: true

补充知识点:cron表达式

cron表达式是一种用于指定定时任务执行时间的字符串格式，广泛用于Linux系统的cron作业调度器以及各种编程框架中。

一个标准的CRON表达式由6个或7个字段组成(取决于是否包含年份字段)，各字段之间用空格分隔:[秒] [分钟] [小时] [日期] [月份] [星期] [年份] (可选)

各字段的取值范围如下:

字段	范围
秒	0-59
分钟	0-59
小时	0-23
日期	1-31
月份	1-12或JAN-DEC
星期	0-7或SUN-SAT(0和7都表示星期日)
年份	(可选)1970-2099

常见符号说明:

符号	含义
*	表示该字段的所有可能值，例如*在分钟字段表示每分钟
,	分隔多个具体的值，例如1,15表示第1分钟和第15分钟
-	定义一个值范围，例如10-15表示从第10分钟到第15分钟
/	指定增量，例如*/5表示每隔5个单位执行一次
?	用于日期或星期字段，表示不指定明确的值，通常用于其中一个字段时，另一个字段有具体值
L	表示最后一天或最后一个工作日，例如L在日期字段表示每月最后一天。
W	表示最近的工作日，例如15W表示离15号最近的工作日
#	用于星期字段，表示某个月的第几个星期几，例如2#3表示每月的第三个星期二

注意:cron表达式的星期和日期不能同时为具体的值，如果同时指定具体的值，可能会导致逻辑冲突或不明确的行为。

示例:

cron表达式	含义
0 30 * * * ?	每小时第30分钟执行
0 0 2 * * ?	每天凌晨2点执行
0 0 8 ? * MON	每周一的上午8点执行
0 0 0 L * ?	每月的最后一天的午夜执行
0 0/5 * * * ?	每5分钟执行一次

5.通过自定义注解+AOP实现任务监听(可选)

如果需要对定时任务进行监听并做出其他相应的处理的话，我们还可以自己通过自定义注解+AOP的方式实现任务监听器来进行监听处理。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface TaskListener {
}

@Component
@Aspect
public class TaskListenerAspect {@Before("@annotation(xiaoxin.Timer.SpringTask.TaskListener)")public void beforeTask(JoinPoint joinPoint){System.out.println("task:"+joinPoint.getSignature().getName()+" 即将开始...");}@After("@annotation(xiaoxin.Timer.SpringTask.TaskListener)")public void afterTask(JoinPoint joinPoint){System.out.println("task:"+joinPoint.getSignature().getName()+" 已结束...");}
}