Spring Boot 整合定时任务和异步任务处理
Posted jwen1994
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Spring Boot 整合定时任务和异步任务处理相关的知识,希望对你有一定的参考价值。
1.定时任务
Spring Boot 使用注解方式开启定时任务,分为3步
1)启动类里面加上 @EnableScheduling 注解开启定时任务,自动扫描标记了@Scheduled 注解的方法
@SpringBootApplication @EnableScheduling public class BaseProjectApplication public static void main(String[] args) SpringApplication.run(BaseProjectApplication.class, args);
2)定时任务业务类加上 @Component 注解,用于被容器扫描
3)定时执行的方法加上注解 @Scheduled(fixedRate=2000) 定期执行一次
@Component public class TestTask @Scheduled(fixedRate=2000)//两秒执行一次 public void sum() throws InterruptedException System.out.println("结束 当前时间:"+new Date());
常用定时任务表达式配置
(1)fixedRate: 定时多久执行一次(上一次开始执行时间点后xx毫秒再次执行)
(2)fixedRateString: 定时多久执行一次(上一次开始执行时间点后xx毫秒再次执行),字符串形式,可以通过配置文件指定
(3)fixedDelay: 定时多久执行一次(上一次执行结束时间点后xx毫秒再次执行)
(4)fixedDelayString: 定时多久执行一次(上一次执行结束时间点后xx毫秒再次执行),字符串形式,可以通过配置文件指定
(5)cron 定时任务表达式 @Scheduled(cron="*/1 * * * * *") 表示每秒。crontab 工具 https://tool.lu/crontab/
@Scheduled(fixedRate=2000)//两秒执行一次 @Scheduled(fixedRateString="2000")//两秒执行一次 @Scheduled(fixedDelay=2000)//两秒执行一次 @Scheduled(fixedDelayString="2000")//两秒执行一次 @Scheduled(cron="*/2 * * * * *")//每两秒执行一次
2.异步任务
Spring Boot 使用注解方式开启异步任务,分为3步
1)启动类里面加上 @EnableAsync 注解开启异步任务,自动扫描标记了 @Async 注解的方法
@SpringBootApplication @EnableAsync //开启异步任务 public class XdclassApplication public static void main(String[] args) SpringApplication.run(XdclassApplication.class, args);
2)异步任务业务类加上 @Component 注解,用于被容器扫描
3)异步执行的方法加上注解 @Async 表示该方法可以异步执行,也可以在异步任务业务类加上 @Async 表示该类中的所有方法可以异步执行
@Component @Async public class AsyncTask public void task1() throws InterruptedException long begin = System.currentTimeMillis(); Thread.sleep(1000L); long end = System.currentTimeMillis(); System.out.println("任务1耗时="+(end-begin)); public void task2() throws InterruptedException long begin = System.currentTimeMillis(); Thread.sleep(2000L); long end = System.currentTimeMillis(); System.out.println("任务2耗时="+(end-begin)); public void task3() throws InterruptedException long begin = System.currentTimeMillis(); Thread.sleep(3000L); long end = System.currentTimeMillis(); System.out.println("任务3耗时="+(end-begin)); //获取异步结果 public Future<String> task4() throws InterruptedException long begin = System.currentTimeMillis(); Thread.sleep(2000L); long end = System.currentTimeMillis(); System.out.println("任务4耗时="+(end-begin)); return new AsyncResult<String>("任务4"); public Future<String> task5() throws InterruptedException long begin = System.currentTimeMillis(); Thread.sleep(3000L); long end = System.currentTimeMillis(); System.out.println("任务5耗时="+(end-begin)); return new AsyncResult<String>("任务5"); public Future<String> task6() throws InterruptedException long begin = System.currentTimeMillis(); Thread.sleep(1000L); long end = System.currentTimeMillis(); System.out.println("任务6耗时="+(end-begin)); return new AsyncResult<String>("任务6");
测试代码如下:
@RestController @RequestMapping("/api/v1") public class UserController @Autowired private AsyncTask task; @GetMapping("async_task") public JsonData exeTask() throws InterruptedException long begin = System.currentTimeMillis(); // task.task1(); // task.task2(); // task.task3(); Future<String> task4 = task.task4(); Future<String> task5 = task.task5(); Future<String> task6 = task.task6(); for(;;) if (task4.isDone() && task5.isDone() && task6.isDone()) break; long end = System.currentTimeMillis(); long total = end-begin; System.out.println("执行总耗时="+total); return JsonData.buildSuccess(total);
注意点:
1)要把异步任务封装到类里面,不能直接写到 Controller
2)增加 Future<String> 返回结果 AsyncResult<String>("task执行完成");
3)如果需要拿到结果,需要判断全部的 task.isDone();
以上是关于Spring Boot 整合定时任务和异步任务处理的主要内容,如果未能解决你的问题,请参考以下文章
Spring Boot整合Scheduled定时任务器整合Quartz定时任务框架