SpringBoot @Async实现异步调用

Posted

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了SpringBoot @Async实现异步调用相关的知识，希望对你有一定的参考价值。

参考技术A

异步调用是相对于同步调用的，同步调用是按照顺序进行执行任务，只有上一个任务执行完成下一个任务才能执行， 异步调用是指在按照顺序执行任务的过程中不需要等待任务结果的出现，就可以顺序执行下一个任务 。

异步处理的方式：

SpringBoot自身没有对异步调用做很大的变动，基本还是使用SpringMVC的@Async

注解 ：在使用**@EnableWebMvc**注解的时候也可以开启异步调用，但是在SpringBoot中使用异步调用会使得SpringBoot的AutoConfig一部分功能失效。

定义一个或者多个线程池

我们使用 ThreadPoolTaskExecutor 创建线程池，其参数配置如下：

异步调用方法有两种一个是没有返回值的，一种是有返回值的，具体实现如下：

在多线程池的时候，我们需要在@Async()指定线程池名称**@Async("threadPoolTaskExecutor1")**

在单元测试用例中，注入Task对象，并在测试用例中执行 asyncMethodWithVoidReturnType_One 、 asyncMethodWithVoidReturnType_Two() 、 asyncMethodWithVoidReturnType_Three() 三个函数。

执行结果如下：


SpringBoot集成篇 异步调用Async

什么是异步调用？

异步调用是相对于同步调用而言的，同步调用是指程序按预定顺序一步步执行，每一步必须等到上一步执行完后才能执行，异步调用则无需等待上一步程序执行完即可执行。

 

如何实现异步调用？

多线程，这是很多人第一眼想到的关键词，没错，多线程就是一种实现异步调用的方式。

 

在非spring目项目中我们要实现异步调用的就是使用多线程方式，可以自己实现Runable接口或者集成Thread类，或者使用jdk1.5以上提供了的Executors线程池。

 

StrngBoot中则提供了很方便的方式执行异步调用。

按照官方示例开撸

代码入下

maven依赖：

 

[java] view plain copy
 
  1. <parent>  
  2.     <groupId>org.springframework.boot</groupId>  
  3.     <artifactId>spring-boot-starter-parent</artifactId>  
  4.     <version>1.5.3.RELEASE</version>  
  5. </parent>  
  6. <dependencies>  
  7.     <dependency>  
  8.         <groupId>org.springframework.boot</groupId>  
  9.         <artifactId>spring-boot-starter-web</artifactId>  
  10.     </dependency>  
  11. </dependencies>  

 

 

启动类：添加@EnableAsync注解

 

[java] view plain copy
 
  1. @SpringBootApplication  
  2. @EnableAsync  
  3. public class Application{  
  4.   
  5.     public static void main(String[] args) {  
  6.         SpringApplication.run(Application.class, args);  
  7.     }  
  8. }  


 

Controller 

只需在需要异步执行方法上添加@Async注解

 

