JDK11的新特性:新的HTTP API

简介: JDK11的新特性:新的HTTP API

目录



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。


  1. 生成一个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的使用。


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

相关文章
|
21天前
|
Java API 数据库
构建RESTful API已经成为现代Web开发的标准做法之一。Spring Boot框架因其简洁的配置、快速的启动特性及丰富的功能集而备受开发者青睐。
【10月更文挑战第11天】本文介绍如何使用Spring Boot构建在线图书管理系统的RESTful API。通过创建Spring Boot项目,定义`Book`实体类、`BookRepository`接口和`BookService`服务类,最后实现`BookController`控制器来处理HTTP请求,展示了从基础环境搭建到API测试的完整过程。
36 4
|
7天前
|
JavaScript 前端开发 API
Vue 3新特性详解:Composition API的威力
【10月更文挑战第25天】Vue 3 引入的 Composition API 是一组用于组织和复用组件逻辑的新 API。相比 Options API,它提供了更灵活的结构,便于逻辑复用和代码组织,特别适合复杂组件。本文将探讨 Composition API 的优势,并通过示例代码展示其基本用法,帮助开发者更好地理解和应用这一强大工具。
15 1
|
1月前
|
存储 安全 Java
jdk21的外部函数和内存API(MemorySegment)(官方翻译)
本文介绍了JDK 21中引入的外部函数和内存API(MemorySegment),这些API使得Java程序能够更安全、高效地与JVM外部的代码和数据进行互操作,包括调用外部函数、访问外部内存,以及使用不同的Arena竞技场来分配和管理MemorySegment。
28 1
jdk21的外部函数和内存API(MemorySegment)(官方翻译)
|
20天前
|
缓存 JavaScript 前端开发
深入理解 Vue 3 的 Composition API 与新特性
本文详细探讨了 Vue 3 中的 Composition API,包括 setup 函数的使用、响应式数据管理(ref、reactive、toRefs 和 toRef)、侦听器(watch 和 watchEffect)以及计算属性(computed)。我们还介绍了自定义 Hooks 的创建与使用,分析了 Vue 2 与 Vue 3 在响应式系统上的重要区别,并概述了组件生命周期钩子、Fragments、Teleport 和 Suspense 等新特性。通过这些内容,读者将能更深入地理解 Vue 3 的设计理念及其在构建现代前端应用中的优势。
26 0
深入理解 Vue 3 的 Composition API 与新特性
|
2月前
|
存储 JavaScript 前端开发
敲黑板!vue3重点!一文了解Composition API新特性:ref、toRef、toRefs
该文章深入探讨了Vue3中Composition API的关键特性,包括`ref`、`toRef`、`toRefs`的使用方法与场景,以及它们如何帮助开发者更好地管理组件状态和促进逻辑复用。
敲黑板!vue3重点!一文了解Composition API新特性:ref、toRef、toRefs
|
2月前
|
容器
jdk8新特性-详情查看文档
jdk8新特性-详情查看文档
42 3
|
2月前
|
Java 程序员 API
Java 8新特性之Lambda表达式与Stream API的探索
【9月更文挑战第24天】本文将深入浅出地介绍Java 8中的重要新特性——Lambda表达式和Stream API,通过实例解析其语法、用法及背后的设计哲学。我们将一探究竟,看看这些新特性如何让Java代码变得更加简洁、易读且富有表现力,同时提升程序的性能和开发效率。
|
27天前
|
存储 安全 Java
JDK1.8 新的特性
JDK1.8 新的特性
18 0
|
1月前
|
API
使用`System.Net.WebClient`类发送HTTP请求来调用阿里云短信API
使用`System.Net.WebClient`类发送HTTP请求来调用阿里云短信API
20 0
|
2月前
|
安全 Java API
【性能与安全的双重飞跃】JDK 22外部函数与内存API:JNI的继任者,引领Java新潮流!
【9月更文挑战第7天】JDK 22外部函数与内存API的发布,标志着Java在性能与安全性方面实现了双重飞跃。作为JNI的继任者,这一新特性不仅简化了Java与本地代码的交互过程,还提升了程序的性能和安全性。我们有理由相信,在外部函数与内存API的引领下,Java将开启一个全新的编程时代,为开发者们带来更加高效、更加安全的编程体验。让我们共同期待Java在未来的辉煌成就!
62 11