OkHttp4.9.3源码详解

2022-06-09 21:36:50

一.Dispatcher工作流程

1）OkHttp的基本使用

我们先从okHttp最基础的使用开始

private fun httpRequestWithManyRequests() {
    // 创建了一个okHttpClient对象 
    val okHttpClient = OkHttpClient.Builder().build()
    // 创建了一个请求
    val request = Request.Builder().url("https://www.baidu.com").build())
    // 通过okHttpClient创建出一个call对象
    val call = okHttpClient.newCall(request)
    // 调用call对象的enqueue方法异步请求网络并通过回调获取响应
    call.enqueue(object : Callback {
        override fun onFailure(call: Call, e: IOException) {
            Log.i("httpRequestWithManyRequests", "onFailure: " + e.message)
        }

        override fun onResponse(call: Call, response: Response) {
            Log.i("httpRequestWithManyRequests", "onResponse: " + response.body?.string())
        }
    })
}

结合注释，我们很容易可以看出okHttpClient发起网络请求的入口是在enqueue所以我们应该从这里开始追踪代码，
需要注意的是这里的call是一个RealCall对象，RealCall也是Call接口的唯一实现类，所以很好定位。

override fun newCall(request: Request): Call = RealCall(this, request, forWebSocket = false)

2）RealCall.enqueue

override fun enqueue(responseCallback: Callback) {
  check(executed.compareAndSet(false, true)) { "Already Executed" }
         
  callStart()
  // 这里的callback就是客户端注册的回调
  // 这里将callback封装成AsyncCall对象后交给okHttpClient的dispatcher（分发器）进行管理
  client.dispatcher.enqueue(AsyncCall(responseCallback))
}

3） Dispatcher.enqueue

internal fun enqueue(call: AsyncCall) {
  synchronized(this) {
    // 将call加入就绪队列
    readyAsyncCalls.add(call)
      
    if (!call.call.forWebSocket) {
      val existingCall = findExistingCallWithHost(call.host)
      if (existingCall != null) call.reuseCallsPerHostFrom(existingCall)
    }
  }
  
  // 遍历就绪队列，将符合条件的asyncCall送入线程池中执行
  promoteAndExecute()
}

Dispatcher的enqueue方法主要做了两件事

将asyncCall加入就绪队列
调用promoteAndExecute()方法，遍历就绪队列，将符合条件的asyncCall送入线程池中执行

接下来就到了promoteAndExecute()方法

4）Dispatcher.promoteAndExcute

private fun promoteAndExecute(): Boolean {
  this.assertThreadDoesntHoldLock()
  
  val executableCalls = mutableListOf<AsyncCall>()
  val isRunning: Boolean
  synchronized(this) {
    // 遍历就绪队列，从就就绪队列中取出符合条件的asyncCall
    // 调用asyncCall的
    val i = readyAsyncCalls.iterator()
    while (i.hasNext()) {
      val asyncCall = i.next()
       // 总请求个数不能操作 64 个
      if (runningAsyncCalls.size >= this.maxRequests) break // Max capacity.
       // 请求同一个主机的请求不能操作this.maxRequestsPerHost（5）个
      if (asyncCall.callsPerHost.get() >= this.maxRequestsPerHost) continue 

      // 将满足条件的asyncCall从ready队列中移除  
      i.remove()
      // 访问该主机的请求数 + 1
      asyncCall.callsPerHost.incrementAndGet()
      // 将asyncCall添加到executableCalls，while循环后会将该队列中的asyncCall送到线程池中执行
      executableCalls.add(asyncCall)
      // 将asyncCall 添加到running队列
      runningAsyncCalls.add(asyncCall)
    }
    isRunning = runningCallsCount() > 0
  }
  
  // 将该队列中的asyncCall送到线程池中执行
  for (i in 0 until executableCalls.size) {
    val asyncCall = executableCalls[i]
    asyncCall.executeOn(executorService)
  }

  return isRunning
}

整理一下流程：

遍历就绪队列
找出就绪队列中符合条件的asyncCall，asyncCall需要满足以下两个条件
（1）当前正在进行的请求数不能超过64个
（2）对同一个主机的访问数不能超过5个
将满足的条件从就绪队列中移除，然后分别加入running队列和executable对了
将executable队列中的asyncCall送到线程池中执行

这里需要知道，AsyncCall是一个实现了Runnable接口的类

internal inner class AsyncCall(private val responseCallback: Callback) : Runnable {
   ...
}

然后可以来看看AsyncCall的executeOn方法

5） AsyncCall.executeOn

fun executeOn(executorService: ExecutorService) {
  client.dispatcher.assertThreadDoesntHoldLock()

  var success = false
  try {
    // 添加到线程池执行
    executorService.execute(this)
    success = true
  } catch (e: RejectedExecutionException) {
    val ioException = InterruptedIOException("executor rejected")
    ioException.initCause(e)
    noMoreExchanges(ioException)
    responseCallback.onFailure(this@RealCall, ioException)
  } finally {
    if (!success) {
      client.dispatcher.finished(this) // This call is no longer running!
    }
  }
}

异常处理这里就不去详细追究了，
我们看看executorService.execute(this)这句代码，executorService是一个ExecutorService，
实际上它就是线程池ThreadPoolExecutor

@get:Synchronized
@get:JvmName("executorService") val executorService: ExecutorService
  get() {
    if (executorServiceOrNull == null) {
      executorServiceOrNull = ThreadPoolExecutor(0, Int.MAX_VALUE, 60, TimeUnit.SECONDS,
          SynchronousQueue(), threadFactory("$okHttpName Dispatcher", false))
    }
    return executorServiceOrNull!!
  }

所以AsyncCall.executeOn主要就是将AsyncCall自身加入线程池，由线程池管理和执行。而上面提到AyncCall是一个Runnable对象，我们要追踪它执行的逻辑就得去看看它的run方法

6）AsyncCall.run

override fun run() {
    threadName("OkHttp ${redactedUrl()}") {
      var signalledCallback = false
      timeout.enter()
      try {
        // 调用拦截器链获取请求响应
        val response = getResponseWithInterceptorChain()
        signalledCallback = true
        // 回调响应
        responseCallback.onResponse(this@RealCall, response)
      } catch (e: IOException) {
        if (signalledCallback) {
          // Do not signal the callback twice!
          Platform.get().log("Callback failure for ${toLoggableString()}", Platform.INFO, e)
        } else {
          responseCallback.onFailure(this@RealCall, e)
        }
      } catch (t: Throwable) {
        cancel()
        if (!signalledCallback) {
          val canceledException = IOException("canceled due to $t")
          canceledException.addSuppressed(t)
          responseCallback.onFailure(this@RealCall, canceledException)
        }
        throw t
      } finally {
        // 不管请求是否成功，最终都需要调用AsyncCall的finish方法
        client.dispatcher.finished(this)
      }
    }
  }
}

异常处理的部分还是不分析了，AsyncCall的run方法就是
1.调用拦截器链获取响应
2.如果请求途中出现异常，则对异常进行响应的处理
3.若成功获取响应，那么回调该响应给客户端
4.无论是请求成功还是应为异常终止，最终都会调用Dispatcher的finish方法

最后来看看Dispatcher.finish

7）Dispatcher.finish

internal fun finished(call: AsyncCall) {
  // 该AsyncCall对于的主机的请求数 - 1
  call.callsPerHost.decrementAndGet()
  // 将AsyncCall从running队列移除，并唤醒其他位于ready队列中的AsyncCall
  finished(runningAsyncCalls, call)
}

接下来看看重载的finish方法

private fun <T> finished(calls: Deque<T>, call: T) {
  val idleCallback: Runnable?
  synchronized(this) {
    // 将asyncCall从running队列中移除，移除失败抛出异常
    if (!calls.remove(call)) throw AssertionError("Call wasn't in-flight!")
    idleCallback = this.idleCallback
  }

  // 这里又调用了promoteAndExecute方法，该方法在上介绍过，就是遍历ready队列，从中取出满足条件的AsyncCall加入running队列，并交给线程池管理和执行
  val isRunning = promoteAndExecute()

  if (!isRunning && idleCallback != null) {
    idleCallback.run()
  }
}

总的来说，finish方法中主要做了以下几件事

执行完毕的asyncCall对应的主机的请求数 - 1
将asyncCall从running队列中移除
调用promoteAndExcute方法，唤醒下一个(组)满足条件的AsyncCall，并将它(们)加入running队列，然后交给线程池管理和执行

8）总体流程总结

二.拦截器链

通过okHttp整理工作流程的分析，我们知道网络请求的响应是在AsyncCall的run方法中，通过调用拦截器链得到的

val response = getResponseWithInterceptorChain()

我们来看看拦截器链

1）AsyncCall.getResponseWithInterceptor

@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
  // 添加用户自定义的网络拦截器
  if (!forWebSocket) {
    interceptors += client.networkInterceptors
  }
  // 添加呼叫服务拦截器
  interceptors += CallServerInterceptor(forWebSocket)

    
  // 新建拦截器链
  val chain = RealInterceptorChain(
      call = this,
      interceptors = interceptors, // 注意这里将拦截器看列表作为参数传入
      index = 0,
      exchange = null,
      request = originalRequest,
      connectTimeoutMillis = client.connectTimeoutMillis,
      readTimeoutMillis = client.readTimeoutMillis,
      writeTimeoutMillis = client.writeTimeoutMillis
  )

  var calledNoMoreExchanges = false
  try {
    // chain.proceed(originalRequest)用于将请求传递给下一个拦截器，这里将会传给拦截器链表中的第一个拦截器（如果用户没有添加应用拦截器，那么就是重试和重定向拦截器）
    val response = chain.proceed(originalRequest)
    if (isCanceled()) {
      response.closeQuietly()
      throw IOException("Canceled")
    }
    return response
  } catch (e: IOException) {
    calledNoMoreExchanges = true
    throw noMoreExchanges(e) as Throwable
  } finally {
    if (!calledNoMoreExchanges) {
      noMoreExchanges(null)
    }
  }
}

结合注释我们关注一下val response = chain.proceed(originalRequest)，它用于将请求传递给下一个拦截器，这里将会传给拦截器链表中的第一个拦截器，如果用户没有添加应用拦截器，那么就是重试和重定向拦截器

我们来看看RealInterceptorChain.proceed方法

2） RealInterceptorChain.proceed

override fun proceed(request: Request): Response {
  check(index < interceptors.size)

  calls++

  if (exchange != null) {
    check(exchange.finder.sameHostAndPort(request.url)) {
      "network interceptor ${interceptors[index - 1]} must retain the same host and port"
    }
    check(calls == 1) {
      "network interceptor ${interceptors[index - 1]} must call proceed() exactly once"
    }
  }

  // 构造出下一条拦截器链，注意下index = index + 1 ，index参数用于从拦截器链对象的拦截器列表中取出相应的拦截器链
  val next = copy(index = index + 1, request = request)
  // 获取到当前index对应的拦截器
  val interceptor = interceptors[index]

  @Suppress("USELESS_ELVIS")
  // 调用拦截器的intercept方法，而每个拦截器的Interceptor都会调用processed
  val response = interceptor.intercept(next) ?: throw NullPointerException(
      "interceptor $interceptor returned null")

  if (exchange != null) {
    check(index + 1 >= interceptors.size || next.calls == 1) {
      "network interceptor $interceptor must call proceed() exactly once"
    }
  }

  check(response.body != null) { "interceptor $interceptor returned a response with no body" }

  return response
}

3）RealInterceptorChain.processed在各种拦截器的Interceptor方法中的调用

【1】RetryAndFollowUpInterceptor.intercepte

@Throws(IOException::class)
override fun intercept(chain: Interceptor.Chain): Response {
 //  ... 
  
        // 将请求交给下一个拦截器
        response = realChain.proceed(request)
          
//   ...
          
    // 返回结果给上一个拦截器
    return response
}

【2】BridageInterceptor.intercepte

override fun intercept(chain: Interceptor.Chain): Response {
  val userRequest = chain.request()
  val requestBuilder = userRequest.newBuilder()
  
  // ..........
  
  // 将请求交给下一个拦截器
  val networkResponse = chain.proceed(requestBuilder.build())

  // ..........  

  // 处理下一个拦截器返回的响应
  val responseBuilder = networkResponse.newBuilder()
      .request(userRequest)

  // .........
    
  // 将结果返回给上一个拦截器
  return responseBuilder.build()
}

【3】 CacheIntercptor.intercepte

