RetryAndFollowUpInterceptor 实现原理和功能分析

RetryAndFollowUpInterceptor 实现原理和功能分析

Overview

该拦截器功能有
* 创建Address
* 创建StreamAllocation
* 处理响应结果，例如重定向或者重试

这个类最核心的方法就是它的
```java
@Override public Response intercept(Chain chain) throws IOException
```
这个Chain是在RealCall中的 getResponseWithInterceptorChain()构造并传入的。

下面是该方法的实现

1.创建Address和StreamAllocation

```java
private Address createAddress(HttpUrl url) {
    SSLSocketFactory sslSocketFactory = null;
    HostnameVerifier hostnameVerifier = null;
    CertificatePinner certificatePinner = null;
    if (url.isHttps()) {
      sslSocketFactory = client.sslSocketFactory();
      hostnameVerifier = client.hostnameVerifier();
      certificatePinner = client.certificatePinner();
    }

    return new Address(url.host(), url.port(), client.dns(), client.socketFactory(),
        sslSocketFactory, hostnameVerifier, certificatePinner, client.proxyAuthenticator(),
        client.proxy(), client.protocols(), client.connectionSpecs(), client.proxySelector());
  }
 ```

 通过此代码创建一个Address，然后创建一个StreamAllocation，这个类算是OkHttp的核心类，创建Socket和连接Socket都在这个类当中。

2.执行chain.proceed()

```
response = ((RealInterceptorChain) chain).proceed(request, streamAllocation, null, null);
releaseConnection = false;
```

将Request和构建好的streamAllocation传递给后面的interceptor,并返回Response

3.处理响应结果，例如重定向或者重试

得到Response，根据响应状态做响应的处理

怎么实现重定向和重试的？

这是其 public Response intercept(Chain chain) 的一段大致流程代码，
这段代码不是源码，是我在源码的基础上认为比较重要的复制出来拼在一起的
很佩服作者的思路，真的很巧妙。
用一个死循环来做的，重定向是根据结果返回的的来决定是否需要跳出死循环，
重试是根据抛出的IOException的时候判断是将异常抛出还是继续执行循环来做的

```
 while (true){

    //proceed
    try {

        response = chain.proceed(request, streamAllocation, null, null)

    }catch (IOException e) {
         boolean requestSendStarted = !(e instanceof ConnectionShutdownException);
    //这是其中的一个异常处理 ，recover是判断时候需要重试，若需要重试继续循环，不需要则抛出异常退出循环
         if (!recover(e, requestSendStarted, request)) throw e;
         releaseConnection = false;
         continue;
    }
    //根据response判断是否需要重定向 ，不要返回null 需要返回重定向的Request
    Request followUp = followUpRequest(response)

    //不需要重定向 返回response
    if (followUp == null){
        return response
    }

    //是否达到最大允许的重定向次数
    if (++followUpCount > MAX_FOLLOW_UPS) {
        streamAllocation.release()
        throw ProtocolException("Too many follow-up requests: " + followUpCount)
    }

    //重新构建streamAllocation
    if (!sameConnection(response, followUp.url())) {
        streamAllocation.release();
        streamAllocation = new StreamAllocation(
                client.connectionPool(), createAddress(followUp.url()), callStackTrace);
    } else if (streamAllocation.codec() != null) {
        throw new IllegalStateException("Closing the body of " + response
                + " didn't close its backing stream. Bad interceptor?");
    }

    接着循环
}
```

End 到此这个类的功能原理就很清楚了