JDK11以前,java的HTTP功能很弱,只提供了HttpURLConnection来进行HTTP链接,而且使用起来很是复杂。因此通常你们都是用第三方的HTTP client(Apache HttpComponents 或者 OkHttp)来进行HTTP请求。java
一切在JDK11的时候彻底变了,在java.net.http包,最新的HttpClient, HttpRequest 和 HttpResponse彻底能够知足你的需求。git
更多内容请访问 www.flydean.com
一般咱们要在代码中作一个HTTP请求,一般有三个步骤。github
作HTTP请求,须要创建一个HTTP客户端和HTTP server之间的链接,HTTP协议是很是复杂的,有不少可控的参数。因此须要有一个HttpClient来进行相关的配置。api
HttpClient client = HttpClient.newBuilder() .version(HttpClient.Version.HTTP_2) .connectTimeout(Duration.ofSeconds(5)) .followRedirects(HttpClient.Redirect.ALWAYS) .build();
建立HttpClient很简单,使用newBuilder就能够了,咱们能够指定version,connectTimeout,proxy,SSL,认证或者cookie等。promise
一样的,使用HttpRequest.newBuilder()就能够用来建立HTTP Request。cookie
HttpRequest getRequest = HttpRequest.newBuilder() .GET() .uri(URI.create("http://www.flydean.com")) .header("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/81.0.4044.122 Safari/537.36") .build();
上面的例子咱们建立了一个get请求,并设置了请求的url和head。异步
若是是post请求,则须要构建一个request body:post
HttpRequest.BodyPublisher requestBody = HttpRequest.BodyPublishers .ofString("{ 我是body }"); HttpRequest postRequest = HttpRequest.newBuilder() .POST(requestBody) .uri(URI.create("http://www.flydean.com")) .build();
有了client和request,咱们就能够发送HTTP请求了。ui
HttpResponse<String> response = client.send( getRequest, HttpResponse.BodyHandlers.ofString()); String respnseBody = response.body(); log.info(respnseBody);
这样一个完美的HTTP请求就完成了。url
上面的例子咱们使用client.send来发送http请求,这个请求其实是同步的,这意味着咱们的程序必须一直等待,直到返回请求结果。
HttpClient还提供了一个sendAsync的异步执行的方法。该方法返回一个CompletableFuture。
仍是看个例子:
public void useAsyncHttp() { HttpClient client = HttpClient.newBuilder() .version(HttpClient.Version.HTTP_2) .connectTimeout(Duration.ofSeconds(5)) .followRedirects(HttpClient.Redirect.ALWAYS) .build(); CompletableFuture<Void> completableFuture=checkUri(client,URI.create("http://www.flydean.com")); //获取completableFuture的值 completableFuture.join(); } private CompletableFuture<Void> checkUri(HttpClient httpClient, URI uri){ HttpRequest request = HttpRequest.newBuilder() .GET() .uri(uri) .header("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/81.0.4044.122 Safari/537.36") .build(); return httpClient.sendAsync(request,HttpResponse.BodyHandlers.ofString()) .thenApply(HttpResponse::statusCode) .thenApply(statusCode -> statusCode == 200 ) .exceptionally(ex -> false) .thenAccept(valid -> { if (valid) { log.info("uri {} is valid",uri); } else { log.info("uri {} is not valid", uri); } }); }
上面的例子中咱们获取了HTTP请求,而后调用了CompletableFuture的thenApply和thenAccept对结果进行过滤和处理。
CompletableFuture是Future和CompletionStage的混合体。Future你们都很熟悉了,能够经过get方法获取异步执行的结果。而CompletionStage表明的是一个异步计算的stage,不一样的stage能够互相依赖,经过then*方法来组成一个级联操做。和Stream的操做有点像,和ES6中的promise的then同样,使用CompletionStage能够避免回调地狱。CompletionStage能够将异步回调转换成级联操做。
关于CompletableFuture的更多内容,能够参考关于CompletableFuture的一切,看这篇文章就够了
thenApply的参数是一个Function,thenAccept是一个Consumer。
最后,咱们须要调用completableFuture.join()来保证completableFuture的异步操做执行完成。
固然调用completableFuture.get()方法也是能够的。
本文讲解了JDK12新建立的HTTP Client操做,并进一步讨论了CompletableFuture的使用。
本文的例子[https://github.com/ddean2009/
learn-java-base-9-to-20](https://github.com/ddean2009/...
本文做者:flydean程序那些事本文连接:http://www.flydean.com/jdk11-http-api/
本文来源:flydean的博客
欢迎关注个人公众号:程序那些事,更多精彩等着您!