Java11新特性效能翻倍的HttpClient

　　古老的背景
　　从JDK1。1开始，JDK中就有HttpURLConnection来提供了网络连接的能力，但是由于实现的比较古早，其有很多的局限性。比如HttpURLConnection是通过底层提供的socket连接来进行通信，而每一个HttpURLConnection实例只能发送一个请求，之后只能通过close（）释放请求的网络资源，或在持久化连接时用disconnect（）来关闭关闭底层socket。而其基类URLConnection是为了支持很多协议而设计的，但诸如FTP这种协议已经不咋用了。
　　HttpURLConnection并不是不能使用，由于不需要依赖，在一些demo项目的时候也会偶尔拿来用。但HttpURLConnection本身已经太过古早，并且很难说HttpURLConnection能够胜任包含各种鉴权信息、各种COOKIE信息的访问请求。
　　针对这种情况网络上各种大神提供了更多高级的封装，比较流行的有Apache的HttpClient、OkhttpClient、SpringCloudFeign之类的。这些封装提供了更丰富的资源与更便捷的封装，也支持了更高级功能如HTTP2协议、异步请求等。
　　不过到了JDK9的时候，Java提供了一个新的Http请求工具HttpClient，经过了JDK10的再次预览，最终在JAVA11中作为正式功能提供使用，同时也完全替换了仅有阻塞模式的HttpURLConnection。HttpClient简介
　　作为JDK11中正式推出的新Http连接器，支持的功能还是比较新的，主要的特性有：完整支持HTTP2。0或者HTTP1。1支持HTTPSTLS有简单的阻塞使用方法支持异步发送，异步时间通知支持WebSocket支持响应式流
　　HTTP2。0其他的客户端也能支持，而HttpClient使用CompletableFuture作为异步的返回数据。WebSocket的支持则是HttpClient的优势。响应式流的支持是HttpClient的一大优势。
　　而HttpClient中的NIO模型、函数式编程、CompletableFuture异步回调、响应式流让HttpClient拥有极强的并发处理能力，所以其性能极高，而内存占用则更少。
　　HttpClient的主要类有：java。net。http。HttpClientjava。net。http。HttpRequestjava。net。http。HttpResponsejava。net。http。WebSocket（本文就不介绍这个了）
　　细节会在后文介绍，但是WebSocket用的比较少，本文就略过了。核心使用
　　HttpClient的核心类主要就是HttpClient、HttpRequest以及HttpResponse，它们都是位于java。net。http包下，接下来对他们进行一下介绍。HttpClient
　　HttpClient类是最核心的类，它支持使用建造者模式进行复杂对象的构建，主要的参数有：Http协议的版本（HTTP1。1或者HTTP2。0），默认是2。0。是否遵从服务器发出的重定向连接超时时间代理认证可以用参数调整HttpClientclientHttpClient。newBuilder（）。version（Version。HTTP11）。followRedirects（Redirect。NORMAL）。connectTimeout（Duration。ofSeconds（20））。proxy（ProxySelector。of（newInetSocketAddress（proxy。example。com，8080）））。authenticator（Authenticator。getDefault（））。build（）；也可以直接全部默认的便捷创建HttpClientclientSimpleHttpClient。newHttpClient（）；
　　当创建了HttpClient实例后，可以通过其发送多条请求，不用重复创建。HttpRequest
　　HttpRequest是用语描述请求体的类，也支持通过建造者模式构建复杂对象，主要的参数有：请求地址请求方法：GET，POST，DELETE等（默认是GET）请求体（按需设置，例如GET不用body，但是POST要设置）请求超时时间（默认）请求头使用参数组合进行对象构建，读取文件作为请求体HttpRequestrequestHttpRequest。newBuilder（）。uri（URI。create（http：www。baidu。com））。timeout（Duration。ofSeconds（20））。header（Contenttype，applicationjson）。POST（HttpRequest。BodyPublishers。ofFile（Paths。get（data。json）））。build（）；直接GET访问HttpRequestrequestSimpleHttpRequest。newBuilder（URI。create（http：www。baidu。com））。build（）；
　　HttpRequest是一个不可变类，可以被多次发送。HttpResponse
　　HttpResponse没有提供外部可以创建的实现类，它是一个接口，从client的返回值中创建获得。接口中的主要方法为：publicinterfaceHttpResponseT｛publicintstatusCode（）；publicHttpRequestrequest（）；publicOptionalHttpResponseTpreviousResponse（）；publicHttpHeadersheaders（）；publicTbody（）；publicURIuri（）；publicOptionalSSLSessionsslSession（）；publicHttpClient。Versionversion（）；｝
　　HttpResponse的返回内容与常识一致，这里就不展开介绍了。信息发送
　　HttpClient中可以使用同步发送或者异步发送。
　　同步send（）
　　同步发送后，请求会一直阻塞到收到response为止。finalHttpResponseStringsendclient。send（httpRequest，HttpResponse。BodyHandlers。ofString（））；System。out。println（send。body（））；
　　其中send的第二个参数是通过HttpResponse。BodyHandlers的静态工厂来返回一个可以将response转换为目标类型T的处理器（handler），本例子中的类型是String。HttpResponse。BodyHandlers。ofString（）的实现方法为：publicstaticBodyHandlerStringofString（）｛return（responseInfo）BodySubscribers。ofString（charsetFrom（responseInfo。headers（）））；｝
　　其中，BodySubscribers。ofString（）的方法实现是：publicstaticBodySubscriberStringofString（Charsetcharset）｛Objects。requireNonNull（charset）；returnnewResponseSubscribers。ByteArraySubscriber（bytesnewString（bytes，charset））；｝
　　可以看到最终是返回了一个ResponseSubscribers，而Subscribers则是我们之前《JDK9响应式编程》中讨论过的订阅者。这个构造方法的入参Functionbyte〔〕，T定义了订阅者中的finisher属性，而这个属性将在响应式流完成订阅的时在onComplete（）方法中调用。
　　异步sendAsync（）
　　异步请求发送之后，会立刻返回CompletableFuture，然后可以使用CompletableFuture中的方法来设置异步处理器。client。sendAsync（httpRequest，HttpResponse。BodyHandlers。ofString（））。thenApply（HttpResponse：：body）。thenAccept（System。out：：println）。join（）；
　　而就如同JDK中响应式流中发布者的submit（）方法与offer（）方法一样，HttpClient中的send（）方法知识sendAsync方法的特例，在send（）方法中是先调用sendAsync（）方法，然后直接阻塞等待响应结束再返回，部分核心代码为：OverridepublicTHttpResponseTsend（HttpRequestreq，BodyHandlerTresponseHandler）throwsIOException，InterruptedException｛CompletableFutureHttpResponseTcfnull；ifthethreadisalreadyinterruptednoneedtogofurther。cf。get（）wouldthrowanyway。if（Thread。interrupted（））thrownewInterruptedException（）；try｛cfsendAsync（req，responseHandler，null，null）；returncf。get（）；｝catch（InterruptedExceptionie）｛if（cf！null）cf。cancel（true）；throwie；｝。。。
　　响应式流
　　HttpClient作为Request的发布者（publisher），将Request发布到服务器，作为Response的订阅者（subscriber），从服务器接收Response。而上文中我们在send（）的部分发现，调用链的最底端返回的是一个ResponseSubscribers订阅者。
　　当然，就如同HttpResponse。BodyHandlers。ofString（），HttpClient默认提供了一系列的默认订阅者，用语处理数据的转换：HttpRequest。BodyPublishers：：ofByteArray（byte〔〕）HttpRequest。BodyPublishers：：ofByteArrays（Iterable）HttpRequest。BodyPublishers：：ofFile（Path）HttpRequest。BodyPublishers：：ofString（String）HttpRequest。BodyPublishers：：ofInputStream（SupplierInputStream）HttpResponse。BodyHandlers：：ofByteArray（）HttpResponse。BodyHandlers：：ofString（）HttpResponse。BodyHandlers：：ofFile（Path）HttpResponse。BodyHandlers：：discarding（）
　　所以在HttpClient的时候我们也可以自己创建一个实现了Flow。SubscriberListByteBuffer接口的订阅者，用于消费数据。响应式流完整的简单的例子如下：publicclassHttpClientTest｛publicstaticvoidmain（String〔〕args）throwsIOException，InterruptedException｛finalHttpClientclientHttpClient。newHttpClient（）；finalHttpRequesthttpRequestHttpRequest。newBuilder（URI。create（http：www。baidu。com））。build（）；HttpResponse。BodySubscriberStringsubscriberHttpResponse。BodySubscribers。fromSubscriber（newStringSubscriber（），StringSubscriber：：getBody）；client。sendAsync（httpRequest，responseInfosubscriber）。thenApply（HttpResponse：：body）。thenAccept（System。out：：println）。join（）；｝staticclassStringSubscriberimplementsFlow。SubscriberListByteBuffer｛Flow。Subscriptionsubscription；ListByteBufferresponsenewArrayList（）；Stringbody；publicStringgetBody（）｛returnbody；｝OverridepublicvoidonSubscribe（Flow。Subscriptionsubscription）｛this。subscriptionsubscription；subscription。request（1）；｝OverridepublicvoidonNext（ListByteBufferitem）｛response。addAll（item）；subscription。request（1）；｝OverridepublicvoidonError（Throwablethrowable）｛System。err。println（throwable）；｝OverridepublicvoidonComplete（）｛byte〔〕datanewbyte〔response。stream（）。mapToInt（ByteBuffer：：remaining）。sum（）〕；intoffset0；for（ByteBufferbuffer：response）｛intremainbuffer。remaining（）；buffer。get（data，offset，remain）；offsetremain；｝bodynewString（data）；｝｝｝最后
　　HttpClient是JDK11正式上线的高性能Http客户端。其底层基于响应式流，通过上层封装还提供了异步信息发送、同步信息发送，以及其他完成的HTTP协议内容。在进行响应式编程的方面，HttpClient也是一个十分优秀的参照目标。