当前位置： 移动技术网 > IT编程>开发语言>Java > Spring Boot集成教程之异步调用Async

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

2019年07月19日  | 移动技术网IT编程  | 我要评论

前言

本文主要给大家介绍了关于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

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

总结

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

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网