[移动开发] OkHttp源码解析

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 移动开发 -> OkHttp源码解析 -> 正文阅读

[移动开发]OkHttp源码解析

阅读源码目标

了解底层原理，有助于使用API，排查问题
学习设计模式
学习系统架构
面试

功能及原理

功能

同步请求
异步请求
WebSocket
自定义拦截器处理缓存，重定向，请求体管理Bridge，链接管理

核心流程
RealCall 保存了拦截器List

// RealCall.kt
 @Throws(IOException::class)
  internal fun getResponseWithInterceptorChain(): Response {
    val interceptors = mutableListOf<Interceptor>()
    interceptors += client.interceptors
    interceptors += RetryAndFollowUpInterceptor(client)
    interceptors += BridgeInterceptor(client.cookieJar)
    interceptors += CacheInterceptor(client.cache)
    interceptors += ConnectInterceptor
   ......
   }

RealCall 发起请求后构建RealInterceptorChain对象，构造方法传入连接器List和当前访问的Index。

 val chain = RealInterceptorChain(
        call = this,
        interceptors = interceptors,
        index = 0,
    )

执行val response = chain.proceed(originalRequest)，该方法会进入到如下逻辑：

// index+1 构建下一个拦截器的RealInterceptorChain对象
    val next = copy(index = index + 1, request = request)
    val interceptor = interceptors[index]

    @Suppress("USELESS_ELVIS")
    val response = interceptor.intercept(next) ?: throw NullPointerException(
        "interceptor $interceptor returned null")

在提供的几种Intercept中会执行自身拦截处理逻辑，调用chain.proceed返回response，将责任链继续传导下去。
整体责任链其实是一个递归模式，假如拦截器List中是ABCD，先执行A的request的处理，再调用chain.proceed，继而执行B的request的处理，直到CD，接下来再从D一步步返回A，处理Response。
在这里插入图片描述

核心代码

Response getResponseWithInterceptorChain() throws IOException {
    // Build a full stack of interceptors.
    //用来盛放所有的拦截器的
    List<Interceptor> interceptors = new ArrayList<>();
    
    //1. 添加用户定义的拦截器
    interceptors.addAll(client.interceptors());
    //2. 添加一些OkHttp自带的拦截器
    interceptors.add(new RetryAndFollowUpInterceptor(client));
    interceptors.add(new BridgeInterceptor(client.cookieJar()));
    interceptors.add(new CacheInterceptor(client.internalCache()));
    interceptors.add(new ConnectInterceptor(client));
    
    if (!forWebSocket) {
      //这里还有一个网络拦截器,也是可以用户自定义的
      interceptors.addAll(client.networkInterceptors());
    }
    
    //最终访问服务器的拦截器
    interceptors.add(new CallServerInterceptor(forWebSocket));
    
    //3. 将拦截器,当前拦截器索引等传入Interceptor.Chain
    Interceptor.Chain chain = new RealInterceptorChain(interceptors, transmitter, null, 0,
        originalRequest, this, client.connectTimeoutMillis(),
        client.readTimeoutMillis(), client.writeTimeoutMillis());
    
    boolean calledNoMoreExchanges = false;
    try {
      //4. 请求访问下一个拦截器
      Response response = chain.proceed(originalRequest);
      if (transmitter.isCanceled()) {
        closeQuietly(response);
        throw new IOException("Canceled");
      }
      return response;
    } catch (IOException e) {
      calledNoMoreExchanges = true;
      throw transmitter.noMoreExchanges(e);
    } finally {
      if (!calledNoMoreExchanges) {
        transmitter.noMoreExchanges(null);
      }
    }
}