SpringBoot 异步任务+定时任务(附源码)-阿里云开发者社区

SpringBoot 异步任务+定时任务(附源码)

2022-05-10 155

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： SpringBoot 异步任务+定时任务(附源码)

一、异步任务

在Java应用中，绝大多数情况下都是通过同步的方式来实现交互处理的；但是在处理与第三方系统交互的时候，容易造成响应迟缓的情况，之前大部分都是使用多线程来完成此类任务，其实，在Spring 3.x之后，就已经内置了@Async来完美解决这个问题。

两个注解：@EnableAysnc、@Aysnc

首先我们来看不加异步接口的操作

@Service
public class AsyncService {
    public void hello(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("处理数据中...");
    }
}

@RestController
public class AsyncController {
    @Autowired
    AsyncService asyncService;
    @GetMapping("/hello")
    public String hello(){
        asyncService.hello();
        return "success";
    }
}

启动服务器：我们可以看到页面在等待三秒后才会执行我们想要的结果

屏幕快照 2022-05-10 下午12.33.09.png

三秒后：

这里我们加上同步操作（只需两个注解轻松搞定）：

@Service
public class AsyncService {
    //告诉Spring这是一个异步方法
    @Async
    public void hello(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("处理数据中...");
    }
}

别忘了在启动器上开启异步注解功能，否则异步不起效果

@EnableAsync  //开启异步注解功能
@SpringBootApplication
public class Springboot04TaskApplication {
  public static void main(String[] args) {
  SpringApplication.run(Springboot04TaskApplication.class, args);
  }
}

这里我们就可以看到异步可以成功启动

二、定时任务

项目开发中经常需要执行一些定时任务，比如需要在每天凌晨时候，分析一次前一天的日志信息。Spring为我们提供了异步执行任务调度的方式，提供TaskExecutor、TaskScheduler接口。

屏幕快照 2022-05-10 下午12.33.59.png

@Service
public class ScheduledService {
    /**
     * second(秒), minute（分）, hour（时）, day of month（日）, month（月）, day of week（周几）.
     * 0 * * * * MON-FRI
     *  【0 0/5 14,18 * * ?】 每天14点整，和18点整，每隔5分钟执行一次
     *  【0 15 10 ? * 1-6】 每个月的周一至周六10:15分执行一次
     *  【0 0 2 ? * 6L】每个月的最后一个周六凌晨2点执行一次
     *  【0 0 2 LW * ?】每个月的最后一个工作日凌晨2点执行一次
     *  【0 0 2-4 ? * 1#1】每个月的第一个周一凌晨2点到4点期间，每个整点都执行一次；
     */
   // @Scheduled(cron = "0 * * * * 2")
    //@Scheduled(cron = "0,1,2,3,4 * * * * 2")
   // @Scheduled(cron = "0-4 * * * * 2")
    @Scheduled(cron = "0/4 * * * * 2")  //周二每4秒执行一次
    public void hello(){
        System.out.println("hello ... ");
    }
}

开启基于注解的定时任务

@EnableAsync  //开启异步注解功能
@EnableScheduling //开启基于注解的定时任务
@SpringBootApplication
public class Springboot04TaskApplication {
  public static void main(String[] args) {
  SpringApplication.run(Springboot04TaskApplication.class, args);
  }
}