首页 > 代码库 > OkHttp面试之--OkHttp的整个异步请求流程

OkHttp面试之--OkHttp的整个异步请求流程

通过上一节,我们已经了解了如何使用OkHttp发送异步请求,下载网络图片信息并显示到ImageView控件上,从这一节开始我们就来开始研究一下其内部的实现流程和原理。因为整个流程相对而言还是比较复杂,因此对于流程的分析我划分成以下几个章节去介绍

  1. 流程概述
  2. 拦截器的原理
  3. HttpEngine中sendRequest的流程分析
  4. HttpEngine中readResponse的流程分析

这一节我们先来看一下整个流程的概述,先上一张时序图
技术分享
以上图片来自http://www.jianshu.com/p/db197279f053

就从上一些OkHttp的使用开始分析:
上一节我们通过OkHttpClient.newCall(Request)的方法创建出一个Call对象,
Call是一个接口代码如下:

package okhttp3;

import java.io.IOException;

public interface Call {

  Request request();

  Response execute() throws IOException;

  void enqueue(Callback responseCallback);

  void cancel();

  boolean isExecuted();

  boolean isCanceled();

  interface Factory {
    Call newCall(Request request);
  }
}

因此OkHttpClient需要给我们返回一个Call接口的实现类,点击去看一下,代码如下:

/**
   * Prepares the {@code request} to be executed at some point in the future.
   */
  @Override public Call newCall(Request request) {
    return new RealCall(this, request);
  }

可以发现,其实返回的是RealCall对象。

接下来在Activity中调用Call.enqueue(Callback)方法,点进去之后代码如下:
技术分享
在enqueue一参的方法中又调用了2参数的方法,并将第二个参数forWebSocket置为了false.

而在2参数的enqueue方法中,我们发现最终调用了client.dispatcher.enqueue的方法,并且将Callback和forWebSocket两个参数封装到了一个叫做AsyncCall的对象当中.

这个dispatcher就是OkHttpClient中的一个全局变量,点进去查看如下:

synchronized void enqueue(AsyncCall call) {
    if (runningAsyncCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) {
      runningAsyncCalls.add(call);
      executorService().execute(call);
    } else {
      readyAsyncCalls.add(call);
    }
  }

Dispatcher内部是过一个线程池来执行,超过最大请求数后则先加入准备请求的队列中,对于这个线程池后续会单独用一篇博客来讲解,此时我们主要来整理一下整个请求流程,因此不做过多解释。 以上代码会执行到if代码块,然后执行executorService().execute(call); 看到这对于线程池有了解的同学应该能立马想到AsyncCall其实就是一个Runnable对象,我们点进AsyncCall代码中可以看到它就是继承了NamedRunnable,而NamedRunnable又实现了Runnable接口并且在run方法中主动调用了execute的方法,如下所示:
技术分享

而这个抽象的execute方法在AsyncCall中已经被实现,如下所示:

技术分享

由上图可以看到,当执行一个AsyncCall的execute方法时,会调用一个叫做getResponseWithInterceptorChain的方法,并返回Response对象,然后通过接口回调的方式将此Response返回给我们在Activity中所实现的Callback接口并刷新UI。

那这个getResponseWithInterceptorChain内部又是如何工作的呢??其实这个方法中的源码很简单,如下所示:
技术分享

创建了一个ApplicationInterceptorChain对象,然后调用其proceed方法进行,接下来看一下ApplicationInterceptorChain的proceed代码如下

技术分享

在proceed方法中,判断如果index小于OkHttpClient中拦截器集合的个数,则会递归创建新的ApplicationInterceptorChain对象,并将这个新的ApplicationInterceptorChain对象那个传递给index下标的拦截器的intercept方法

注意:此处有一个亮点,如果我们想自己实现Intercept一定要在intercept方法中主动调用chain.proceed方法,这样整个递归循环才能顺利的执行下去,反过来说我们也可以在某一个拦截器中将网络请求进行拦截,做法就是只要在拦截器中不调用proceed方法即可

对于拦截器的作用以及原理我会在后续章节中单独分析


但是在这个递归循环中,最终index都会处于一个>=client.interceptors.size的阶段,因此最终会调用最后一行代码getResponse(request, forWebSocket)方法。这个方法是真正的发送网络请求并获取Response的方法,其内部代码如下所示:

技术分享

如图所示,在getResponse方法中创建了一个HttpEngine的对象,然后分别调用HttpEngine的sendRequest和readResponse方法,这两个方法依次是发送网络请求和读取网络请求结果,最后将Response对象返回到之前说的getResponseWithInterceptorChain方法,并回传给Activity中的Callback

对于HttpEngine内部实现后续会单独再做分析。

最后用两个图来做一个流程总结

技术分享


技术分享

<script type="text/javascript"> $(function () { $(‘pre.prettyprint code‘).each(function () { var lines = $(this).text().split(‘\n‘).length; var $numbering = $(‘
    ‘).addClass(‘pre-numbering‘).hide(); $(this).addClass(‘has-numbering‘).parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($(‘
  • ‘).text(i)); }; $numbering.fadeIn(1700); }); }); </script>

    OkHttp面试之--OkHttp的整个异步请求流程