[java] view plain copy
 
  1. @RestController  
  2. @RequestMapping("")  
  3. public class AsyncTaskController {  
  4.       
  5.     @RequestMapping("")  
  6.     public String doTask() throws InterruptedException{  
  7.         long currentTimeMillis = System.currentTimeMillis();  
  8.         this.task1();  
  9.         this.task2();  
  10.         this.task3();  
  11.         long currentTimeMillis1 = System.currentTimeMillis();  
  12.         return "task任务总耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms";  
  13.     }  
  14.       
  15.     @Async  
  16.     public void task1() throws InterruptedException{  
  17.         long currentTimeMillis = System.currentTimeMillis();  
  18.         Thread.sleep(1000);  
  19.         long currentTimeMillis1 = System.currentTimeMillis();  
  20.         System.out.println("task1任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  21.     }  
  22.       
  23.     @Async  
  24.     public void task2() throws InterruptedException{  
  25.         long currentTimeMillis = System.currentTimeMillis();  
  26.         Thread.sleep(2000);  
  27.         long currentTimeMillis1 = System.currentTimeMillis();  
  28.         System.out.println("task2任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  29.     }  
  30.     @Async  
  31.     public void task3() throws InterruptedException{  
  32.         long currentTimeMillis = System.currentTimeMillis();  
  33.         Thread.sleep(3000);  
  34.         long currentTimeMillis1 = System.currentTimeMillis();  
  35.         System.out.println("task3任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  36.     }  
  37. }  

 

 

main函数运行spirngboot项目，启动完成后浏览器访问：

http://localhost:8080/

 

控制台：

[html] view plain copy
 
  1. task1任务耗时:1012ms  
  2. task2任务耗时:2009ms  
  3. task3任务耗时:3004ms  
 

等了一段浏览器时候输出入下：

 

[html] view plain copy
 
  1. task任务总耗时:6002ms   


 

异步并没有执行！

难道是代码写错了？反复检查了好几遍，并没有发现什么明显错误，想起spring对@Transactional注解时也有类似问题，spring扫描时具有@Transactional注解方法的类时，是生成一个代理类，由代理类去开启关闭事务，而在同一个类中，方法调用是在类体内执行的，spring无法截获这个方法调用。

豁然开朗，将异步任务单独放到一个类中，调整代码入下：

 

Controller

[java] view plain copy
 
  1. @RequestMapping("")  
  2. @RestController  
  3. public class AsyncTaskController {  
  4.       
  5.     @Autowired  
  6.     private AsyncTask asyncTask;  
  7.       
  8.     @RequestMapping("")  
  9.     public String doTask() throws InterruptedException{  
  10.         long currentTimeMillis = System.currentTimeMillis();  
  11.         asyncTask.task1();  
  12.         asyncTask.task2();  
  13.         asyncTask.task3();  
  14.         long currentTimeMillis1 = System.currentTimeMillis();  
  15.         return "task任务总耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms";  
  16.           
  17.     }  
  18. }  

 

 

异步任务类

 

[java] view plain copy
 
  1. @Component  
  2. public class AsyncTask {  
  3.       
  4.     @Async  
  5.     public void task1() throws InterruptedException{  
  6.         long currentTimeMillis = System.currentTimeMillis();  
  7.         Thread.sleep(1000);  
  8.         long currentTimeMillis1 = System.currentTimeMillis();  
  9.         System.out.println("task1任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  10.     }  
  11.       
  12.     @Async  
  13.     public void task2() throws InterruptedException{  
  14.         long currentTimeMillis = System.currentTimeMillis();  
  15.         Thread.sleep(2000);  
  16.         long currentTimeMillis1 = System.currentTimeMillis();  
  17.         System.out.println("task2任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  18.     }  
  19.     @Async  
  20.     public void task3() throws InterruptedException{  
  21.         long currentTimeMillis = System.currentTimeMillis();  
  22.         Thread.sleep(3000);  
  23.         long currentTimeMillis1 = System.currentTimeMillis();  
  24.         System.out.println("task3任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  25.     }  
  26. }  

 

控制台：

[html] view plain copy
 
  1. task1任务耗时:1012ms  
  2. task2任务耗时:2009ms  
  3. task3任务耗时:3004ms  

访问浏览器结果入下：

 

[html] view plain copy
 
  1. task任务总耗时:19ms  
 

 

异步调用成功！

 

如何知道三个异步任务什么时候执行完，执行的结果怎样呢？可以采用添加Fature回调方式判断

代码入下：

异步任务类

 

[java] view plain copy
 
  1. @Component  
  2. public class AsyncTask {  
  3.       
  4.     @Async  
  5.     public Future<String> task1() throws InterruptedException{  
  6.         long currentTimeMillis = System.currentTimeMillis();  
  7.         Thread.sleep(1000);  
  8.         long currentTimeMillis1 = System.currentTimeMillis();  
  9.         System.out.println("task1任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  10.         return new AsyncResult<String>("task1执行完毕");  
  11.     }  
  12.       
  13.     @Async  
  14.     public Future<String> task2() throws InterruptedException{  
  15.         long currentTimeMillis = System.currentTimeMillis();  
  16.         Thread.sleep(2000);  
  17.         long currentTimeMillis1 = System.currentTimeMillis();  
  18.         System.out.println("task2任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  19.         return new AsyncResult<String>("task2执行完毕");  
  20.     }  
  21.     @Async  
  22.     public Future<String> task3() throws InterruptedException{  
  23.         long currentTimeMillis = System.currentTimeMillis();  
  24.         Thread.sleep(3000);  
  25.         long currentTimeMillis1 = System.currentTimeMillis();  
  26.         System.out.println("task3任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms");  
  27.         return new AsyncResult<String>("task3执行完毕");  
  28.     }  
  29. }  

Controller

 

[java] view plain copy
 
  1. @RequestMapping("")  
  2. @RestController  
  3. public class AsyncTaskController {  
  4.       
  5.     @Autowired  
  6.     private AsyncTask asyncTask;  
  7.       
  8.     @RequestMapping("")  
  9.     public String doTask() throws InterruptedException{  
  10.         long currentTimeMillis = System.currentTimeMillis();  
  11.         Future<String> task1 = asyncTask.task1();  
  12.         Future<String> task2 = asyncTask.task2();  
  13.         Future<String> task3 = asyncTask.task3();  
  14.         String result = null;  
  15.         for (;;) {  
  16.             if(task1.isDone() && task2.isDone() && task3.isDone()) {  
  17.                 // 三个任务都调用完成，退出循环等待  
  18.                 break;  
  19.             }  
  20.             Thread.sleep(1000);  
  21.         }  
  22.         long currentTimeMillis1 = System.currentTimeMillis();  
  23.         result = "task任务总耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms";  
  24.         return result;  
  25.     }  
  26. }  

 

 

控制台输出：

[html] view plain copy
 
  1. task1任务耗时:1000ms  
  2. task2任务耗时:2001ms  
  3. task3任务耗时:3001ms  

浏览器输出：

[html] view plain copy
 
  1. <span style="font-family:Simsun;font-size:14px;">task任务总耗时:4015ms</span>  

 

 

 

异步调用成功，并且在所有任务都完成时程序才返回了结果！

 

 

 

版权声明：本文为博主原创文章，未经博主允许不得转载。







以上是关于SpringBoot @Async实现异步调用的主要内容，如果未能解决你的问题，请参考以下文章

SpringBoot集成篇 异步调用Async

#yyds干货盘点# springboot使用@Async实现异步调用

Springboot 使用@Async开启异步调用

SpringBoot系列：Spring Boot异步调用@Async

springboot 的异步调用 @Async注解

springboot 异步调用Async使用方法