override fun intercept(chain: Interceptor.Chain): Response {
  val call = chain.call()
  val cacheCandidate = cache?.get(chain.request())
    
  // ..........  

  var networkResponse: Response? = null
  try {
    // 将请求交给下一个拦截器，因为下一个拦截器属于网络拦截器，所以变量名叫networkResponse
    networkResponse = chain.proceed(networkRequest)
  } finally {
    if (networkResponse == null && cacheCandidate != null) {
      cacheCandidate.body?.closeQuietly()
    }
  }

  // ...... 处理networkResponse
  
  // 返回结果给上一个拦截器
  return response
}

【4】ConnecteInterceptor.Intercepte

object ConnectInterceptor : Interceptor {
  @Throws(IOException::class)
  override fun intercept(chain: Interceptor.Chain): Response {
    val realChain = chain as RealInterceptorChain
    val exchange = realChain.call.initExchange(chain)
    val connectedChain = realChain.copy(exchange = exchange)
    // 将下一个拦截器返回的结果直接返回给上一个拦截器
    return connectedChain.proceed(realChain.request)
  }
}

【5】CallServerInterceptor.intercepte

override fun intercept(chain: Interceptor.Chain): Response {
  // 这个是拦截器链中的最后一个拦截器，所以无需再调用RealInterceptorChain.Intercept，它负责从套接字缓存去读写数据，是直接于服务器通讯的对象
  
  // ...... 处理和服务器通讯的结果，得到Response
  
  // 返回响应
  return response
}

4）拦截器链流程图

三.拦截器

1.五种拦截器介绍

1）RetryAndFollowUpInterceptor - 重定向拦截器

这种拦截器属于应用程序类拦截器，它用于处理重定向或者网络请求过程失败时的重试

2）BridgeInterceptor - 桥接拦截器

这种拦截器用于处理构建RequestHeader请求头类

3）CacheInterceptor - 缓存拦截器

该拦截器用于处理请求数据的缓存
在客户端向服务器发起一次请求会经过缓存拦截器：
1.缓存拦截器会判断是否存有该次请求url的缓存数据
1）有，直接从缓存中读取数据，网络请求中断
2）没有的话，缓存拦截器会放行该次请求，等到获取服务器的响应之后，将从服务器响应的数据进行缓存

4）ConnectInterceptor - 连接拦截器

1.在这里主要会创建RealConnection对象，该对象用于创建客户端与服务器之间的套接字连接。
2.调用RealConnection的newCodec方法，该方法会根据url类型（Http1 ， Http2）生成不同的ExchangeCodec（Http1ExchangeCodec，Http2ExchangeCodec）并将其交由Exchange管理。

而ExchangeCodec负责向服务器和客户端之间的套接字缓冲区读写数据

5）CallServerInterceptor - 呼叫服务拦截器

这里就是操作ExchangeCodec向套接字缓冲区读写数据

2.五种拦截器源码分析

1.RetryAndFollowUpInterceptor - 重定向拦截器

1）intercept方法分析

override fun intercept(chain: Interceptor.Chain): Response {
  //获取拦截器链
  val realChain = chain as RealInterceptorChain
  var request = chain.request
  val call = realChain.call
  var followUpCount = 0
  var priorResponse: Response? = null
  var newExchangeFinder = true
  var recoveredFailures = listOf<IOException>()
  while (true) 
    // 如果newExchangeFinder == true，这里会创建一个Exchange对象
    call.enterNetworkInterceptorExchange(request, newExchangeFinder)
    var response: Response
    var closeActiveExchange = true 
    try {
      // 如果中途取消请求，则抛出异常，改异常不会再该方法中捕获，所以会直接跳出该方法
      if (call.isCanceled()) {
        throw IOException("Canceled")
      }

      try {
        // 调用拦截器链获取response
        response = realChain.proceed(request)
        newExchangeFinder = true
      } catch (e: RouteException) {
        // 连接路由失败
        if (!recover(e.lastConnectException, call, request, requestSendStarted = false)) {
          throw e.firstConnectException.withSuppressed(recoveredFailures)
        } else {
          recoveredFailures += e.firstConnectException
        }
        // 无需再新建一个Exchage
        newExchangeFinder = false
        // 重试
        continue
      } catch (e: IOException) {
        // 连接服务器失败
        if (!recover(e, call, request, requestSendStarted = e !is ConnectionShutdownException))             
        {
          throw e.withSuppressed(recoveredFailures)
        } else {
          recoveredFailures += e
        }
        // 无需再新建一个Exchage
        newExchangeFinder = false
        // 重试
        continue
      }

      // Attach the prior response if it exists. Such responses never have a body.
      if (priorResponse != null) {
        response = response.newBuilder()
            .priorResponse(priorResponse.newBuilder()
                .body(null)
                .build())
            .build()
      }

     
      val exchange = call.interceptorScopedExchange
      // 根据response的返回码生成重定向Request即followUp
      val followUp = followUpRequest(response, exchange)

      // followUp == null表示无需进行下一步也就是重定向请求。直接返回response
      if (followUp == null) {
        if (exchange != null && exchange.isDuplex) {
          call.timeoutEarlyExit()
        }
        // 将该标志位置为false，表示无需关闭exchange
        closeActiveExchange = false
        return response
      }

      val followUpBody = followUp.body
      if (followUpBody != null && followUpBody.isOneShot()) {
        // 将该标志位置为false，表示无需关闭exchange
        closeActiveExchange = false
        return response
      }
      
      // 走到这一步，说明还需要进行重定向请求，也就是该response不是客户端想要的响应，所以先关闭该response.body
      response.body?.closeQuietly()
       
      // 如果尝试次数超过MAX_FOLLOW_UPS，也就是20次，那么直接抛出异常（这个异常不会在该方法中被捕获）
      if (++followUpCount > MAX_FOLLOW_UPS) {
        throw ProtocolException("Too many follow-up requests: $followUpCount")
      }
      
      // 将request换成重定向后的请求
      request = followUp
      // 保存上一个response
      priorResponse = response
    } finally {
      // 根据closeActiveExchange的值判断是否需要关闭exchange，每次循环的最后都会执行
      call.exitNetworkInterceptorExchange(closeActiveExchange)
    }
  }
}

先来了解一下ExchangeFinder：
ExchangeFinder在网络请求开始前，会根据request中的url的主机字段寻找到一个RealConnection，进而通过RealConnection获取到ExchangeCodec对象。
RealConnection：对应一个套接字连接
ExchangeCodec：用于向套接字缓冲区读写数据

ExchangeFinder是通过该方法中的call.enterNetworkInterceptorExchange(request, newExchangeFinder)这一行代码创建的

fun enterNetworkInterceptorExchange(request: Request, newExchangeFinder: Boolean) {
  check(interceptorScopedExchange == null)

  synchronized(this) {
    check(!responseBodyOpen) {
      "cannot make a new request because the previous response is still open: " +
          "please call response.close()"
    }
    check(!requestBodyOpen)
  }
  // 根据newExchangeFinder标志位出创建ExchangeFinder
  if (newExchangeFinder) {
    this.exchangeFinder = ExchangeFinder(
        connectionPool,
        createAddress(request.url),
        this,
        eventListener
    )
  }
}

最后梳理一下流程：
开启一个循环用作重定向请求和网络请求失败后的重试

根据newExchangeFinder标识符的值创建一个ExchangeFinder,这里会有两种情况

(1) 请求因为异常(连接路由异常或者连接服务器异常)返回，该异常会被捕获然后调用continue进行下一次循环也就是网络请求失败后的重试，这个时候request并没有改变，所以ExchangeFinder不用改变，newExchangeFinder = false
(2) 请求成功后response，检查该response的状态码，若状态码为3 * *（比如301)，会根据response新建一个request（代码中的followUp），随后进行下一次循环也就是执行重定向请求，而由于此时request已经不再是上一次请求的request，所以ExchangeFinder也应该重建，newExchangeFinder = true
调用拦截器链获取response
(1) 若出现异常（路由选择异常或连接服务器异常 --- > 进入下一次循环进行网络请求失败后的重试

(2) 若成功获取到response，检查response的状态码

【1】若response的状态码为3 * * ，表明需要进行重定向操作，此时会根据response生成新的request然后进入下一个循环开始执行重定向请求

【2】否则不需要重定向，return response。
流程图如下

2.BridgeInterceptor - 桥接向拦截器

1）intercept方法分析

@Throws(IOException::class)
override fun intercept(chain: Interceptor.Chain): Response {
  val userRequest = chain.request()
  val requestBuilder = userRequest.newBuilder()

  val body = userRequest.body
  if (body != null) {
    val contentType = body.contentType()
    if (contentType != null) {
      // 向头部添加Content-Type , 该字段用于让接收方知道传输实体类型（json ，text，html等）
      requestBuilder.header("Content-Type", contentType.toString())
    }

    val contentLength = body.contentLength()
    if (contentLength != -1L) {
      // contentLength不为null表示实体类大小确定
      requestBuilder.header("Content-Length", contentLength.toString())
      // 这个时候无需进行传输编码（一般都是Transfer-Encoding:chunked ---- 分块传输），所以移除Transfer-Encoding字段
      requestBuilder.removeHeader("Transfer-Encoding")
    } else {
      // 如果contentLength == -1L，表示传输实体大小不确定，这个时候采用分块传输策略
      requestBuilder.header("Transfer-Encoding", "chunked")
      // 移除头部Content-Length字段
      requestBuilder.removeHeader("Content-Length")
    }
  }

  if (userRequest.header("Host") == null) {
    // 添加头部Host字段
    requestBuilder.header("Host", userRequest.url.toHostHeader())
  }

  if (userRequest.header("Connection") == null) {
    // 默认该连接是一个持久连接
    requestBuilder.header("Connection", "Keep-Alive")
  }

  var transparentGzip = false
  // Accept-Encoding 通过该头部字段告诉接收方，发送方支持的内容编码类型（比如gzip）
  // Rang
  if (userRequest.header("Accept-Encoding ") == null && userRequest.header("Range") == null) {
    // 将该标志位置为true，表示可能进行gzip压缩
    transparentGzip = true
    // 向头部添加 Accept-Encoding:gzip 告诉接收请求方，发送方支持gzip压缩，所以收到的response中的body可能进行过gzip压缩
    requestBuilder.header("Accept-Encoding", "gzip")
  }

  
  val cookies = cookieJar.loadForRequest(userRequest.url)
  if (cookies.isNotEmpty()) {
    requestBuilder.header("Cookie", cookieHeader(cookies))
  }

  if (userRequest.header("User-Agent") == null) {
    // 如果header的User-Agent字段为空，则添加默认的User-Agent
    // 默认的User-Agent，也就是userAgent
    // const val userAgent = "okhttp/${OkHttp.VERSION}"
    requestBuilder.header("User-Agent", userAgent)
  }
  
  // 调用拦截器链获取
  val networkResponse = chain.proceed(requestBuilder.build())

  cookieJar.receiveHeaders(userRequest.url, networkResponse.headers)

  val responseBuilder = networkResponse.newBuilder()
      .request(userRequest)

  // 如果transparentGzip标志位为true，并且收到的response头的Content-Encoding字段的值为gzip，这时表明收到的response的body经过gzip压缩，需要进行gzip解压
  if (transparentGzip && "gzip".equals(networkResponse.header("Content-Encoding"), ignoreCase = true) && networkResponse.promisesBody()) {
    // 获取response的body
    val responseBody = networkResponse.body
    if (responseBody != null) {
      // 对获取到的资源进行gzip解压
      val gzipSource = GzipSource(responseBody.source())
      // 解压完后，response头部不再需要Content-Encoding和Content-Length字段
      val strippedHeaders = networkResponse.headers.newBuilder()
          .removeAll("Content-Encoding")
          .removeAll("Content-Length")
          .build()
      responseBuilder.headers(strippedHeaders)
      // 根据Content-Type字段以及gzipSource生成response的body
      val contentType = networkResponse.header("Content-Type")
      responseBuilder.body(RealResponseBody(contentType, -1L, gzipSource.buffer()))
    }
  }

  return responseBuilder.build()
}

桥接拦截器的工作流程如下：
1.为request添加头部字段
2.调用拦截器链获取response
3.判断response的传输数据是否进行gzip压缩，有则解压，然后根据response头的Content-Type字段生成相应类型的Body

3.cacheInterceptor - 缓存拦截器

1）intercept方法分析

