在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方法，但是我们不提供任何线程执行器，只有后台工作者中运行就足够了。
download source code from github （本地下载）
注意：在这个例子中，我决定在Spring Boot中使用一个网络函数，仅仅是为了一个参数。但最好不要在REST端点中直接使用网络功能，特别是当您希望立即获得结果时。原因是：网络功能是阻塞的，这意味着，如果你调用这个REST端点，您必须在端点等待获取结果。强烈建议使用其他方法（如queue或push方法）（例如websocket）来调用阻塞函数。
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。
相关文章
这篇文章主要介绍了Java IO读取文件的实例详解的相关资料,主要介绍字符流和字节流的内容，需要的朋友可以参考下2017-07-07
这篇文章主要介绍了Lombok使用@Tolerate实现冲突兼容问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-08-08
这篇文章主要介绍了SpringDataJpa增删改查操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-07-07
这篇文章主要介绍了Struts2下拉框实例解析，分享了相关代码示例，小编觉得还是挺不错的，具有一定借鉴价值，需要的朋友可以参考下2018-02-02
springboot prototype设置多例不起作用的解决操作
这篇文章主要介绍了springboot prototype设置多例不起作用的解决操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-09-09
今天小编就为大家分享一篇java判断字符串相等的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-07-07
这篇文章主要介绍了Java字段初始化的规律解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-10-10
这篇文章主要介绍了如何将java打包成可执行的jar，并执行jar包中指定的main方法的相关资料，文中给出了详细的示例代码，对大家具有一定的参考价值，需要的朋友们下面来一起看看吧。2017-03-03
RESTful是一种web软件风格，它不是标准也不是协议，它不一定要采用,只是一种风格，它倡导的是一个资源定位(url)及资源操作的风格，这篇文章主要介绍了SpringBoot使用RESTful接口2022-11-11
这篇文章主要介绍了Servlet开发JavaWeb工程示例详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-07-07
最新评论