Spring Boot集成教程之异步调用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
异步调用成功,并且在所有任务都完成时程序才返回了结果!
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。