Spring Boot集成教程之异步调用Async

更新时间：2018年03月22日 11:12:09 作者：再见尼罗河

在项目中，当访问其他人的接口较慢或者做耗时任务时，不想程序一直卡在耗时任务上，想程序能够并行执行，我们可以使用多线程来并行的处理任务，也可以使用spring提供的异步处理方式@Async。需要的朋友们下面来一起看看吧。

前言

本文主要给大家介绍了关于Spring Boot集成之异步调用Async的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍吧。

什么是异步调用？

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

异步处理方式

调用之后，不返回任何数据。
调用之后，返回数据，通过Future来获取返回数据

如何实现异步调用？

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

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

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

按照官方示例开撸

代码入下

maven依赖：

<parent> 
 <groupId>org.springframework.boot</groupId> 
 <artifactId>spring-boot-starter-parent</artifactId> 
 <version>1.5.3.RELEASE</version> 
</parent> 
<dependencies> 
 <dependency> 
  <groupId>org.springframework.boot</groupId> 
  <artifactId>spring-boot-starter-web</artifactId> 
 </dependency> 
</dependencies>

启动类：添加@EnableAsync注解

@SpringBootApplication 
@EnableAsync 
public class Application{ 
 
 public static void main(String[] args) { 
  SpringApplication.run(Application.class, args); 
 } 
}

Controller

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

@RestController 
@RequestMapping("") 
public class AsyncTaskController { 
 @RequestMapping("") 
 public String doTask() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  this.task1(); 
  this.task2(); 
  this.task3(); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  return "task任务总耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"; 
 } 
  
 @Async 
 public void task1() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(1000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task1任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
 } 
  
 @Async 
 public void task2() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(2000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task2任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
 } 
 @Async 
 public void task3() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(3000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task3任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
 } 
}

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

控制台：

task1任务耗时:1012ms 
task2任务耗时:2009ms 
task3任务耗时:3004ms

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

task任务总耗时:6002ms

异步并没有执行！

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

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

Controller

@RequestMapping("") 
@RestController 
public class AsyncTaskController { 
 @Autowired 
 private AsyncTask asyncTask; 
 @RequestMapping("") 
 public String doTask() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  asyncTask.task1(); 
  asyncTask.task2(); 
  asyncTask.task3(); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  return "task任务总耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"; 
   
 } 
}

异步任务类

@Component 
public class AsyncTask { 
 @Async 
 public void task1() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(1000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task1任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
 } 
  
 @Async 
 public void task2() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(2000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task2任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
 } 
 @Async 
 public void task3() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(3000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task3任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
 } 
}

控制台：

task1任务耗时:1012ms 
task2任务耗时:2009ms 
task3任务耗时:3004ms

访问浏览器结果入下：

task任务总耗时:19ms

异步调用成功！

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

代码入下：

异步任务类

@Component 
public class AsyncTask { 
 @Async 
 public Future<String> task1() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(1000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task1任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
  return new AsyncResult<String>("task1执行完毕"); 
 } 
  
 @Async 
 public Future<String> task2() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(2000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task2任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
  return new AsyncResult<String>("task2执行完毕"); 
 } 
 @Async 
 public Future<String> task3() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Thread.sleep(3000); 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  System.out.println("task3任务耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"); 
  return new AsyncResult<String>("task3执行完毕"); 
 } 
}

Controller

@RequestMapping("") 
@RestController 
public class AsyncTaskController { 
 @Autowired 
 private AsyncTask asyncTask; 
 @RequestMapping("") 
 public String doTask() throws InterruptedException{ 
  long currentTimeMillis = System.currentTimeMillis(); 
  Future<String> task1 = asyncTask.task1(); 
  Future<String> task2 = asyncTask.task2(); 
  Future<String> task3 = asyncTask.task3(); 
  String result = null; 
  for (;;) { 
   if(task1.isDone() && task2.isDone() && task3.isDone()) { 
    // 三个任务都调用完成，退出循环等待 
    break; 
   } 
   Thread.sleep(1000); 
  } 
  long currentTimeMillis1 = System.currentTimeMillis(); 
  result = "task任务总耗时:"+(currentTimeMillis1-currentTimeMillis)+"ms"; 
  return result; 
 } 
}

控制台输出：

task1任务耗时:1000ms 
task2任务耗时:2001ms 
task3任务耗时:3001ms

浏览器输出：

task任务总耗时:4015ms

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

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

您可能感兴趣的文章:

springboot整合mybatis-plus基于注解实现一对一(一对多)查询功能
这篇文章主要介绍了springboot整合mybatis-plus基于纯注解实现一对一(一对多)查询功能，因为本人采用的是spring-boot进行开发，本身springboot就提倡采用不用配置自动配置的方式，所以真心希望mybatis(不是mybatis-plus)这点需要继续努力
2021-09-09
Java 精炼解读数据结构的链表的概念与实现
链表是一种物理存储单元上非连续、非顺序的存储结构，数据元素的逻辑顺序是通过链表中的指针连接次序实现的，每一个链表都包含多个节点，节点又包含两个部分，一个是数据域，一个是引用域
2022-03-03
java中File与MultipartFile互转代码示例
在Java开发中,当需要将本地File对象转换为MultipartFile对象以处理文件上传时,可以通过实现MultipartFile接口或使用CommonsMultipartFile类来实现,本文提供了详细的转换方法和代码示例,需要的朋友可以参考下
2024-10-10
SpringBoot 应用程序测试实现方案
这篇文章主要介绍了SpringBoot 应用程序测试实现方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-11-11
IDEA 非常重要的一些设置项(一连串的问题差点让我重新用回 Eclipse)
这篇文章主要介绍了IDEA 非常重要的一些设置项(一连串的问题差点让我重新用回 Eclipse),本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-08-08
java使用elasticsearch分组进行聚合查询过程解析
这篇文章主要介绍了java使用elasticsearch分组进行聚合查询过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-02-02
java中关于深拷贝的几种方式总结
这篇文章主要介绍了java中关于深拷贝的几种方式总结，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-08-08
详解使用@RequestBody取POST方式的json字符串
这篇文章主要介绍了详解使用@RequestBody取POST方式的json字符串，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-12-12
有关Java中的BeanInfo介绍
Java的BeanInfo在工作中并不怎么用到，我也是在学习spring源码的时候，发现SpringBoot启动时候会设置一个属叫"spring.beaninfo.ignore"，网上一些地方说这个配置的意思是是否跳过java BeanInfo的搜索，但是BeanInfo又是什么呢？本文我们将对此做一个详细介绍
2021-09-09
Spring Boot + Kotlin整合MyBatis的方法教程
前几天由于工作需要，便开始学习了kotlin,java基础扎实学起来也还算比较快，对于kotlin这个编程语言自然是比java有趣一些，下面这篇文章主要给大家介绍了关于Spring Boot + Kotlin整合MyBatis的方法教程，需要的朋友可以参考下。
2018-01-01

Spring Boot集成教程之异步调用Async

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具