在上文中分析了 HttpURLConnection的用法,功能还是比较简单的,没有什么封装
接下来看看Apache HttpClient
是如何封装httpClient的
使用的版本
<dependency>
<groupId>org.apache.httpcomponents.client5</groupId>
<artifactId>httpclient5</artifactId>
<version>5.2.1</version>
</dependency>
组成
HttpClient 5 的系统架构主要由以下几个部分组成:
- HttpCore:核心包,包含了 HTTP 协议的核心抽象和实现,定义了 HTTP 客户端和服务端的基本组件,例如请求消息、响应消息、传输层等。
- HttpClient:高级 API,封装了 HttpCore 包中的核心抽象,提供了一组简单易用的 API,以便于客户端应用程序发送 HTTP 请求。
- HttpAsyncClient:异步 API,是基于 HttpCore 和 HttpClient 构建的异步 HTTP 客户端,可以通过异步方式实现 HTTP 请求。
- HttpClient 和 HttpAsyncClient 都可以通过扩展进行定制和优化,可以添加拦截器、设置连接管理器、Cookie 管理器、认证器等。
请求代码
GET请求代码
String resultContent = null;
String url = "http://127.0.0.1:8081/get";
HttpGet httpGet = new HttpGet(url);
//通过工厂获取
CloseableHttpClient httpClient = HttpClients.createDefault();
//请求
CloseableHttpResponse response = httpClient.execute(httpGet);
// Get status code
System.out.println(response.getVersion());
// HTTP/1.1
System.out.println(response.getCode());
// 200
System.out.println(response.getReasonPhrase());
// OK
HttpEntity entity = response.getEntity();
// Get response information
resultContent = EntityUtils.toString(entity);
System.out.println(resultContent);
代码分析
创建实例
Apache HttpClient提供了一个工厂类来返回HttpClient
实例
但实际上都是通过HttpClientBuilder
去创建的,
Apache HttpClient通过构建者模式加上策略模式实现非常灵活的配置,以实现各种不同的业务场景
通过看build()的代码,创建HttpClient
主要分为两步
public static CloseableHttpClient createDefault() {
return HttpClientBuilder.create().build();
}
第一步是初始化配置
里边很多策略模式的使用,可以实现相关的类来拓展自己的需求,可以通过HttpClient
的set方法把新的策略设置进去,其他配置也可以通过RequestConfig
设置好
ConnectionKeepAliveStrategy keepAliveStrategyCopy = this.keepAliveStrategy;
if (keepAliveStrategyCopy == null) {
keepAliveStrategyCopy = DefaultConnectionKeepAliveStrategy.INSTANCE;
}
AuthenticationStrategy targetAuthStrategyCopy = this.targetAuthStrategy;
if (targetAuthStrategyCopy == null) {
targetAuthStrategyCopy = DefaultAuthenticationStrategy.INSTANCE;
}
AuthenticationStrategy proxyAuthStrategyCopy = this.proxyAuthStrategy;
if (proxyAuthStrategyCopy == null) {
proxyAuthStrategyCopy = DefaultAuthenticationStrategy.INSTANCE;
}
在这里会初始化包括连接管理器、请求重试处理器、请求执行器、重定向策略、认证策略、代理、SSL/TLS等配置
第二步是创建处理器链
通过组合多个处理器来构建成处理器链处理请求
需要注意的是这里的添加顺序的方法,添加最终的执行处理器调用的是addLast()
处理器链中的每个处理器都有不同的功能,例如请求预处理、重试、身份验证、请求发送、响应解析等等。在每个处理器的处理过程中,可以对请求或响应进行修改或扩展,以满足不同的需求
最后再把初始化好的参数传递给InternalHttpClient
返回一个HttpClient
实例
发起请求
接下来看看请求方法
CloseableHttpResponse response = httpClient.execute(httpGet);
主要请求方法在InternalHttpClient#doExecute
中
主要分为三步,第一步是将各种配置填充到上下文中HttpContext
第二步,执行刚刚封装执行链
//execChain就是上一步封装好的执行链
final ClassicHttpResponse response = this.execChain.execute(ClassicRequestBuilder.copy(request).build(), scope);
执行 execute
方法,执行链中的处理器被依次调用,每个元素都可以执行一些预处理、后处理、重试等逻辑
第三步,请求结束后,将结果转换为CloseableHttpResponse
返回
自定义拦截器和处理器
接下来试试加一下自定义的拦截器和处理器
拦截器和处理器的实现是不一样的,处理器的实现是ExecChainHandler
,拦截器是HttpResponseInterceptor
和HttpRequestInterceptor
//执行链处理器
class MyCustomInterceptor implements ExecChainHandler {
@Override
public ClassicHttpResponse execute(ClassicHttpReque