okhttp的Interceptor拦截器源码解析

几个关键类以及接口

• RealInterceptorChain

• Interceptor

RealInterceptorChain

RealInterceptorChain实现了Interceptor接口,调用源头来自于RealCall的getResponseWithInterceptorChain方法

  Response getResponseWithInterceptorChain() throws IOException {
    // Build a full stack of interceptors.
    List<Interceptor> interceptors = new ArrayList<>();
    /**
    *  1
    */
    interceptors.addAll(client.interceptors());
    interceptors.add(retryAndFollowUpInterceptor);
    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));
    /**
    *  2
    */
    Interceptor.Chain chain = new RealInterceptorChain(
        interceptors, null, null, null, 0, originalRequest);
    return chain.proceed(originalRequest);
  }

1. 第一处是把自定义的拦截器先加入进去，然后把okhttp内置的一些拦截器按照功能顺序add进list里

2. 第二处是整个拦截器工作的源头，先new了一个RealInterceptorChain,index为0，把初始的request传了进去,然后调用proceed获取请求的response

接下来看一下proceed方法的具体实现,忽略掉一些检查

public Response proceed(Request request, StreamAllocation streamAllocation, HttpCodec httpCodec,
      RealConnection connection) throws IOException {
    if (index >= interceptors.size()) throw new AssertionError();

    calls++;
    /**
    *  1
    */
    // Call the next interceptor in the chain.
    RealInterceptorChain next = new RealInterceptorChain(interceptors, streamAllocation, httpCodec,
        connection, index + 1, request, call, eventListener, connectTimeout, readTimeout,
        writeTimeout);
    Interceptor interceptor = interceptors.get(index);
    Response response = interceptor.intercept(next);

    return response;
  }

先是检查一下index是否超出interceptors也就是拦截器list的长度，接着又new了一个RealInterceptorChain，把当前RealInterceptorChain的一些参数属性都传了进去，并且在这里把index + 1,这个地方很重要，在这里可以把RealInterceptorChain想象成把拦截器给包装了起来，然后用下一个拦截器生成一个新的RealInterceptorChain中，然后把index+1下标的chain传进了当前拦截器的intercept方法里，也就是我们自定义拦截器的时候需要重写的intercept方法，也就是说我们添加的拦截器里的intercept方法中RealInterceptorChain对象，实际上里面包含有整个request以及下一个拦截器。所以就形成了一条链，每一个拦截器都持有下一个拦截器经过包装之后的RealInterceptorChain对象,直到拦截器链的最后一个拦截器CallServerInterceptor 这个拦截器会做最后的处理，然后开始请求生成Response并且返回。拦截器可以通过intercept方法获取下一个拦截器return的response,而且会通过proceed方法向下一个拦截器传递自己处理过的Requeset

---

到这里总结一下各个方法以及类的作用

• RealInterceptorChain

包装了拦截器以及网络请求的信息

• RealInterceptorChain.proceed

参数中有Request,是上一个拦截器包装过后的Request,然后将下一个拦截器和整个Request的信息包装成RealInterceptorChain，并且会调用当前拦截器的intercept方法把下一个拦截器(RealInterceptorChain)传进去，并且获取到Response

• Interceptor.intercept

方法参数是下一个Chain也就是RealInterceptorChain，然后调用RealInterceptorChain.request()去获取请求,调用RealInterceptorChain.proceed()去获取Response

这三点结合在一起，就形成了一条链，假设有拦截器A/B/C,RealInterceptorChain A/B/C

RA.proceed->A.intercept（调用下一个拦截器的proceed）->RB.proceed->B.intercept，这样的写法，可以让每个拦截器都获取到上一个拦截器包装过的Request并且自己处理之后再传给下一个拦截器，然后最后一个拦截器生成Response之后，从拦截器链尾部往头部拦截器一层层return，就形成了一个完整的拦截器链处理逻辑