override fun intercept(chain: Interceptor.Chain): Response {
  val call = chain.call()
  // 寻找当前请求的url是否有缓存对应的response
  // chache是否为null也就是是否设置 OkHttpClient.Builder().cache()
  // 这也说明了okHttp的网络请求缓存是要手动开启的
  val cacheCandidate = cache?.get(chain.request())

  val now = System.currentTimeMillis()

  // 构建缓存策略，构建过程中会根据情况修改request的请求头
  val strategy = CacheStrategy.Factory(now, chain.request(), cacheCandidate).compute()
  // 修改后的Request
  val networkRequest = strategy.networkRequest
  val cacheResponse = strategy.cacheResponse
  
  // 记录缓存命中次数
  cache?.trackResponse(strategy)
    
  val listener = (call as? RealCall)?.eventListener ?: EventListener.NONE

  if (cacheCandidate != null && cacheResponse == null) {
    // The cache candidate wasn't applicable. Close it.
    cacheCandidate.body?.closeQuietly()
  }

  // 这里networkRequest == null 有以下两种情况
  // 1.强制拒绝网络连接(此时networkRequest == null)而只使用缓存获取响应
  // 2.有缓存，并且缓存没有过期，无需进行网络请求
  
  // 只有第一种情况会进入到该if语句中
  // 强制拒绝网络连接(此时networkRequest == null)而只使用缓存获取响应，如果此时缓存响应cacheResponse 也为 null ，那么返回一个请求失败的response，code为504
  if (networkRequest == null && cacheResponse == null) {
    return Response.Builder()
        .request(chain.request())
        .protocol(Protocol.HTTP_1_1)
        .code(HTTP_GATEWAY_TIMEOUT)
        .message("Unsatisfiable Request (only-if-cached)")
        .body(EMPTY_RESPONSE)
        .sentRequestAtMillis(-1L)
        .receivedResponseAtMillis(System.currentTimeMillis())
        .build().also {
          listener.satisfactionFailure(call, it)
        }
  }

  // 上面提到的networkRequest == null的两种情况，
  // 第二种情况必定进入到该if语句中
  // 第一种情况如果能跳过上面的if语句，也就是cacheResponse != null，也会进入该if语句中
  
  // 这里说明在找到缓存，并且该缓存没有过期，无需发送网络请求，直接返回缓存的response
  if (networkRequest == null) {
    return cacheResponse!!.newBuilder()
        .cacheResponse(stripBody(cacheResponse))
        .build().also {
          listener.cacheHit(call, it)
        }
  }

  
  if (cacheResponse != null) {
    listener.cacheConditionalHit(call, cacheResponse)
  } else if (cache != null) {
    listener.cacheMiss(call)
  }


  var networkResponse: Response? = null
  try {
    // 将请求交给拦截器链的下一个拦截器处理
    networkResponse = chain.proceed(networkRequest)
  } finally {
    if (networkResponse == null && cacheCandidate != null) {
      cacheCandidate.body?.closeQuietly()
    }
  }

  // 走到这说明，有缓存，然而缓存的有效期过了。
  // 所以发送请求给服务器请求新的资源并对响应的结果做分析
  if (cacheResponse != null) {
    // 服务器返回304说明资源没有修改过，也就是客户端的缓存仍然有效，但是需要修改一下缓存的有效期等
    if (networkResponse?.code == HTTP_NOT_MODIFIED) {
      val response = cacheResponse.newBuilder()
          .headers(combine(cacheResponse.headers, networkResponse.headers))
          .sentRequestAtMillis(networkResponse.sentRequestAtMillis)
          .receivedResponseAtMillis(networkResponse.receivedResponseAtMillis)
          .cacheResponse(stripBody(cacheResponse))
          .networkResponse(stripBody(networkResponse))
          .build()

      networkResponse.body!!.close()

      cache!!.trackConditionalCacheHit()
        
      // 这里更新缓存的时候不会更实体的内容，只会更新之前缓存响应头的内容，比如过期时间等等
      cache.update(cacheResponse, response)
      // 返回响应
      return response.also {
        listener.cacheHit(call, it)
      }
    } else {
      cacheResponse.body?.closeQuietly()
    }
  }

  // 获取和服务器协商缓存的结果
  val response = networkResponse!!.newBuilder()
      .cacheResponse(stripBody(cacheResponse))
      .networkResponse(stripBody(networkResponse))
      .build()

  // 判断是否设置cache，如果在OkHttpClient创建的时候没有设置cache，那么它将为null
  // 也就是是否设置 OkHttpClient.Builder().cache()
  if (cache != null) {
    if (response.promisesBody() && CacheStrategy.isCacheable(response, networkRequest)) {
      // 更新缓存并返回
      val cacheRequest = cache.put(response)
      return cacheWritingResponse(cacheRequest, response).also {
        if (cacheResponse != null) {
          // This will log a conditional cache miss only.
          listener.cacheMiss(call)
        }
      }
    }

    // 这里判断一下请求的方法，如果不是Get请求，那么这将是一个无效的缓存，需要移除
    if (HttpMethod.invalidatesCache(networkRequest.method)) {
      try {
        cache.remove(networkRequest)
      } catch (_: IOException) {
        // The cache cannot be written.
      }
    }
  }
 
  // 未手动开启cache，直接返回response
  return response
}

梳理一下缓存拦截器的流程
要想让缓存拦截器发挥作用，需要手动开启缓存，也就是设置 OkHttpClient.Builder().cache()。
所以这里我们假设已经开启缓存，那么缓存拦截器的工作流程如下：

去缓存中寻找request对于的缓存响应cacheResponse
构建缓存策略,并获取到策略对象的networkRequest和cacheResponse属性，networkRequest是根据缓存策略修改原来request的结果
如果networkRequest == null，表示不需要进行网络请求。
这里 networkRequest == null 有两种情况：

（1）强制拒绝网络连接，需要手动设置 Request.Builder().cacheControl(CacheControl.FORCE_CACHE)，此时无论如何不会发出网络请求，而只会去寻找缓存

【1】找到有效缓存，返回缓存

【2】未找到有效缓存，返回code为504的Response，表示请求失败

（2）存在原来的request对于的缓存，并且缓存未失效。无需进行网络请求直接返回缓存
若 networkRequest != null，说明需要进行网络请求，则将networkRequest交给拦截器链进行网络请求，知道获取响应networkResponse
判断cacheResponse是否为null

（1）若cacheResponse != null，说明有缓存，但是缓存过期，并重新向服务器请求。
【1】如果networkResponse的code为304，说明请求的资源未发生改变，可以直接返回缓存响应cacheResponse，然后更新一下对应缓存的过期事件等头字段即可，无需更新实体内容

【2】否则，更新缓存,包括实体内容

（2）若cacheResponse == null，说明没有缓存，那么根据服务器返回的响应头字段(Cache-Control不为no-store就是需要缓存)，判断需不需要缓存。

【1】需要缓存，如果用户手动开启了okHttp的cache并且该请求能缓存，那么将响应缓存然后返回，否则不缓存直接返回响应。

【2】如果不需要缓存，直接返回响应。
流程图如下：

我们接下来看看缓存策略对象

2）CacheStrategy.Factory.init

init {
  if (cacheResponse != null) {
    this.sentRequestMillis = cacheResponse.sentRequestAtMillis
    this.receivedResponseMillis = cacheResponse.receivedResponseAtMillis
    val headers = cacheResponse.headers
    for (i in 0 until headers.size) {
      val fieldName = headers.name(i)
      val value = headers.value(i)
      when {
        // equals 中 ignore = true 表示比较的时候忽略大小写
        //记录Date头字段
        fieldName.equals("Date", ignoreCase = true) -> {
          servedDate = value.toHttpDateOrNull()
          servedDateString = value
        }
        // 记录Expires头字段
        fieldName.equals("Expires", ignoreCase = true) -> {
          expires = value.toHttpDateOrNull()
        }
        // 记录Last-Modified头字段
        fieldName.equals("Last-Modified", ignoreCase = true) -> {
          lastModified = value.toHttpDateOrNull()
          lastModifiedString = value
        }
        // 记录ETag头字段
        fieldName.equals("ETag", ignoreCase = true) -> {
          etag = value
        }
        // 记录Age头字段
        fieldName.equals("Age", ignoreCase = true) -> {
          ageSeconds = value.toNonNegativeInt(-1)
        }
      }
    }
  }
}

CacheStrategy缓存策略对象通过Factory构造实例，
Factory的init中记录了cacheResponse响应头各个头字段的值

3）CacheStrategy.Factory.compute()

fun compute(): CacheStrategy {
  // 构建缓存策略对象
  val candidate = computeCandidate()

  // 如果用户设置了强制拒绝网络连接(request.cacheControl.onlyIfCached),且	   candidate.networkRequest != null
  // 这里解释一下，在调用computeCandidate函数之后如果candidate.networkRequest != null表示，没有找到对应的有效缓存(缓存可能已经过期，也可能压根就没有)
    
  //所以该if语句就是说，在用户强制拒绝网络连接的条件下，又找不到有效的缓存，那么返回的CacheStrategy对象的networkRequest和cacheResponse属性都为null
  if (candidate.networkRequest != null && request.cacheControl.onlyIfCached) {
    return CacheStrategy(null, null)
  }

  return candidate
}

最后来看一下CacheStrategy.Factory.computeCandidate()方法

4）CacheStrategy.Factory.computeCandidate()

private fun computeCandidate(): CacheStrategy {
  // 若没有对应的缓存，则返回的缓存策略对象中的cacheResponse属性为null
  if (cacheResponse == null) {
    return CacheStrategy(request, null)
  }

  // 或者是该请求为https请求，且对应的缓存还未进行过TLS四次握手(说明是无效缓存)，则返回的缓存策略对象中的cacheResponse属性为null
  if (request.isHttps && cacheResponse.handshake == null) {
    return CacheStrategy(request, null)
  }

  // 如果不满足缓存条件，则返回的缓存策略对象中的cacheResponse属性为null
  if (!isCacheable(cacheResponse, request)) {
    return CacheStrategy(request, null)
  }

  val requestCaching = request.cacheControl
  // 如果cacheControl的noCache字段为true，对应请求头带有cache-control:no-cache字段
  // 如果请求头带有cache-control:no-cache字段，则表示强制跳过缓存直接向服务器请求
  // 则返回的缓存策略对象中的networkRequest不为null ， cacheResponse属性为null
  if (requestCaching.noCache || hasConditions(request)) {
    return CacheStrategy(request, null)
  }

  // 计算几个用于验证缓存是否过期的变量
  val responseCaching = cacheResponse.cacheControl

  // 这个可以看成是 从接收缓存响应开始到现在所经历的时间
  val ageMillis = cacheResponseAge()
    
  // 计算出缓存的总新鲜度，有效时长（和到期日期区分开）
  var freshMillis = computeFreshnessLifetime()

  if (requestCaching.maxAgeSeconds != -1) {
    freshMillis = minOf(freshMillis, SECONDS.toMillis(requestCaching.maxAgeSeconds.toLong()))
  }

  // 计算出允许缓存的最小剩余新鲜度
  var minFreshMillis: Long = 0
  if (requestCaching.minFreshSeconds != -1) {
    minFreshMillis = SECONDS.toMillis(requestCaching.minFreshSeconds.toLong())
  }

  // 允许的最大过期时间，如果过期时间小于maxStaleMillis，则视为缓存仍然有效
  var maxStaleMillis: Long = 0
  if (!responseCaching.mustRevalidate && requestCaching.maxStaleSeconds != -1) {
    maxStaleMillis = SECONDS.toMillis(requestCaching.maxStaleSeconds.toLong())
  }
  
  // 如果响应头的cache-control字段的值不为no-cache，并且缓存还在有效期内，说明缓存没有过期
  if (!responseCaching.noCache && ageMillis + minFreshMillis < freshMillis + maxStaleMillis) {
    val builder = cacheResponse.newBuilder()
    if (ageMillis + minFreshMillis >= freshMillis) {
      builder.addHeader("Warning", "110 HttpURLConnection \"Response is stale\"")
    }
    val oneDayMillis = 24 * 60 * 60 * 1000L
    if (ageMillis > oneDayMillis && isFreshnessLifetimeHeuristic()) {
      builder.addHeader("Warning", "113 HttpURLConnection \"Heuristic expiration\"")
    }
    //返回一个networkRequesR属性为null的CacheStrategy对象表明缓存未生效，无需进行网络请求
    return CacheStrategy(null, builder.build())
  }

  // 走到这里说明找到了request对应的缓存，但是缓存过期了，需要向服务器重新发送请求，这种请求的需要包含一些特定的头字段
  val conditionName: String
  val conditionValue: String?
  when {
    etag != null -> {
      conditionName = "If-None-Match"
      conditionValue = etag
    }

    lastModified != null -> {
      conditionName = "If-Modified-Since"
      conditionValue = lastModifiedString
    }

    servedDate != null -> {
      conditionName = "If-Modified-Since"
      conditionValue = servedDateString
    }

    else -> return CacheStrategy(request, null)
  }

  val conditionalRequestHeaders = request.headers.newBuilder()
  conditionalRequestHeaders.addLenient(conditionName, conditionValue!!)

  val conditionalRequest = request.newBuilder()
      .headers(conditionalRequestHeaders.build())
      .build()
  // 返回经过处理的缓存request
  return CacheStrategy(conditionalRequest, cacheResponse)
}

