SpringBoot+@Async注解一起使用，速度提升100倍！

介绍：异步调用几乎是处理高并发web应用性能问题的灵丹妙药，那么什么是“异步调用”呢？“异步调用”对应“同步调用”。同步调用是指程序按照定义的顺序顺序执行，每一行程序都必须等待上一行程序执行完成后才能执行；异步调用是指程序顺序执行时，不等待异步调用语句返回结果，就会执行后面的程序。异步调用几乎是处理高并发Web应用性能问题的灵丹妙药，那么什么是“异步调用”呢？“异步调用”对应“同步调用”。同步调用是指程序按照定义的顺序顺序执行，每一行程序都必须等待上一行程序执行完成后才能执行；异步调用是指程序顺序执行时，不等待异步调用语句返回结果，就会执行后面的程序。同步调用下面通过一个简单的例子来直观的理解什么是同步调用：定义Task类，创建三个处理函数模拟执行任务的三个操作，操作时间随机选择（10秒以内）@ComponentpublicclassTask{公共静态随机随机=新随机（）；publicvoiddoTaskOne()throwsException{System.out.println("开始做任务一");长启动=System.currentTimeMillis();Thread.sleep(random.nextInt(10000));长端=System.currentTimeMillis();System.out.println("完成任务一，耗时："+(end-start)+"毫秒");}publicvoiddoTaskTwo()throwsException{System.out.println("开始任务2");长启动=System.currentTimeMillis();Thread.sleep(random.nextInt(10000));长端=System.currentTimeMillis();System.out.println("完成任务秒，耗时："+(end-start)+"毫秒");}publicvoiddoTaskThree()throwsException{System.out.println("开始做任务三");长启动=System.currentTimeMillis();Thread.sleep(随机.nexttInt(10000));长端=System.currentTimeMillis();System.out.println("完成任务三，耗时："+(end-start)+"毫秒");}在单元测试用例中，注入Task对象，执行测试用例中的三个函数doTaskOne、doTaskTwo、doTaskThree@RunWith(SpringJUnit4ClassRunner.class)@SpringApplicationConfiguration(classes=Application.class)publicclassApplicationTests{@AutowiredprivateTasktask;@Testpublicvoidtest()throwsException{task.doTaskOne();任务.doTaskTwo();任务.doTaskThree();}}执行单元测试，可以看到类似下面的输出：开始做任务，完成任务一，耗时：4256毫秒开始做任务二，完成任务二，耗时：4957毫秒.启动任务3，完成任务3，耗时：7173毫秒。任务1、任务2、任务3依次执行。异步调用上面的同步调用虽然成功执行了三个任务，但是可以看出执行时间比较长。如果三个任务之间没有依赖关系，可以并发执行，那么同步调用在执行上会更高效。差，可以考虑通过异步调用的方式并发执行。在SpringBoot中，我们只需要使用@Async注解，就可以简单的把原来的同步函数变成异步函数，Task类改为如下模式：@ComponentpublicclassTask{@AsyncpublicvoiddoTaskOne()throwsException{//同上，省略}@AsyncpublicvoiddoTaskTwo()throwsException{//同上，省略}@AsyncpublicvoiddoTaskThree()throwsException{//同上，省略}}为了使@Async注解生效，还需要在SpringBoot主程序中配置@EnableAsync，如下：@SpringBootApplication@EnableAsyncpublicclassApplication{publicstaticvoidmain(String[]args){SpringApplication.run(Application.类，参数）；}}此时单元测试可以反复执行，可能会遇到各种各样的结果，例如：没有任务相关的输出，部分任务相关的输出乱序，任务相关输出的原因是当前doTaskOne、doTaskTwo、doTaskThree三个函数的时候已经是异步执行了。异步调用主程序后，主程序不关心这三个函数是否执行完毕。由于没有其他内容需要执行，程序自动结束，导致任务相关内容输出不完整或没有输出。.注意：@Async修饰的函数不要定义为静态类型，这样异步调用不会生效。异步回调为了让doTaskOne、doTaskTwo、doTaskThree正常结束，假设我们需要统计这三个任务并发执行的总耗时。这是需要等到上面三个函数都调完了，才能记录时间，计算结果。那么我们如何判断以上三个异步调用是否已经执行呢？我们需要使用Future来返回异步调用的结果，就像改造doTaskOne函数一样：@AsyncpublicFuturedoTaskOne()throwsException{System.out.println("开始做任务一");长启动=系统。当前时间毫秒();Thread.sleep(random.nextInt(10000));长端=System.currentTimeMillis();System.out.println("完成任务一，耗时："+(end-start)+"毫秒");returnnewAsyncResult<>("Thetaskiscompleted");}按照上面的方法对另外两个异步函数进行改造后，我们来对测试用例进行改造，让测试等待三个异步完成后可以做其他事情电话。@Testpublicvoidtest()throwsException{longstart=System.currentTimeMillis();Futuretask1=task.doTaskOne();Futuretask2=task.doTaskTwo();未来任务3=任务。doTaskThree();while(true){if(task1.isDone()&&task2.isDone()&&task3.isDone()){//所有三个任务都被调用，退出循环并等待break；}Thread.sleep(1000);}longend=System.currentTimeMillis();System.out.println("所有任务完成，总耗时："+(end-start)+"milliseconds");}看看我们做了什么改动：在开头记录了测试用例的开始时间。调用三个异步函数时，返回Future类型的结果对象。三个异步函数调用完成后，开始一个循环，通过返回的Future对象来判断三个异步函数是否全部结束。.如果全部结束，则循环结束；如果还没有全部结束，请等待1秒后再进行判断。跳出循环后，根据结束时间-开始时间计算三个任务并发执行的总耗时。执行上面的单元测试，可以看到如下结果：开始做任务1，开始做任务2，开始做任务3，完成任务3，耗时：37毫秒完成任务2，耗时：3661毫秒完成任务1，耗时：7149毫秒，任务全部完成，总耗时：8025毫秒。可以看出，通过异步调用，任务1、2、3并发执行，有效减少了程序的总运行时间。