在Spring Boot2中使用CompletableFuture的方法教程
前言
在spring boot中有一个注释@async,可以帮助开发人员开发并发应用程序。但使用此功能非常棘手。在本博客中,我们将了解如何将此功能与completablefuture一起使用。我认为你已经知道关于completablefuture的基础,所以我不会在这里重复这个概念。
首先,您需要使用@enableasync来注释您的应用程序类,这个注释告诉spring查找使用@async注释的方法并在单独的执行程序中运行它们。
@springbootapplication @enableasync public class app { resttemplate public static void main(string[] args) { springapplication.run(app.class, args); } }
如果您查看有关使用completablefuture和@async的spring boot示例,您会注意到他们使用此功能的方式基于rest请求,在我看来,我相信,它有点受限,它不会给你在其他情况下如何使用此功能的线索。例如,如果你有一个长期运行的任务,你会怎么做?
// source : https://spring.io/guides/gs/async-method/ package hello; import org.slf4j.logger; import org.slf4j.loggerfactory; import org.springframework.boot.web.client.resttemplatebuilder; import org.springframework.scheduling.annotation.async; import org.springframework.stereotype.service; import org.springframework.web.client.resttemplate; import java.util.concurrent.completablefuture; @service public class githublookupservice { private static final logger logger = loggerfactory.getlogger(githublookupservice.class); private final resttemplate resttemplate; public githublookupservice(resttemplatebuilder resttemplatebuilder) { this.resttemplate = resttemplatebuilder.build(); } @async public completablefuture<user> finduser(string user) throws interruptedexception { logger.info("looking up " + user); string url = string.format("https://api.github.com/users/%s", user); user results = resttemplate.getforobject(url, user.class); // artificial delay of 1s for demonstration purposes thread.sleep(1000l); return completablefuture.completedfuture(results); } }
在finduser(string user)中,它在主线程中使用completablefuture,此方法的主要任务是使用resttemplate从github获取数据,功能是“执行http请求的同步客户端”。如何使用长时间运行的任务,如调用网络功能,如从rest端点ping服务器?在这种情况下,您需要定制completablefuture。你不能简单地调用:
return completablefuture.completedfuture(results);
如何使用completablefuture
要在代码中使用@async,您的方法必须返回future或completablefuture,看一下下面的例子:
@async public completablefuture<boolean> isserveralive(string ip) { completablefuture<boolean> future = new completablefuture<boolean>(){ @override public boolean get() throws interruptedexception, executionexception { inetaddress address = null; try { address = inetaddress.getbyname(ip); return address.isreachable(1000); } catch (unknownhostexception e) { e.printstacktrace(); return false; } catch (ioexception e) { e.printstacktrace(); return false; } } }; return future; }
在这个例子中,我重写了get()方法并返回completablefuture而没有任何线程执行器,事实上我们要求spring在不同的线程中执行@async方法,但是我们不提供任何线程执行器,只有后台工作者中运行就足够了。
()
注意:在这个例子中,我决定在spring boot中使用一个网络函数,仅仅是为了一个参数。但最好不要在rest端点中直接使用网络功能,特别是当您希望立即获得结果时。原因是:网络功能是阻塞的,这意味着,如果你调用这个rest端点,您必须在端点等待获取结果。强烈建议使用其他方法(如queue或push方法)(例如websocket)来调用阻塞函数。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
推荐阅读
-
在Spring Boot2中使用CompletableFuture的方法教程
-
Spring Boot中使用activiti的方法教程(一)
-
Spring Boot中使用Activiti的方法教程(二)
-
普通对象使用spring容器中的对象的实现方法
-
Spring boot中PropertySource注解的使用方法详解
-
Spring Boot中使用activiti的方法教程(一)
-
Spring Boot中使用Activiti的方法教程(二)
-
Python中的sort()方法使用基础教程
-
在Yii2中使用Pjax导致Yii2内联脚本载入失败的原因分析,yii2pjax_PHP教程
-
PHP模板引擎Smarty之配置文件在模板变量中的使用方法示例,模板smarty