前言

开发 web 应用时，多数应用都具备任务调度功能，常见的任务包括异步任务、定时任务和邮件任务。我们以数据库报表为例看看任务调度如何帮助改善系统设计。报表可能是错综复杂的，用户可能需要很长时间找到需要的报表数据，此时我们可以在这个报表应用中添加异步任务减少用户等待时间，从而提高用户体验性；除此之外，还可以在报表应用中添加定时任务和邮件任务，以便用户可以安排在任何他们需要的时间定时生成报表，并在 Email 中发送。本文记录如何使用 SpringBoot 开发这些常见的任务。

一，异步任务

web 应用开发中，大多数情况都是通过同步方式完成数据交互处理，但是，当处理与第三方系统的交互时，容易造成响应迟缓的情况，之前大部分都是使用多线程完成此类任务，除此之外，还可以使用异步调用的方式完美解决这个问题。根据异步处理方式的不同，可以将异步任务的调用分为无返回值异步任务调用和有返回值异步任务调用。

1.1 无返回值异步任务调用

在启动类上添加注解 @EnableAsync(开启基于注解的异步任务支持)
在指定无返回值的业务方法上添加 @Asyn注解，实现异步请求方法

启动类

@EnableAsync
@SpringBootApplication
public class AsyncApplication {

	public static void main(String[] args) {
		SpringApplication.run(AsyncApplication.class, args);
	}
}

Service 层代码

@Service
public class AsyncService {

    @Async
    public void send(){
        System.out.println("调用短信验证码方法......");
        long start = System.currentTimeMillis();
        try {
            Thread.sleep(4000);
        } catch (InterruptedException e) {
            e.printStackTrace();
            System.out.println("出现异常："+ e.getMessage());
        }
        long end = System.currentTimeMillis();
        System.out.println("短信验证码方法执行时间："+(end - start) + "毫秒");
    }
}

Controller 层代码

@RestController
public class AsyncController {
    @Autowired
    private AsyncService asyncService;

    @GetMapping("/async")
    public R testAsync(){
        long start = System.currentTimeMillis();
        asyncService.send();
        long end = System.currentTimeMillis();
        System.out.println("调用结束主流程耗时"+(end-start)+"毫秒");
        return R.ok().put("success", "调用结束主流程耗时"+(end-start)+"毫秒");
    }
}

若没有使用异步处理(注释掉 @Async 注解)，访问接口返回数据如下

在这里插入图片描述

控制台输出内容：

在这里插入图片描述

若使用异步处理(使用 @Async 注解)，访问接口返回数据如下

在这里插入图片描述

控制台输出内容：

在这里插入图片描述

当未使用异步处理时，访问接口需要等待4s左右才返回数据，而使用异步处理后几乎不需要等待时间，用户体验更佳了。

需要说明的是，无返回值异步方法在被主流程方法调用时，主流程方法不会阻塞，而是继续向下执行主流程方法内容，直接向页面响应结果，而调用的异步方法会作为一个子线程单独执行，直到异步方法执行完成。

1.2 有返回值异步任务调用

在启动类上添加注解 @EnableAsync(开启基于注解的异步任务支持)
在指定有返回值的业务方法上添加 @ASync注解，实现异步请求方法
注意： 返回值必须用Future 泛型封装，例如: new AsyncResult(count)，当想获取装的值时用 Futue 对象调用其 get() 方法即可获得。

业务场景设定：假设业务A(耗时3秒)进行数据分析返回一个整数值，业务B(耗时5秒)也进行数据分析返回一个整数值；且两者没有相互影响，计算业务A和业务B的返回整数值相加的结果。

同步方式： 先调用业务A ，再调用B，再将A返回值与B返回值相加，最终将结果返回给用户，总耗时肯定大于8秒。这种方式相对来说整体耗时更长，响应慢，降低了用户体验。

异步方式：

@Async
public Future<Integer> processA(){
    System.out.println("开始分析并统计业务A数据......");
    long start = System.currentTimeMillis();
    try {
        Thread.sleep(3000);
    } catch (InterruptedException e) {
        e.printStackTrace();
        System.out.println("出现异常："+ e.getMessage());
    }
    Integer numA = 20;
    long end = System.currentTimeMillis();
    System.out.println("业务A数据统计共耗时："+(end - start));
    return new AsyncResult<Integer>(numA);
}

@Async
public Future<Integer> processB(){
    System.out.println("开始分析并统计业务B数据......");
    long start = System.currentTimeMillis();
    try {
        Thread.sleep(5000);
    } catch (InterruptedException e) {
        e.printStackTrace();
        System.out.println("出现异常："+ e.getMessage());
    }
    Integer numB = 25;
    long end = System.currentTimeMillis();
    System.out.println("业务B数据统计共耗时："+(end - start));
    return new AsyncResult<Integer>(numB);
}

@GetMapping("/asyncTask")
public R Async() throws Exception {
    long start = System.currentTimeMillis();
    Future<Integer> processA = asyncService.processA();
    Future<Integer> processB = asyncService.processB();
    int sum = processA.get() + processB.get();
    //等待A B结果相加成功后再向下执行,这里阻塞了
    long end = System.currentTimeMillis();
    System.out.println("调用结束主流程耗时"+(end-start)+"毫秒");
    return R.ok().put("data","success");
}