本文引用了谷粒商城的课程
定时任务
定时任务是我们系统里面经常要用到的一些功能。如每天的支付订单要与支付宝进行对账操作、每个月定期进行财务汇总、在服务空闲时定时统计当天所有信息数据等。
定时任务有个非常流行的框架Quartz和Java原生API的Timer类。Spring框架也可以支持定时任务。
cron表达式
语法：秒 分 时 日 月 周 年（Spring 不支持）
http://www.quartz-scheduler.org/documentation/quartz-2.3.0/tutorials/crontrigger.html
特殊字符：
，：枚举: (cron=“7,9,23 * * * * ?”)：任意时刻的 7,9，23 秒启动这个任务；
-：范围： (cron=“7-20 * * * * ?”):任意时刻的 7-20 秒之间，每秒启动一次
()* ：任意；指定位置的任意时刻都可以
/：步长； (cron=“7/5 * * * * ?”)：第 7 秒启动，每 5 秒一次；(cron=“/5 * * * * ?“)：任意秒启动，每 5 秒一次；
？：（出现在日和周几的位置）：为了防止日和周冲突，在周和日上如果要写通配符使用?(cron=” * * 1 * ?”)：每月的 1 号，启动这个任务；
L：（出现在日和周的位置）”， last：最后一个 (cron=“* * * ? * 3L”)：每月的最后一个周二
W：Work Day：工作日 (cron=“* * * W * ?”)：每个月的工作日触发 (cron=“* * * LW * ?”)：每个月的最后一个工作日触发
#：第几个 (cron=“* * * ? * 5#2”)：每个月的第 2 个周 4
注意：日和周几通常会发生冲突，如果日定了，那么周就要使用？通配符
可以在线生成cron表达式
https://cron.qqe2.com/
cron实例
SpringBoot整合
* 1、Spring中6位组成，不允许第7位的年
* 2、在周几的位置，1-7代表周一到周日：MON-SUN
测试代码如下
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
/**
* 定时任务
* 1、@EnableScheduling开启定时任务
* 2、@scheduled 开启一个定时任务
* **/
@EnableScheduling
@Component
@Slf4j
public class HelloSchedule {
@Scheduled(cron = "*/5 * * * * 4")
public void hello(){
log.info("hello.....");
try {
Thread.sleep(8000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
但是这里存在一个问题
定时任务不应该阻塞，默认是阻塞的。（也就是要等业务执行完，定时任务才能开始执行）
可以使用以下几种解决方案
1）、CompletableFuture.runAsync()可以让业务以异步的方式，自己提交到线程池
2）、支持定时任务线程池设置：
spring.task.scheduling.pool.size=5
3）、让定时任务异步执行
通常是采用第3种方案
开启异步定时任务
- 异步任务
1、@EnableAsycn:开启异步任务功能
2、@Async 给希望异步执行的方法上标注上注解
3、自动配置类 TaskExecutionAutoConfiguration 属性绑定在TaskExecutionProperties
4、.配置定时任务的线程池属性：
spring.task.execution.pool.core-size=5
spring.task.execution.pool.max-size=30
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
/**
* 定时任务
* 1、@EnableScheduling开启定时任务
* 2、@scheduled 开启一个定时任务
* 异步任务
* 1、@EnableAsycn:开启异步任务功能
* 2、@Async 给希望异步执行的方法上标注上注解
* 3、自动配置类 TaskExecutionAutoConfiguration 属性绑定在TaskExecutionProperties
* 4.配置：
* spring.task.execution.pool.core-size=5
* spring.task.execution.pool.max-size=30
* **/
@EnableScheduling
@Component
@Slf4j
@EnableAsync
public class HelloSchedule {
/**
* 1、Spring中6位组成，不允许第7位的年
* 2、在周几的位置，1-7代表周一到周日：MON-SUN
* 3、定时任务不应该阻塞，默认是阻塞的。（也就是要等业务执行完，定时任务才能开始执行）
* 1）、CompletableFuture.runAsync()可以让业务以异步的方式，自己提交到线程池
* 2）、支持定时任务线程池设置：
* spring.task.scheduling.pool.size=5
* 3）、让定时任务异步执行
*
* 解决：使用异步+定时任务来完成定时任务不阻塞的功能。
* **/
@Async
@Scheduled(cron = "*/5 * * * * 4")
public void hello(){
log.info("hello.....");
try {
Thread.sleep(8000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
