JDK11的新特性:新的HTTP API

简介

JDK11以前，java的HTTP功能很弱，只提供了HttpURLConnection来进行HTTP链接，而且使用起来很是复杂。因此通常你们都是用第三方的HTTP client（Apache HttpComponents 或者 OkHttp）来进行HTTP请求。

一切在JDK11的时候彻底变了，在java.net.http包，最新的HttpClient, HttpRequest 和 HttpResponse彻底能够知足你的需求。

更多内容请访问www.flydean.com

使用HTTP Client请求的基本流程

一般咱们要在代码中作一个HTTP请求，一般有三个步骤。

1. 构建一个HTTP client。
2. 生成一个HTTP Request。
3. 使用HTTP Client发送HTTP Request获得一个HTTP Response。

建立HTTP Client

作HTTP请求，须要创建一个HTTP客户端和HTTP server之间的链接，HTTP协议是很是复杂的，有不少可控的参数。因此须要有一个HttpClient来进行相关的配置。

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等。

建立HTTP Request

一样的，使用HttpRequest.newBuilder()就能够用来建立HTTP Request。

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：

HttpRequest.BodyPublisher requestBody = HttpRequest.BodyPublishers
                .ofString("{ 我是body }");
        HttpRequest postRequest = HttpRequest.newBuilder()
                .POST(requestBody)
                .uri(URI.create("http://www.flydean.com"))
                .build();
复制代码

发送HTTP请求

有了client和request，咱们就能够发送HTTP请求了。

HttpResponse<String> response = client.send( getRequest, HttpResponse.BodyHandlers.ofString());
        String respnseBody = response.body();
        log.info(respnseBody);
复制代码

这样一个完美的HTTP请求就完成了。

异步HTTP请求

上面的例子咱们使用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的使用。

本文的例子github.com/ddean2009/ learn-java-base-9-to-20

本文做者：flydean程序那些事

本文连接：www.flydean.com/jdk11-http-…

本文来源：flydean的博客

欢迎关注个人公众号:程序那些事，更多精彩等着您！