一、okhttp简介
OkHttp是当下Android使用最频繁的网络请求框架,由Square公司开源。Google在Android4.4以后开始将源码中的HttpURLConnection底层实现替换为OKHttp,同时现在流行的Retrofit框架底层同样是使用OKHttp的。
优点:
- 支持HTTP/2并允许对同一主机的所有请求共享一个套接字
- 通过连接池减少请求延迟
- 默认通过GZip压缩数据
- 响应缓存,避免了重复请求的网络
- 请求失败自动重试主机的其他ip,自动重定向
二、总体架构
okhttp架构主要分为以下几层:
- Interface——接口层:接受网络访问请求
- Protocol——协议层:处理协议逻辑
- Connection——连接层:管理网络连接,发送新的请求,接收服务器访问
- Cache——缓存层:管理本地缓存
- I/O——I/O层:实际数据读写实现
- Inteceptor——拦截器层:拦截网络访问,插入拦截逻辑
三、okhttp工作流程
1. 创建okhttp客户端OkhttpClient;
2. 构建请求Request;
3. 将请求加入队列中并执行;
4. 分发器Dispatcher 进行任务调配和分发;
5. 五大拦截器对请求进行一步步处理;
6. 返回Response结果;
分发器
分发器:负责请求调配和分发,内部包含一个线程池和三个队列,也可以传入自己的线程池。
1. 线程池和队列的数据结构
//异步请求同时存在的最大请求
private int maxRequests = 64;
//异步请求同一域名同时存在的最大请求
private int maxRequestsPerHost = 5;
//闲置任务(没有请求时可执行一些任务,由使用者设置)
private @Nullable Runnable idleCallback;
// 异步请求的 准备队列
private final Deque<AsyncCall> readyAsyncCalls = new ArrayDeque<>();
// 异步请求的 运行队列
private final Deque<AsyncCall> runningAsyncCalls = new ArrayDeque<>();
// 同步请求的队列
private final Deque<RealCall> runningSyncCalls = new ArrayDeque<>();
- 线程池的目的是复用线程
- 此处选择0个核心线程的原因是 核心线程会一直运行,而我们的请求有时候可能会没有,如果我们在一段时间内没有请求,此时如果有线程在运行,是一种资源的浪费,所以此处核心线程数为0
- 此处不限制最大线程池,满足最大需要
- SynchronousQueue的选择:SynchronousQueue是一种没有容量的阻塞队列,阻塞队列的另外两种ArrayBlockingQueue和LinkedBlockingQueue会有容量,如果队列有容量,那么新来的任务会先放到队列中,等上一个任务执行完再执行队列中的任务。队列没有容量,则任务放不进去后,便会直接创建线程去执行。
2. 异步请求的入队及执行
- 先进行条件判断,如果正在请求的数量少于64个 并且 对同一台服务器的请求少于5个时,直接执行任务并将任务加入异步运行队列,否则加入异步准备队列中
synchronized void enqueue(AsyncCall call) {
// todo 1. 正在请求的数量是有限制的 默认64
// 2. 同一主机同一域名正在请求的个数也是有限制的,与同一台服务器进行的请求最多为5个
if (runningAsyncCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) {
runningAsyncCalls.add(call); executorService().execute(call);
} else {
readyAsyncCalls.add(call);
}
}
拦截器
拦截器的控制工作在RealCall的getResponseWithInterceptorChain方法中,五大拦截器均实现了Interceptor方法。
1. 五大拦截器
- 重试拦截器:在交出(交给下一个)之前,负责判断用户是否取消了请求,在获得了结果之后,会根据响应码判断是否需要重定向,如果满足条件那么就会重启执行所有拦截器
- 桥接拦截器:在交出之前,负责将HTTP协议必备的请求头加入其中(如:Host)并添加一些默认的行为(如:GZIP压缩);在获得了结果后,调用保存cookie接口并解析GZIP数据
- 缓存拦截器:顾名思义,交出之前读取并判断是否使用缓存;获得结果后判断缓存;
- 连接拦截器:在交出之前,负责找到或者新建一个连接,并获得对应的socket流,在获得结果后不进行额外的处理
- 请求拦截器:请求服务器拦截器进行真正的与服务器的通信,向服务器发送数据,解析读取的响应数据
2. 拦截器类图和流程图
- 类图:Interceptor是一个抽象接口,五大拦截器均实现了Interceptor接口
- 五大拦截器的实现采用了责任链模式,处理顺序依次是重试和重定向拦截器、桥接拦截器、缓存拦截器、连接拦截器和请求服务拦截器
- 责任链模式:为请求创建了一个接收者对象的链,在处理请求的时候执行过滤(各司其职)。责任链上的处理者负责处理请求,客户只需要将请求发送到责任链即可,无须关心请求的处理细节和请求的传递,所以职责链将请求的发送者和请求的处理者解偶了
重试和重定向拦截器
1. 重试的判定
- 可重试的情况:路由异常、IO异常、超时异常
- 不可重试的情况:协议异常、证书格式错误、证书校验失败
2. 重定向的判定
桥接拦截器
1. 补全请求
2. 处理响应
读取Set-Cookie响应头并调用接口告知用户,在下次请求则会读取对应的数据设置进入请求头,默认CookieJar无实现;
响应头Content-Encoding为gzip,使用GzipSource包装便于解析。
缓存拦截器(重)
1. 缓存命中判定
缓存策略:拦截器通过CacheStrategy判断使用缓存或发起网络请求。此对象中的networkRequest与cacheResponse分别代表需要发起请求或者直接使用缓存
即:networkRequest存在则优先发起网络请求,否则使用cacheResponse缓存,若都不存在则请求失败!
2. 是否缓存判定
3. 面试描述
缓存拦截器,就是判断是否使用缓存,首先缓存要存在,同时要满足http缓存规则和机制,要在有效期内,不在有效期内,和服务器做对比,如果服务器缓存仍然不变,则更新本地缓存有效期,这就是缓存拦截器。
连接拦截器(重)
1. 连接流程
2. 连接池
3. 正常连接
4. 代理连接
- socks代理:创建socket时,直接将代理传入
- http普通代理:将请求的域名+路径放到请求头中,无代理时只有路径没有域名
- https隧道代理:先向目标服务器发送一个 connect,然后再正常发送
请求服务拦截器
1. HTTP报文格式:先把请求头包装成报文格式/流写出去
2. Expect: 100-continue:如果请求头中包含"100-continue",则立即读取服务器的响应头,如果请求头不包含"100-continue",则继续发送请求体