该方法会根据Http请求头字段和Response响应头字段返回一个缓存策略对象，也就是CacheStrategy
如果CacheStrategy的构造方法中，第一个参数为networkRequest，第二个参数为cacheResponse
networkRequest传入null表示不需要使用网络连接，如果cacheResponse传入null表示缓存不可用(没有缓存或者缓存过期)

梳理一下该方法的流程

判断是否有缓存，若没有直接 return CacheStrategy(request, null)(第一个参数不为null，第二个参数为null)，表示没有可用的缓存，需要进行网络请求
若协议为Https，需要判断对应的缓存是否已经和服务器进行过TLS四次握手，若没有则这是一个无效缓存直接return(CacheStrategy(request, null)
判断是否可以使用缓存，主要通过判断请求头和响应头的cache-control的值是否为no-store，若其中一个满足该条件，则视为不可缓存
判断请求头中是否带有cache-control:no-cache字段，如果有表示客户端想要强制跳过缓存直接向服务器发起请求。所以直接返回return CacheStrategy(request, null)（另外，如果这个字段出现在响应头：表示服务器允许客户端缓存，但是每次使用缓存前都需要向服务器询问缓存是否过期并得到响应以后才能读取缓存）
计算几个用于判断缓存是否过期的值
1. 缓存的年龄，可以看成从缓存响应报文生成到现在 ( 现在可以看成是发出request的时间 ) 所经过的时间。
2. 缓存的总新鲜度，也就是缓存的最大时长
3. 当前请求中允许的缓存最小剩余新鲜度，剩余新鲜度表示缓存还有多久到期
4. 当前请求允许的最大过期时间，也就是发起请求的客户端允许返回过期，并且过期时间不超过最大过期时间的缓存
通过是否满足 缓存的年龄 + 当前请求中允许的缓存最小剩余新鲜度 > 缓存的总新鲜度 + 当前请求允许的最大过期时间 来判断缓存是否过期，如果满足则缓存过期，不满足缓存可用（这里确实比较不好理解）

（1）如果缓存未过期，那么直接 return CacheStrategy(null ， cacheResponse)表示无需进行网络请求，直接访问缓存即可

（2）如果缓存已过期，那么需要修改请求头（为了和服务器进行缓存协商），然后直接
return CacheStrategy(request,cacheResponse)，这里第一个参数networkRequest不为null很好理解，就是缓存过期，必须请求服务器，而第二个参数cacheResponse不为null是因为，该缓存虽然过期了，但是缓存对应服务器上的资源不一定会发生改变，此时询问服务器，若服务器返回304，则表示缓存对应服务器上的资源并未改变，可以继续使用，这就又省去一次数据的传输了。

4.ConnectInterceptor

在okHttp拦截器责任链中，ConnectInterceptor是责任链中的第四个拦截器。它属于网络层拦截器，所以我们主要看一下它的Interceptor方法

1）intercept方法分析

object ConnectInterceptor : Interceptor {
  @Throws(IOException::class)
  override fun intercept(chain: Interceptor.Chain): Response {
    // 获取拦截器链
    val realChain = chain as RealInterceptorChain
    // 获取exchange对象
    val exchange = realChain.call.initExchange(chain)
    // 复制拦截器链，并且设置exchange
    val connectedChain = realChain.copy(exchange = exchange)
    // 传递责任给下一个拦截器也就是CallServerInterceptor
    return connectedChain.proceed(realChain.request)
  }
}

exchagne(Exchange)，它用于向一次连接的套接字缓冲区中读写数据，也就是和目标服务器进行数据交换。
应用拦截器中Exchange属性为是null,因为它们不需要和目标服务器进行数据交流。
网络拦截器的Exchange不能为null，因为它们负责目标服务器进行数据交流。

所以前面的三个拦截器RetryAndFollowUpInterceptor，BridgeInterceptor，CacheInterceptor都属于应用拦截器，所以它们的exchange属性为null，在传递责任链的时候就不会传递exchange对象。
而拦截器责任链中从ConnectInterceptor以后的拦截器都属于网络拦截器，所以它们必须拥有一个exchange对象，exchange也是在ConnectInterceptor拦截器中创建

结合val exchange = realChain.call.initExchange(chain)，我们来看看exchage是如何创建的

2）RealCallback.initExchange

internal fun initExchange(chain: RealInterceptorChain): Exchange {
    synchronized(this) {
      check(expectMoreExchanges) { "released" }
      check(!responseBodyOpen)
      check(!requestBodyOpen)
    }
    // 这个exchangeFinder就是在重定向拦截器中创建的那个
    val exchangeFinder = this.exchangeFinder!!
    // codec是一个ExchangeCodec,它是Exchange中真正负责和目标服务器进行数据交流的对象
    val codec = exchangeFinder.find(client, chain)
    // 创建Exchange，并将codec作为参数传入，Exchange会持有一个ExchangeCodec对象
    val result = Exchange(this, eventListener, exchangeFinder, codec)
    this.interceptorScopedExchange = result
    this.exchange = result
    synchronized(this) {
      this.requestBodyOpen = true
      this.responseBodyOpen = true
    }

    if (canceled) throw IOException("Canceled")
    // 返回result，也就是Exchange对象
    return result
  }

这里除了注释，我们重点关注一下这两行代码:

val codec = exchangeFinder.find(client, chain)这行代码，codec是一个ExchangeCodec对象，它是真正负责与目标服务器进行数据交流(向套接字缓冲区中读写数据)的对象
val result = Exchange(this, eventListener, exchangeFinder, codec)而这行代码创建了一个Exchange对象，并把ExchangeCodec实例codec作为参数传入，所以Exchange在创建完之后会持有一个ExchangeCodec，并将于目标服务器进行数据通讯(向套接字缓冲区读写数据)的任务交给它

这里的重点是val codec = exchangeFinder.find(client, chain)如何通过exchangeFinder的find方法找到一个codec对象，我们来看看ExchangeFinder.find方法

3）ExchangeFInder.find

fun find(
  client: OkHttpClient,
  chain: RealInterceptorChain
): ExchangeCodec {
  try {
    //寻找到一个健康的连接也就是健康的RealConnection对象
    val resultConnection = findHealthyConnection(
        connectTimeout = chain.connectTimeoutMillis,
        readTimeout = chain.readTimeoutMillis,
        writeTimeout = chain.writeTimeoutMillis,
        pingIntervalMillis = client.pingIntervalMillis,
        connectionRetryEnabled = client.retryOnConnectionFailure,
        doExtensiveHealthChecks = chain.request.method != "GET"
    )
    // 调用寻找的RealConnection对象的newCodec方法创建一个ExchangeCodec对象
    return resultConnection.newCodec(client, chain)
  } catch (e: RouteException) {
    trackFailure(e.lastConnectException)
    throw e
  } catch (e: IOException) {
    trackFailure(e)
    throw RouteException(e)
  }
}

RealConnection类对象对应一个于目标服务器的套接字连接，也就是对应一个Request，在同一个时间上，同一个RealConnection对应一个Request，但RealConnection可以复用，所以在不同时间上，同一个RealConnection可以对应不同的Request

该方法的核心就是通过findHealthyConnection找到一个健康的RealConnection对象，然后通过RealConnection对象的newCodec方法创建出一个ExchangeCoedec对象

我们来看看ExchangeFInder.findHealthyConnection

4）ExchangeFInder.findHealthyConnection

private fun findHealthyConnection(
  connectTimeout: Int,
  readTimeout: Int,
  writeTimeout: Int,
  pingIntervalMillis: Int,
  connectionRetryEnabled: Boolean,
  doExtensiveHealthChecks: Boolean
): RealConnection {
  // 一个死循环
  while (true) {
    // 通过findCConnection方法获取到一个RealConnection
    val candidate = findConnection(
        connectTimeout = connectTimeout,
        readTimeout = readTimeout,
        writeTimeout = writeTimeout,
        pingIntervalMillis = pingIntervalMillis,
        connectionRetryEnabled = connectionRetryEnabled
    )

    // 判断该连接是否健康，如果健康直接返回
    if (candidate.isHealthy(doExtensiveHealthChecks)) {
      return candidate
    }

    // 如果连接不健康，它将会从连接池中被移除
    candidate.noNewExchanges()
 
    // 如果还有下一个路由，那么循环继续
    if (nextRouteToTry != null) continue
  
    // 如果还有下一组路由，那么循环继续
    val routesLeft = routeSelection?.hasNext() ?: true
    if (routesLeft) continue
    
    // 如果还有下一个路由选择器，那么循环继续
    val routesSelectionLeft = routeSelector?.hasNext() ?: true
    if (routesSelectionLeft) continue

    // 若果走到这，说明已经遍历完所有的路由，而且没找到可用的连接，那么将抛出异常
    throw IOException("exhausted all routes")
  }
}

5）ExchangeFInder.findConnection

@Throws(IOException::class)
  private fun findConnection(
    connectTimeout: Int,
    readTimeout: Int,
    writeTimeout: Int,
    pingIntervalMillis: Int,
    connectionRetryEnabled: Boolean
  ): RealConnection {
    if (call.isCanceled()) throw IOException("Canceled")

    // 1. 尝试重用RealCall中的RealConnection对象，
    val callConnection = call.connection 
    if (callConnection != null) {
      var toClose: Socket? = null
      synchronized(callConnection) {
         // 1.1 如果noNewExchanges为true（表示连接以及关闭），或者主机名和端口不匹配，那么将关闭该该连接的套接字。这里先将该连接套接字对象赋值给toClose变量
        if (callConnection.noNewExchanges || !sameHostAndPort(callConnection.route().address.url)) {
          toClose = call.releaseConnectionNoEvents()
        }
      }

      // 1.2 toClose为null表示该call的连接仍可进行复用，直接return
      if (call.connection != null) {
        check(toClose == null)
        return callConnection
      }

      // 1.3 如果toClose不会null，表示该连接不合适，那么将关闭该连接的套接字
      toClose?.closeQuietly()
      eventLi stener.connectionReleased(call, callConnection)
    }

    
    // 2. 这个时候需要为call设置一个新的连接
    
    // 2.1 先将部分变量初始化
    refusedStreamCount = 0
    connectionShutdownCount = 0
    otherFailureCount = 0

    // 2.2 尝试从连接池中找寻一个合适的连接，这个时候address还未进行dns解析，所以第三个参数routes传入null（也就是第三个参数其实是address通过解析得到的routes）
    if (connectionPool.callAcquirePooledConnection(address, call, null, false)) {
      // callAcquirePooledConnection方法如果返回true，那么call的connection属性将会指向从连接池中找到的connection
      val result = call.connection!!
      eventListener.connectionAcquired(call, result)
      return result
    }

    // 2.3 如果在连接池中没有找到合适的连接，那么就找寻和一个合适的路由创建一个新的连接
    val routes: List<Route>?
    val route: Route
    if (nextRouteToTry != null) {
      // Use a route from a preceding coalesced connection.
      routes = null
      route = nextRouteToTry!!
      nextRouteToTry = null
    } else if (routeSelection != null && routeSelection!!.hasNext()) {
      // Use a route from an existing route selection.
      routes = null
      route = routeSelection!!.next()
    } else {
      // Compute a new route selection. This is a blocking operation!
      var localRouteSelector = routeSelector
      if (localRouteSelector == null) {
        localRouteSelector = RouteSelector(address, call.client.routeDatabase, call, eventListener)
        this.routeSelector = localRouteSelector
      }
      val localRouteSelection = localRouteSelector.next()
      routeSelection = localRouteSelection
      routes = localRouteSelection.routes

      if (call.isCanceled()) throw IOException("Canceled")

      
      // 对address进行域名解析得到routes，再去连接池中查找是否有合适的连接可以使用，这个时候第三个参数传入routes
      if (connectionPool.callAcquirePooledConnection(address, call, routes, false))           			{
        val result = call.connection!!
        eventListener.connectionAcquired(call, result)
         // 找到了直接返回该连接
        return result
      }
      
      // 没找到的话就从RouteSelection的Routes列表中拿一个route
      route = localRouteSelection.next()
    }

    // 根据上面获取到的route创建一个新的连接
    val newConnection = RealConnection(connectionPool, route)
    call.connectionToCancel = newConnection
    try {
      // 调用新连接的connect方法连接服务器，这里进行了TCP + TLS握手，该操作会是个阻塞操作
      newConnection.connect(
          connectTimeout,
          readTimeout,
          writeTimeout,
          pingIntervalMillis,
          connectionRetryEnabled,
          call,
          eventListener
      )
    } finally {
      call.connectionToCancel = null
    }
    call.client.routeDatabase.connected(newConnection.route())

    // 第三次从连接池中查找，newConnection.connect会阻塞一段时间，在这段时间可能其它的请求可能会创建正好适合当前请求的连接并加入到了连接池，因为Http2协议是支持多路复用的，即一个连接执行多个请求，若能从第三次查找中找到合适的连接，那么可以关闭之前刚刚创建的连接
    if (connectionPool.callAcquirePooledConnection(address, call, routes, true)) {
      val result = call.connection!!
      nextRouteToTry = route
      newConnection.socket().closeQuietly()
      eventListener.connectionAcquired(call, result)
      return result
    }

    synchronized(newConnection) {
      // 将新建的连接放入连接池
      connectionPool.put(newConnection)
      // 将call加入新建的连接池
      call.acquireConnectionNoEvents(newConnection)
    }

    eventListener.connectionAcquired(call, newConnection)
    return newConnection
  }

我们先重点关注一下connectionPool.callAcquirePooledConnection(address, call, null, false)，这里的connection是一个RealConnectionPool实例

【1】RealConnectionPool.callAcquirePooledConnection

fun callAcquirePooledConnection(
  address: Address,
  call: RealCall,
  routes: List<Route>?,
  requireMultiplexed: Boolean
): Boolean {
  // 遍历连接池中的连接
  for (connection in connections) {
    synchronized(connection) {
      // 是否进行多路复用操作
      if (requireMultiplexed && !connection.isMultiplexed) return@synchronized
      // 根据address和routes找到合适的连接
      if (!connection.isEligible(address, routes)) return@synchronized
      call.acquireConnectionNoEvents(connection)
      return true
    }
  }
  return false
}

return@synchronized 在这里可以看成是跳出synchronized闭包，相当于一次continue

在第一个判断语句if (requireMultiplexed && !connection.isMultiplexed)中，
requireMultiplexed是外部传入的参数，表示使用者想获取一个能够进行多路复用的连接RealConnection对象，
1.如果该连接是Http2连接，connection.isMultiplexed的值一定是true，所以无论如何都可以通过该if语句
2.如果该连接是Http1连接，那么connection.isMultiplexed的值一定是false，这时候requireMultiplexed的值为false才可以通过该语句，也就是Http1无法实现连接的复用。

第二个判断语句中if (!connection.isEligible(address, routes))
主要是判断该连接是否适合address 以及address通过dns解析出的routes，如果不适合那么将跳出该次循环
来看看RealConnection.isEligible()方法

「1」RealConnection.isEligible

internal fun isEligible(address: Address, routes: List<Route>r): Boolean {
  assertThreadHoldsLock()

  // 当该连接的calls队列数量到达最大值 或者 noNewExchanges为true(为true表示该连接已经关闭)时，return false 表示该连接不是合适的连接
  if (calls.size >= allocationLimit || noNewExchanges) return false

  // 当该连接的route（一个连接会有一个route）的address.url的非主机字段 和 参数中的address不一样，返回false表示该连接不是合适的连接
  if (!this.route.address.equalsNonHost(address)) return false

  // 如果参数中的adderss.url主机字段 和 route中的address.url主机字段相同，那么这是一个很完美的连接，所以return true
  if (address.url.host == this.route().address.url.host) {
    return true 
  }

 
  //代码执行到这，说明非主机字段相同，但是主机字段不相同，这个时候若连接合并后满足要求，这仍然是一个合适的连接。下面的代码是针对Https(Http版本为2.0)请求的，不满足这个条件可以直接视为reutrn 

  // 1. 首先该连接需要是http2连接，如果Https使用了Http2，那么对于每一个使用Http2的源，会有一个对应的服务器证书，其中包含名称(主机名)列表或者主机名通配符(比如"*.example.com")，这些符合条件的主机名都会具有权威性，服务器会对这些主机名做出响应
  if (http2Connection == null) return false

  // 2. routes(参数address通过DNS解析得到的route列表）中的任意一个route能够匹配该connection的route，那么进行下一步认证。否则说明该connection不适合该address，直接返回false
  if (routes == null || !routeMatchesAny(routes)) return false

  // 3. 若上一步在routes中找到匹配的route，说明该connection适合该address，但是需要对该address进行证书认证
  if (address.hostnameVerifier !== OkHostnameVerifier) return false
  if (!supportsUrl(address.url)) return false

  // 4. 证书锁定必须匹配该主机
  try {
    address.certificatePinner!!.check(address.url.host, handshake()!!.peerCertificates)
  } catch (_: SSLPeerUnverifiedException) {
    return false
  }
  
  // 该连接能够执行该call
  return true
}

该方法用于判断RealConnection是否适合用于参数中的address。而传入的routes是address经过DNS解析后得到的route列表。
结合注释总结一下该方法的流程：

判断该连接执行的call数量是否达到最大值，或者该连接是否已经关闭，满足任意一个条件都说明该连接不可用
比较 该连接的route属性的route.address的url 和 参数中的adderss 的url ，判断这两个url的非主机字段是否相同，不相同说明该连接不适合用于参数中的address
如果两个url非主机部分相同，比较两个url的主机字段
（1）相同，那这是一个很完美的连接,返回true

（2）不相同
「1」如果不是 Http版本号为2的Http2，那么该连接不适合参数中的address

「2」如果是Https并且Http版本号为2，那么遍历参数routes(由address经过DNS解析得到的route列表)
<1> 若能从routes中找到与连接的route相匹配的route，那么再通过证书比较后即说明该连接适用
<2> 若不能，说明该连接不适用于参数中的address

最后就是call.acquireConnectionNoEvents(connection)我们可以先来看看它的源码

「2」RealCall.acquireConnectionNoEvents

fun acquireConnectionNoEvents(connection: RealConnection) {
  connection.assertThreadHoldsLock()
    
  check(this.connection == null)
  // 将RealCall的connection属性设置成即将加入的connection对象，表示RealCall位于这个connection中
  this.connection = connection
  // 将RealCall(this)加入Connection的calls队列中
  connection.calls.add(CallReference(this, callStackTrace))
}

总的来说就是将call加入connection的calls队列当中，并且call会持有该connection的一个引用，表示该call位于该connection当中

「3」整体流程

遍历连接池中的连接，逐个判断：

该连接是否进行多路复用操作（一个连接执行多个请求，只有Http2版本才行），以及该连接是否支持多路复用操作。
该连接是否适合该地址
如果该连接适合该地址，将该地址加入连接的calls列表当中

回到ExchangeFInder.find()方法当中看看这行代码：val localRouteSelection = localRouteSelector.next()，它是在没找到合适的route的时候，创建了一个新的RouterSelector，然后调用 RouterSelector.next()方法获取到一个RouterSelection对象，RouteSelection会只有一个Routes，也就是Route列表。可以看一下RouteSelection.next()中的逻辑

【2】RouteSelector.next

java@Throws(IOException::class)
operator fun next(): Selection {
  if (!hasNext()) throw NoSuchElementException()
  //  新建一个Route列表
  val routes = mutableListOf<Route>()
  //  这里就是遍历RouteSelector的proxies属性，这是一个Proxy列表  
  while (hasNextProxy()) {
    // 获取到下一个Proxy，这里同时也会找到下一组inetSocketAddresses
    val proxy = nextProxy()
    // 遍历inetSocketAddresses，创建出相应的route并加入routes中
    for (inetSocketAddress in inetSocketAddresses) {
      val route = Route(address, proxy, inetSocketAddress)
      if (routeDatabase.shouldPostpone(route)) {
        postponedRoutes += route
      } else {
        routes += route
      }
    }
    // 如果routes列表不为空，跳出while循环
    if (routes.isNotEmpty()) {
      break
    }
  }
  // 这里体现了先使用能用的routes，在尝试失败的route ？？？？？？？？？？？？？？？？？？待完善？
  if (routes.isEmpty()) {
    routes += postponedRoutes
    postponedRoutes.clear()
  }
  
  // 用routes列表构建出新的RouteSelection对象并返回
  return Selection(routes)
}

1.遍历Proxies列表，得到每一个Proxy 以及 Proxy对应的inetSocketAddresses(inetSocketAddress列表)
2.遍历inetSocketAddresses列表，为inetSocketAddresses中的每一个inetSocketAddress创建一个route，并加入routes中

这里比较核心的是 val proxy = nextProxy() 这句代码不仅会获得下一个proxy，也会将该proxy对应的一组inetSocketAddress保存到属性inetSocketAddresses中

「1」RouteSelector.nextProxy()方法

private fun nextProxy(): Proxy {
  if (!hasNextProxy()) {
    throw SocketException(
        "No route to ${address.url.host}; exhausted proxy configurations: $proxies")
  }
  // 获取到下一个Proxy，并且将 nextProxyIndex + 1，nextProxyIndex是RouteSelector的属性，用于记录当前使用的是proxies中的哪一个proxy
  val result = proxies[nextProxyIndex++]
  // 重置下一组InetSocketAddress，这会直接改变RouteSelector的InetSocketAddress属性
  resetNextInetSocketAddress(result)
  return result
}

该方法调用了resetNextInetSocketAddress(result)，

「2」RouteSelector.resetNextInetSocketAddress

@Throws(IOException::class)
private fun resetNextInetSocketAddress(proxy: Proxy) {
  // 新建一个InetSocketAddress列表
  val mutableInetSocketAddresses = mutableListOf<InetSocketAddress>()
  inetSocketAddresses = mutableInetSocketAddresses
  // 先声名一个 socketHost(主机名) 和 一个socketPort(端口号)，表示要请求的主机名和端口号
  val socketHost: String
  val socketPort: Int
  if (proxy.type() == Proxy.Type.DIRECT || proxy.type() == Proxy.Type.SOCKS) {
    // 如果是直连代理(也就是无代理)，或者SOCKS代理，那么请求的主机和端口号就是目标服务器的主机号和端口号
    socketHost = address.url.host
    socketPort = address.url.port
  } else {
    // 如果是HTTP代理，那么请求的主机名和端口号应该是HTTP代理服务器的主机名和端口号
    val proxyAddress = proxy.address()
    require(proxyAddress is InetSocketAddress) {
      "Proxy.address() is not an InetSocketAddress: ${proxyAddress.javaClass}"
    }
    socketHost = proxyAddress.socketHost
    socketPort = proxyAddress.port
  }
 
  // 检查端口是否在1 - 65535范围内
  if (socketPort !in 1..65535) {
    throw SocketException("No route to $socketHost:$socketPort; port is out of range")
  }

  
  if (proxy.type() == Proxy.Type.SOCKS) {
    mutableInetSocketAddresses += InetSocketAddress.createUnresolved(socketHost, socketPort)
  } else {
    
    eventListener.dnsStart(call, socketHost)

    // 进行DNS域名解析，这也是一个网络请求，结果会返回 主机名经过DNS解析后返回的IP地址列表，注意是IP地址列表，一个主机名可能可以解析出多个IP
    val addresses = address.dns.lookup(socketHost)
    if (addresses.isEmpty()) {
      throw UnknownHostException("${address.dns} returned no addresses for $socketHost")
    }

    eventListener.dnsEnd(call, socketHost, addresses)

    for (inetAddress in addresses) {
      // 将解析到得InetAddress封装成
      mutableInetSocketAddresses += InetSocketAddress(inetAddress, socketPort)
    }
  }
}

【3】RealConnection.connect（待完善）

fun connect(
  connectTimeout: Int,
  readTimeout: Int,
  writeTimeout: Int,
  pingIntervalMillis: Int,
  connectionRetryEnabled: Boolean,
  call: Call,
  eventListener: EventListener
) {
  check(protocol == null) { "already connected" }

  var routeException: RouteException? = null
  val connectionSpecs = route.address.connectionSpecs
  val connectionSpecSelector = ConnectionSpecSelector(connectionSpecs)

  // 如果sslSocketFactory为null，也就是这是一个Http请求
  if (route.address.sslSocketFactory == null) {
    // 如果ConnectionSpec中没有
    if (ConnectionSpec.CLEARTEXT !in connectionSpecs) {
      throw RouteException(UnknownServiceException(
          "CLEARTEXT communication not enabled for client"))
    }
    val host = route.address.url.host
    // 检查目标主机是否允许明文传输
    if (!Platform.get().isCleartextTrafficPermitted(host)) {
      throw RouteException(UnknownServiceException(
          "CLEARTEXT communication to $host not permitted by network security policy"))
    }
  }
  // 如果sslSocketFactory不为null，也就是这是一个Https请求
  else {
    // 如果协议列表包含H2_PRIOR_KNOWLEDGE，抛出异常，H2_PRIOR_KNOWLEDGE是明文Http2协议，而Https不允许明文传输
    if (Protocol.H2_PRIOR_KNOWLEDGE in route.address.protocols) {
      throw RouteException(UnknownServiceException(
          "H2_PRIOR_KNOWLEDGE cannot be used with HTTPS"))
    }
  }

  while (true) {
    try {
      if (route.requiresTunnel()) {
        // 隧道连接
        connectTunnel(connectTimeout, readTimeout, writeTimeout, call, eventListener)
        if (rawSocket == null) {
          // We were unable to connect the tunnel but properly closed down our resources.
          break
        }
      } else {
        // 套接字连接，TCP三次握手在这里进行
        connectSocket(connectTimeout, readTimeout, call, eventListener)
      }
      // 建立协议，TLS四次握手在这里进行
      establishProtocol(connectionSpecSelector, pingIntervalMillis, call, eventListener)
      eventListener.connectEnd(call, route.socketAddress, route.proxy, protocol)
      break
    } catch (e: IOException) {
      socket?.closeQuietly()
      rawSocket?.closeQuietly()
      socket = null
      rawSocket = null
      source = null
      sink = null
      handshake = null
      protocol = null
      http2Connection = null
      allocationLimit = 1

      eventListener.connectFailed(call, route.socketAddress, route.proxy, null, e)

      if (routeException == null) {
        routeException = RouteException(e)
      } else {
        routeException.addConnectException(e)
      }

      if (!connectionRetryEnabled || !connectionSpecSelector.connectionFailed(e)) {
        throw routeException
      }
    }
  }

  if (route.requiresTunnel() && rawSocket == null) {
    throw RouteException(ProtocolException(
        "Too many tunnel connections attempted: $MAX_TUNNEL_ATTEMPTS"))
  }

  idleAtNs = System.nanoTime()
}

@Throws(IOException::class)
private fun establishProtocol(
  connectionSpecSelector: ConnectionSpecSelector,
  pingIntervalMillis: Int,
  call: Call,
  eventListener: EventListener
) {
  // 如果不是Https请求（这种情况下sslSocketFactory为null）
  if (route.address.sslSocketFactory == null) {
    // 并且保证支持明文Http2 (H2_PRIOR_KNOWLEDGE)
    if (Protocol.H2_PRIOR_KNOWLEDGE in route.address.protocols) {
      socket = rawSocket
      protocol = Protocol.H2_PRIOR_KNOWLEDGE
      // 启动http2协议
      startHttp2(pingIntervalMillis)
      return
    }

    socket = rawSocket
    protocol = Protocol.HTTP_1_1
    return
  }

  eventListener.secureConnectStart(call)
  // 四次握手过程
  connectTls(connectionSpecSelector)
  eventListener.secureConnectEnd(call, handshake)

  if (protocol === Protocol.HTTP_2) {
    startHttp2(pingIntervalMillis)
  }
}

【4】整体流程

介绍完ExchangeFInder.findConnection中调用的两个核心方法，我们来看看该方法的整体流程

在介绍流程前，先了解一下多路复用的概念:
多路复用是在Http2.0提出的，也就是只有Http2.0才支持多路复用，多路复用的意思就是一次连接能够并发处理多个请求 ( 详请可见【四.网络技术知识点补充】的【不同http版本的区别】)。所以RealConnection中的calls（call队列）其实也是为Http2.0定制的，因为Http1.0和Http1.1对应的RealConnection没法并发执行多个call

尝试重用call中的conneciton，能重用直接返回该connection，不能重用则将该connection关闭（返回connection的socket，然后关闭该socket）
若无法重用call中的Connection，那么将进行连接池的第一次查找:connectionPool.callAcquirePooledConnection(address, call, null, false)，第一次调用该方法中只传入了call和adderss，其它两个参数是null和false，(这个时候address还进行做域名解析，所以adderss.url的host字段也就是主机名可能是www.baidu.com这种的，也可能是具体的ip比如192.168.1.0。而连接池中的connection对应的主机名都是具体的ip地址，所以不一定能和address匹配得上)
如果第一次在连接池中没有找到合适的连接，那么就会去寻找一个合适的路由去创建一个新的连接。在这个过程中可能对address进行dns解析，解析后得到一个routes这个时候就会进行连接池的第二次查找:connectionPool.callAcquirePooledConnection(address, call, routes, false) ，和第一次调用该方法时多传入了routes参数，routes是address经过dns域名解析以后得到的route列表(一个route包含一个IP地址，所以routes也可以看成是IP列表，这里需要注意一个域名可能解析出多个IP地址，详情见【四.网络技术知识点补充】的【1.DNS负载均衡技术】），这个时候再去连接池中寻找是否有连接能够匹配routes中的route即可。
通过寻找到的路由，新建一个RealConnection，并调用其connect方法，connect方法会与服务器主机进行套接字连接(TCP + TLS三次握手)，这个时候会处于阻塞状态。
等到与服务器主机建立完连接后会进行连接池的第三次查找:connectionPool.callAcquirePooledConnection(address, call, routes, true)，这个时候最后一个参数传入的是true，表示需要将进行多路复用。
第三次查找的目的是，在建立连接的阻塞过程中，可能有别的请求正好创建了一个适合当前请求的连接并加入了连接池当中。而最后一个参数传入true表示需要进行多路复用，说明第三次查找是为Http2.0定制的。如果当前请求是一个Http2.0的请求，那么在第三次查找中很有可能找到合适的连接并对该连接进行多路复用。（若不是Http2.0的话，可以看成没有第三次查找）

（1）若在第三次查找中找到合适的连接，那么关闭新建的连接，将call加入到查找到的连接中并返回查找到的连接

（2）若在第三次查找中仍未找到合适的连接，那么将新建的连接放入到连接池，然后将call加入新建的连接，最后返回新建的连接
流程图如下：

5.CallServerInterceptor

1）intercept方法分析

@Throws(IOException::class)
override fun intercept(chain: Interceptor.Chain): Response {
  val realChain = chain as RealInterceptorChain
  val exchange = realChain.exchange!!
  val request = realChain.request
  val requestBody = request.body
  val sentRequestMillis = System.currentTimeMillis()

  // 先将请求头写入缓冲区
  exchange.writeRequestHeaders(request)

  var invokeStartEvent = true
  var responseBuilder: Response.Builder? = null
  // 判断请求是否为Post请求，且body不为空
  if (HttpMethod.permitsRequestBody(request.method) && requestBody != null) {
    // 如果请求头中包含ExceptL:100-continue，表示需要询问服务器是否愿意接收请求体，如果服务器愿意接收会返回一个code为100的response
    if ("100-continue".equals(request.header("Expect"), ignoreCase = true)) {
      // 第一次请求服务器
      // 注意这时只发送了请求头，请求体中的内容还未发送
      exchange.flushRequest()
      // 获取服务器返回的response,如果为null，那么表示response.code为100
      responseBuilder = exchange.readResponseHeaders(expectContinue = true)
      exchange.responseHeadersStart()
      invokeStartEvent = false
    }
    
    // responseBuilder == null，表示服务器返回的response的code为100，或者不存在Except:100-continue字段(也就是无需询问服务器意见即可传输body数据),此时可以传输请求实体中的数据
    if (responseBuilder == null) {
      if (requestBody.isDuplex()) {
        exchange.flushRequest()
        val bufferedRequestBody = exchange.createRequestBody(request, true).buffer()
          
        requestBody.writeTo(bufferedRequestBody)
      } else {
        // 将请求体中的数据写入缓冲区
        val bufferedRequestBody = exchange.createRequestBody(request, false).buffer()
        requestBody.writeTo(bufferedRequestBody)
        bufferedRequestBody.close()
      }
    }
      
    // responseBuilder != null，表示服务器不愿意接收请求体中的数据
    else {
      exchange.noRequestBody()
      if (!exchange.connection.isMultiplexed) {
        // 关闭连接
        exchange.noNewExchangesOnConnection()
      }
    }
  } else { // 如果不是Post请求或者 是Post请求但是没有请求体
    exchange.noRequestBody()
  }
  
  // 第二次请求服务器
  // finishRequest方法和flushRequest一样都会将缓冲区中的数据发送给服务器
  if (requestBody == null || !requestBody.isDuplex()) {
    exchange.finishRequest()
  }
  
   // responseBuilder == null，这个时候有三种情况（1.不是Post请求 2.是Post请求但请求头不存在Except:100-continue字段 3.是Post请求，请求头存在Except:100-continue字段并且服务器返回的response的code为100）
  
  // ResponseBuilder != null 说明请求头中带有Except:100-continue且服务器未返回状态码为100的Response（服务器不愿意接收请求体数据）
  if (responseBuilder == null) {
    responseBuilder = exchange.readResponseHeaders(expectContinue = false)!!
    if (invokeStartEvent) {
      exchange.responseHeadersStart()
      invokeStartEvent = false
    }
  }
  
  // 获取第一次请求对应的服务器响应
  var response = responseBuilder
      .request(request)
      .handshake(exchange.connection.handshake())
      .sentRequestAtMillis(sentRequestMillis)
      .receivedResponseAtMillis(System.currentTimeMillis())
      .build()
  var code = response
  // 如果响应编码为100，说明服务器愿意接收请求实体数据，而这个时候已经发出第二次请求了，所以可以再去接收缓冲区中读取第二次请求对于的response，这个才是客户端真正需要的response
  if (code == 100) {
    responseBuilder = exchange.readResponseHeaders(expectContinue = false)!!
    if (invokeStartEvent) {
      exchange.responseHeadersStart()
    }
    response = responseBuilder
        .request(request)
        .handshake(exchange.connection.handshake())
        .sentRequestAtMillis(sentRequestMillis)
        .receivedResponseAtMillis(System.currentTimeMillis())
        .build()
    code = response.code
  }

  exchange.responseHeadersEnd(response)

  // 收尾工作
  response = if (forWebSocket && code == 101) { // 如果是webSocket
    response.newBuilder()
        .body(EMPTY_RESPONSE)
        .build()
  } else { // 如果是Http请求
    // 
    response.newBuilder()
        .body(exchange.openResponseBody(response))
        .build()
  }
  
  // 如果response头的Connection字段的值为close，表示服务器要求关闭连接，这个时候直接把连接关闭
  if ("close".equals(response.request.header("Connection"), ignoreCase = true) ||
      "close".equals(response.header("Connection"), ignoreCase = true)) {
    exchange.noNewExchangesOnConnection()
  }
 
  // 如果响应体中没有内容
  if ((code == 204 || code == 205) && response.body?.contentLength() ?: -1L > 0L) {
    throw ProtocolException(
        "HTTP $code had non-zero Content-Length: ${response.body?.contentLength()}")
  }
  
  // 返回响应
  return response
}

结合注释梳理一下CallServerInterceptor的流程：

将请求头写入套接字缓冲区
判断是否为Post请求，并且request的body属性不为空

（1）若命中该命题

【1】检查请求头是是否含有Except:100-continue

「1」若请求头中有Except:100-continue字段，那么进行第一次请求，发送缓冲区中的数据(也就是请求头部分)，并获取到服务器的response对应的ResponseBuilder，如果服务器返回状态码为100的 response，ResponseBuilder 为 null，其他情况ResponseBuilder不为null

「2」若请求头中有Except:100-continue字段，ResponseBuilder为null

【2】检查ResponseBuilder是否为null（response == null 只有一种情况：1.请求头中没有Except:100-continue字段(这种情况说明传输body部分的数据时无需询问服务器是否同意) 2.请求头中有 Except:100-continue，且第一次请求中返回的response的状态码为100 ）

「1」 ResponseBuilder == null，说明可以向服务器发送给body中的数据，这是将请求体中的数据写入套接字缓冲区

「2」 ResponseBuilder != null，这是表示请求头中有Except:100-continue字段，并且第一次请求后得到服务器的response的状态码不为100，表示服务器不愿意接收请求body中的数据，这个时候直接关闭连接，并且从连接池中移除该连接(防止被复用)

（2）未命中该命题，则说明该请求没有body
进行第二次请求，即将请求体中的数据发送给服务器
判断ResponseBuilder是否为空
（1）如果ResponseBuilder == null，那么从套接字接收缓冲区中读取第一次请求后服务器返回的response并生成对应的ResponseBuilder，而此时ResponseBuilder == null 有以下三种情况（注意这个判断此时不在if (HttpMethod.permitsRequestBody(request.method) && requestBody != null) 命题语句内部）：
【1】不是Post请求
【2】是Post请求但请求头不存在Except:100-continue字段
【3】是Post请求，请求头存在Except:100-continue字段并且服务器返回的response的code为100

（2）如果ResponseBuilder != null，说明请求头中带有Except:100-continue且服务器未返回状态码为100的Response（服务器不愿意接收请求体数据），此时不做任何操作
根据ResponseBuilder生成response
（1）如果response的状态码为100，那么说明服务器愿意接收请求体中的数据，这个时候第二次请求也已经发送，

所以得再去套接字缓冲区中读取第二次请求后服务器返回的response，这个response才是客户端真实需要的

（2）如果response的状态码不为100，不需要再次进行读取
检查reponse头部是否有Connection:close字段，存在则说明服务器要求关闭连接，此时需要手动关闭连接
检查reponse状态码以及实体是否为空，若为空抛出异常
返回response
流程图如下：

四 .核心类

1.Route

![image-20211122144419815](/Users/shenyutao/Library/Application Support/typora-user-images/image-20211122144419815.png)

它是一个用于描述一条路由的类，主要通过代理服务器信息proxy、连接目标地址InetSocketAddress来描述一条路由。由于代理协议不同，这里的InetSocketAddress会有不同的含义

没有代理的情况下它包含的信息是经过了DNS解析的IP以及协议的端口号
SOCKS代理的情况下，它包含了HTTP服务器的域名和端口号
HTTP代理的情况下，它包含了代理服务器经过DNS解析后的IP地址和端口号

2.Proxy类

![image-20211122145043102](/Users/shenyutao/Library/Application Support/typora-user-images/image-20211122145043102.png)

这是由java原生提供的Proxy类，位于java.net包下
枚举类Type对应上面提到的三种代理类型

DIRECT ：直连，不使用代理
HTTP：使用HTTP代理
SOCKS：使用SOCKS代理

3.RouterSelector

该类下有一个next方法，通过该方法模拟路由选择的过程，RouteSelector是一个负责管理路由信息，并选择路由的类，它主要有以下三个职责：

收集可用的路由
选择可用的路由
维护连接失败的路由信息

1.RealConnectionPool

连接池，用于管理当前的连接RealConnect，它在okHttpClient.Builder中创建
![image-20211122104919266](/Users/shenyutao/Library/Application Support/typora-user-images/image-20211122104919266.png)

2.RealConnection

RealConnection属性分析

// TCP层的套接字
private var rawSocket: Socket? = null
// 应用层套接字，在rawSocket上分层的SSLSocket，如果此连接不使用SSL，则为rawSocket本身。
private var socket: Socket? = null
  
  ...
  
/*
   如果为true，则无法在此连接上创建新的交换。从池中删除连接时，必须将其设置为true；否则，racing caller可能会在不应该的时候从连接池中得到它。对称地，在从池返回连接之前，必须始终对此进行检查。 

  一旦为true，那么将永远都是true（因为套接字或者资源已经关闭）
*/
var noNewExchanges = false

五.网络技术知识点补充

1.DNS负载均衡技术

一个域名经过DNS解析后得到多个ip，服务器如果做了负载冗余，那么其中一个ip对于的服务器宕机时，另外一个立马补上让用户察觉不到。
冗余：起到的作用是在你的主备服务器的主机宕机时，立刻启动备用机防止不能访问，提供24小时不间断服务。
负载均衡：是在一个DNS服务器中做均衡，比如www.xiaobai.com对应192.168.0.1和192.168.0.2两个IP地址，那么DNS服务器第一次解析www.xiaobai.com域名时返回192.168.0.1，第二次返回192.168.0.2，然后不停循环下去实现负载均衡

重点是需要知道:一个域名可能对应不同的IP地址

2.URL统一资源定位符

http://192.168.10.1:80/index.html 这个是带有主机ip和端口的url，ip:端口可以使用域名代替

http://mail.163.com/index.html

1、http:// -----> 这个是协议, HTTP超文本传输协议, 也就是网页在网上传输的协议.
2、mail -----> 这个是服务器类型，用于决定解析该域名的DNS服务器, mail代表由邮箱服务器来解析该域名
3、163.com -----> 这个是域名, 是用来定位网站的独一无二的名字.
4、mail.163.com ->这个是主机名(网站名), 由服务器名 + 域名组成.
5、/ -----> 这个是根目录, 也就是说, 通过网站名找到服务器, 然后在服务器存放网页的根目录.
6、mail.163.com/index.html -----> url, 统一资源定位符, 全球性地址, 用于定位网上的资源.

3.代理服务器

代理服务器按照协议可以分为Http，Https，Socks，FTP代理服务器等

代理服务器还分为正向代理和反向代理，其中：

正向代理：正向代理的代理对象是客户端。客户端访问外网的时候，不直接请求目标服务器(比如位于外网的Web服务器)，而是先向代理服务器发送请求，让代理服务器去访问目标服务器，代理服务器从目标服务器上得到响应以后再讲响应转发给发出请求的客户端。
![image-20211123164826560](/Users/shenyutao/Library/Application Support/typora-user-images/image-20211123164826560.png)
逆向代理：逆向代理的代理对象是服务器。当客户端向目标服务器发送请求的时候，不是直接发送给目标服务器，而是先发送给目标服务器的代理服务器，再由代理服务器转发给目标服务器，待目标服务器做出响应后，代理服务器再将响应转发给发出请求的客户端
![image-20211123164957787](/Users/shenyutao/Library/Application Support/typora-user-images/image-20211123164957787.png)

总的来说，
正向代理的对象是客户端，它能够隐藏客户端的IP

逆向代理的代理对象是服务器，它能够隐藏服务器的IP

4.不同http版本的区别

Http1：一次请求-响应，建立一个连接，用完就关闭；每一次请求都要建立一个连接

Http1.1：一次连接可用处理多个请求，若干个请求排队串行单线程处理，后面的请求等待前面的请求返回后才开始执行，一旦某个请求超时，后续请求只能被阻塞，也就是线头阻塞。

Http2 ：多个请可以同时在一个连接上并行执行。某个任务耗时严重，不会影响到其他连接的正常执行

5.连接重用

参考文档链接：https://daniel.haxx.se/blog/2016/08/18/http2-connection-coalescing/

链接文档核心内容：

假设这个很酷的虚构站点“example.com”在 DNS 中有两个名称条目：A.example.com 和 B.example.com。当通过 DNS 解析这些名称时，客户端会为每个名称获取一个 IP 地址列表。一个很可能包含 IPv4 和 IPv6 地址混合的列表。每个名称一个列表。

您还必须记住，HTTP/2 也只被浏览器通过 HTTPS 使用，因此对于每个使用 HTTP/2 的源，还有一个相应的服务器证书，其中包含名称列表或通配符模式，该服务器有权响应.

在我们的示例中，我们首先将浏览器连接到 A。假设解析 A 从 DNS 返回 IP 192.168.0.1 和 192.168.0.2，因此浏览器继续连接到这些地址中的第一个，即以“1”结尾的地址”。浏览器在 TLS 握手中获取服务器证书，因此，它还获取服务器可以处理的主机名列表：A.example.com 和 B.example.com。（它也可以是像“*.example.com”这样的通配符）

如果浏览器随后想要连接到 B，它也会将该主机名解析为 IP 列表。假设这里是 192.168.0.2 和 192.168.0.3。

主机 A：192.168.0.1 和 192.168.0.2
主机 B：192.168.0.2 和 192.168.0.3

火狐的连接重用

主机 A 有两个地址，主机 B 有两个地址。地址列表并不相同，但存在重叠——两个列表都包含 192.168.0.2。并且主持人A已经声明它对B也具有权威性。在这种情况下，Firefox 不会再次连接到主机 B。它将重用到主机 A 的连接，并通过该单个共享连接请求主机 B 的内容。这是使用中最激进的合并方法。

Chrome的连接重用

Chrome 具有稍微不那么激进的合并。在上面的示例中，当浏览器连接到第一个主机名的 192.168.0.1 时，Chrome 将要求主机 B 的 IP 包含该特定 IP，以便它重用该连接。如果主机 B 返回的 IP 确实是 192.168.0.2 和 192.168.0.3，则它显然不包含 192.168.0.1，因此 Chrome 将创建到主机 B 的新连接。

如果解析主机 B 返回一个包含连接主机 A 已使用的特定 IP 的列表，Chrome 将重用与主机 A 的连接。

6.Https握手过程

Http: 直接使用明文在客户端和服务器之间完成数据通讯
Https: 采用非对称加密和对称加密相结合的方式加密传输的内容，保证客户端和服务器之间的通信安全。
（非对称算法用于加密交换秘钥 + 对称算法用于加密传输数据 +数字证书验证身份）

这里讲一下对称加密和非对称加密的一个区别：
对称加密：明文P通过密钥K加密后得到密文M，密文M能够通过秘钥P解密成明文P
非对称加密：有一组密钥即公钥和私钥，公钥加密明文P得到密文M，密文M无法通过公钥解密成明文P，只能通过私钥解密

Https：

Tcp三次握手过程：

(SYN = 1,Seq = x)客户端向服务端发送一个SYN标志位为1以及Seq = x的请求，表示请求和服务端建立连接
(SYN=1,ACK=1,Seq =y,ACKNum = x + 1)服务端收到请求后发回确认应答，发送一个SYN和ACK标志位均为1，Seq为y的报文，发送完毕后，服务端进入SYN _RCVD状态
(ACK = 1 ,ACKNum = y+1)客户端验证ACKNum即ACKNum是否等于x + 1，然后发送一个ACKNum = y+1的报文
发送完毕后，客户端进入 ESTABLISHED 状态，当服务端接到这个包时，也进入 ESTABLISHED 状态，至此 TCP 握手结束。

TLS握手过程

首先，客户端向服务器发起握手请求，以明文传输请求信息，主要包括版本号、客户端支持的加密算法、客户端支持的压缩算法等
服务器的配置：支持Https协议的服务器必须要有一套数字证书，可以自己制作也可以向组织申请。自己颁发的证书需要客户端验证通过才可以继续访问，而使用向受信任的公司申请的证书则不会弹出提示页面。
服务端收到请求后，从客户端支持的加密算法中选择一种(服务器也支持该加密算法)并连同证书返回给客户端(公钥就包含在证书当中，证书中还包含颁发机构，过期时间等信息)
客户端验证证书的合法性，包括是否可信，是否过期，以及服务器支持的域名列表等
客户端随机生成一个对称加密算法的共享密钥（这里也叫对称秘钥），并通过证书中的公钥进行加密后发送给服务器
服务器收到后利用私钥解密，得到共享密钥后向客户端发送Finish消息，完成握手过程

开始通信：

服务器利用对称密钥加密客户端想要的数据，并发送给客户端
客户端收到数据后用对称秘钥解密，得到明文数据

四次挥手：

Seq连接序列号，就是用于确认发送报文的对象

(FIN = 1,Seq = x) 客户端向服务器发送一个FIN标志位为1，连接序号为x的请求用来关闭客户端到服务器的数据传送，此时Client进入FIN_WAIT_1状态
(ACK = 1 ，ACKNum = x +1) 收到FIN请求后，服务端向Client发送一个ACK = 1 ，ACKnum = x + 1 的报文确认关闭客户端到服务器的数据传送，此时服务端进入CLOSE_WAIT状态

注意：这个时候只是关闭了客户端到服务端之间的数据传输，客户端以及不能够再想服务器发送数据。而服务端到客户端之间的数据传输还未关闭，服务端此时仍可向客户端发送数据
(FIN = 1,Seq = y) 服务端向客户端发送一个FIN报文用来关闭服务端到客户端的数据传输，服务端进入LAST_ACK状态
(ACK = 1,Seq = y + 1)Client收到FIN后，发送一个ACK给服务端，服务端确认验证Seq后进入CLOSED状态完成四次挥手

7.HTTP 协议头中的 Transfer-Encoding

（1）简介

Transfer-Encoding是Http请求头中的一个字段，字面意思是「传输编码」。而Http请求头中还存在另外一个和编码有关的头部：Content-Encoding「内容编码」。
Content-Encoding「内容编码」通常用于对body内容进行压缩，目的是缩小体积,优化传输。
Transfer-Encoding「传输编码」是用来改变报文格式，不会改变body内容的大小。
一个Http报文很可能同时使用了这两种编码

（2）Transfer-Encoding

Http/1.0的持久连接是在后来才引入的，通过Content:Keep-alive头部字段来实现，服务端和客户端都可以使用该字段告诉对方在发送完数据以后不需要断开Tcp连接，以备复用。

Http/1.1中规定所有连接必须都是持久的连接，除非显示地在头部加上Connection:close告诉对方关闭Tcp连接。所以实际上，Http/1.1中的Connection字段已经没有keep-alive取值了，但由于历史原因很多Web Server和浏览器还是保留着给Http/1.1长连接发送Connection:keep-alive的习惯。也就是说Http/1.1的连接都是长连接，并不需要通过Connection:keep-alive来指定

对于非持久连接:
(1) 服务端可以通过 客户端到服务端的连接是否关闭（四次挥手的前两次） 来判断请求体是否接收完成
(2) 客户端可以通过 服务端到客户端的连接是否关闭（四次挥手的后两次）来判断响应体是否接收完成

对于持久连接，数据传输完成后连接并不会关闭，所以通过连接是否关闭来判断数据是否接收完成在持久连接的情况下显然不奏效。这会造成一方完成数据传输后，另外一方不知道已经收到了全部的数据进而一直处于Pending状态，此时有两种解决方案

【1】Content-Length

Content-Length也是http请求头中的一个字段，用于告诉对方body的长度，对方通过Content-Length来判断是否完成数据的接收，所以此时Content-Length长度必须和body的时机长度一致，
若Content-Length大于body实际长度，会造成对方一直处于Pending状态。
若Content-Length小于body实际长度，会造成内容被截断。

但是在body很大的情况下，去计算Content-Length需要开启一个足够大的Buffer，这会造成很大的内存开销，所以就有了下面的方法：Transfer-Encoding: chunked「分块编码」。

【2】Transfer-Encoding: chunked

Transfer-Encoding: chunked的意思是分块编码。若向Http头部添加了该字段，就表明该报文采用了分块编码。
这时，Http报文中的body部分会改用一系列的分块来传输。每个分块包含body的一段数据以及该段数据的长度等信息。
而在数据的所有分块都完成传输后，会发送一个长度值为0而且没有内容的分块，表示传输结束。

8.HTTP 协议头中的 Accept-Encoding

该字段一般只会出现在请求头（区别响应头）中，Accept-Encoding字段用于告诉接收方发送方支持的「内容编码」格式，比如gzip压缩。
比如客户端向服务端发送了一个带有Accept-Encoding:gzip字段的请求，服务端收到请求后通过该字段能够得知客户端支持gzip编码，这个时候服务器可以根据情况对response的body进行gzip编码（也可以不进行任何编码，如果进行了gzip压缩，服务器会在response的头部添加Content-Encoding:gzip字段）然后发送给客户端，客户端再利用gzip解码即可得到原来的body。

9.HTTP 协议头中的 Range

（1）带有range字段的请求

Range字段只会出现在请求头当中
Range字段用于指定请求资源的部分内容(不包括响应头的大小)，这么说可能有点抽象，来举个例子。

Range字段的格式Range: bytes=start-end
表示只从body的byte流中获取第start个byte到第end个byte之间的内容，比如下面的两个例子：

Range: bytes=10- ：第10个字节及最后个字节的数据
Range: bytes=40-100 ：第40个字节到第100个字节之间的数据.

（2）带有range字段的请求对应的响应头

带有range字段的请求对应的响应头中会带有Content-Range字段
比如Content-Range: bytes 0-10/3103，表示请求指定获取了第0个byte到第10个byte指定的内容。而3103对于资源比特流的总长度。

带有range字段的请求对应的响应头中的Content-Length = end - start + 1

10.Http协议头中的 Except:100-continue

当使用Post的方式发送请求的时候，如果请求头中包含Except:100-continue字段，那么客户端在发送请求传输实体body之前需要先发送请求头header去询问服务器是否愿意接收该数据。

如果服务器愿意接收数据，会返回给客户端一个code为100的response，客户端收到该response后才开始向服务端传输请求数据(这个时候会将请求头和请求体一起发送出去)

11.Http缓存机制

目前只支持Get和Head请求的缓存

（1）相关协议头字段

Cache-Control：请求/响应头，缓存控制字段，由该字段决定要不要缓存数据

它有以下常用的值

[1] no-store :所有内容都不缓存

(2) no-cache: 缓存，但是浏览器使用缓存前，会先请求服务器判断缓存资源是否最新。

(3) max-age = x（秒）：请求缓存后的x秒内不再发起网络请求而是直接读取缓存。它于Expires字段作用相同，并且优先级高于Expires

(4) 全部值

【1】缓存请求Cache-Control字段中的所有可能值

指令	参数	说明
no-cache	无	强制向源服务器再次验证
no-store	无	不缓存请求或响应的任何内容
max-age= [秒]	必需	响应的最大值
max-stale= [秒]	可省略	接收已过期的响应
min-fresh= [秒]	必需	期望在指定时间内的响应仍有效，
no-transform	无	代理不可更改媒体类型
only-if-cached	无	不发送网络请求，只从缓存获取资源
cache-extension	-	新指令标记（token）

min-fresh 指令要求缓存服务器返回至少还未过指定时间的缓存资源。当指定 min-fresh=60 后，过了60秒的资源都无法作为响应返回了。
max-stale 如果指令未指定参数值，那么无论经过多久，客户端都会接收响应；如果指令中指定了具体的数值，那么即使过期，只要仍然处于 max-stale 指定的时间内，仍旧会被客户端接收。
only-if-cached 不发送网络请求，只从缓存获取资源

【2】缓存响应Cache-Control字段中的所有可能值

指令	参数	说明
public	无	可向任意方提供响应的缓存
private	可省略	仅向特定用户返回响应
no-cache	可省略	缓存服务器不能对资源进行缓存
no-store	无	不缓存请求或响应的任何内容
no-transform	无	代理不可更改媒体类型
must-revalidate	无	可缓存但必须再向源服务器进行确认
proxy-revalidate	无	要求中间缓存服务器对缓存的响应有效性再进行确认
max-age=[秒]	必需	响应的最大 Age 值
s-maxage=[秒]	必需	公共缓存服务器响应的最大Age值
cache-extension	-	新指令标记（token）

【3】请求头(客户端)中的max-age 和响应头中的max-age的区别

当客户端发送的请求中包含 max-age 指令时，如果判定缓存资源的缓存时间数值比指定时间的数值更小，那么客户端就接收缓存的资源。另外，当指定 max-age 值为 0 ，那么缓存服务器通常需要将请求转发给源服务器。
当服务器返回的响应中包含 max-age 时，此时表示资源缓存的最长时间，缓存服务器不再对资源的有效性进行确认。
在 HTTP/1.0 版本中，当 Expires 和 max-age (同时出现时)，会优先处理 max-age 指令，忽略 Expires。

Date

表明创建HTTP报文的日期和时间（注意不是接收到报文的时间）
Age

Http报文从创建到接收方接收到报文经过的时间，（如果age > maxAge，说明缓存过期）

本人猜测，设置这个字段的目的是防止服务器的Response头部max-age值太小，导致报文还没发送到客户端手上时就过期了(传输过程可能要经过代理服务器转发)
Expires( Http1.0 的字段 )：

响应头字段，代表资源过期的事件，有服务器提供，GMT日期格式。是Http1.0的字段，优先级低于Cache-control : max-age = x
Last-Modified

响应头字段，资源最新修改事件，由服务器告诉浏览器
Last-Modified-Since

请求头字段，有浏览器提供给服务器。表示该浏览器上一次向服务器发起请求时，返回的Last-Modified字段的值
Etag

响应头字段，资源标识，由服务器告诉服务器
if-None-Match

请求头字段，缓存资源标识，由浏览器告诉服务器。代表上一次请求服务器时返回的Etag。

（2）Http缓存机制

if-None-Match的优先级比Last-Modified-Since高，若请求头中带有if-None-Match，服务器就只比较if-None-Match和ETag，不处理Last-Modified-Since
Last-Modified-Since和Last-Modified头字段，通过比较资源最近修改的时间来判断资源是否发生改变，但是只能到秒，如果资源修改发生在1s以内，那么客户端将无法获取到最新的数据。所以引入了if-None-Match和Etag
if-None-Match和Etag头字段，if-None-Match是浏览器向服务端提供的资源标识，其值是上一次向服务器发送请求时服务器返回的Etag(Etag对应的资源被修改，则Etag发生改变)。也就是服务器通过上一次请求发送给客户端的Etag和当前的Etag作比较，来告诉客户端资源是否发生变化

码农公寓

一.Dispatcher工作流程

1）OkHttp的基本使用

2）RealCall.enqueue

3） Dispatcher.enqueue

4）Dispatcher.promoteAndExcute

5） AsyncCall.executeOn

6）AsyncCall.run

7）Dispatcher.finish

8）总体流程总结

二.拦截器链

1）AsyncCall.getResponseWithInterceptor

2） RealInterceptorChain.proceed

3）RealInterceptorChain.processed在各种拦截器的Interceptor方法中的调用

4）拦截器链流程图

三.拦截器

1.五种拦截器介绍

1）RetryAndFollowUpInterceptor - 重定向拦截器

2）BridgeInterceptor - 桥接拦截器

3）CacheInterceptor - 缓存拦截器

4）ConnectInterceptor - 连接拦截器

5）CallServerInterceptor - 呼叫服务拦截器

2.五种拦截器源码分析

1.RetryAndFollowUpInterceptor - 重定向拦截器

1）intercept方法分析

2.BridgeInterceptor - 桥接向拦截器

1）intercept方法分析

3.cacheInterceptor - 缓存拦截器

1）intercept方法分析

2）CacheStrategy.Factory.init

3）CacheStrategy.Factory.compute()

4）CacheStrategy.Factory.computeCandidate()

4.ConnectInterceptor

1）intercept方法分析

2）RealCallback.initExchange

3）ExchangeFInder.find

4）ExchangeFInder.findHealthyConnection

5）ExchangeFInder.findConnection

【1】RealConnectionPool.callAcquirePooledConnection

「1」RealConnection.isEligible

「2」RealCall.acquireConnectionNoEvents

「3」整体流程

【2】RouteSelector.next

「1」RouteSelector.nextProxy()方法

「2」RouteSelector.resetNextInetSocketAddress

【3】RealConnection.connect（待完善）

【4】整体流程

5.CallServerInterceptor

1）intercept方法分析

四 .核心类

1.Route

2.Proxy类

3.RouterSelector

1.RealConnectionPool

2.RealConnection

五.网络技术知识点补充

1.DNS负载均衡技术

2.URL统一资源定位符

http://mail.163.com/index.html

3.代理服务器

4.不同http版本的区别

5.连接重用

链接文档核心内容：

火狐的连接重用

Chrome的连接重用

6.Https握手过程

Https：

Tcp三次握手过程：

TLS握手过程

开始通信：

四次挥手：

7.HTTP 协议头中的 Transfer-Encoding

（1）简介

（2）Transfer-Encoding

【1】Content-Length

【2】Transfer-Encoding: chunked

8.HTTP 协议头中的 Accept-Encoding

9.HTTP 协议头中的 Range

（1）带有range字段的请求

（2）带有range字段的请求对应的响应头