JDK11的新特性:新的HTTP API

時間 2020-05-20

標籤 jdk11 jdk 特性新的 http api 欄目 Java 简体版

原文原文鏈接

簡介

JDK11以前，java的HTTP功能很弱，只提供了HttpURLConnection來進行HTTP鏈接，而且使用起來很是複雜。因此通常你們都是用第三方的HTTP client（Apache HttpComponents 或者 OkHttp）來進行HTTP請求。java

一切在JDK11的時候徹底變了，在java.net.http包，最新的HttpClient, HttpRequest 和 HttpResponse徹底能夠知足你的需求。git

更多內容請訪問 www.flydean.com

使用HTTP Client請求的基本流程

一般咱們要在代碼中作一個HTTP請求，一般有三個步驟。github

構建一個HTTP client。
生成一個HTTP Request。
使用HTTP Client發送HTTP Request獲得一個HTTP Response。

建立HTTP Client

作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

建立HTTP Request

一樣的，使用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();

發送HTTP請求

有了client和request，咱們就能夠發送HTTP請求了。ui

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

這樣一個完美的HTTP請求就完成了。url

異步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()方法也是能夠的。