锐客网

  1. 首页 > it技术 > >

OkHttp源码(二（同步异步流程源码)）


通过上一节内容，我们知道无论是同步还是异步的调用，都会使用OkHttpClient的newCall来创建一个Call对象。这个Call对象就是用来处理HTTP请求的，下面是newCall的源码：
OKHttpClient的newCall
OkHttp源码(二（同步异步流程源码)）
文章图片
RealCall的newRealCall
OkHttp源码(二（同步异步流程源码)）
文章图片
我们看到最终返回了一个RealCall的对象，这个RealCall是继承自Call接口
Call
负责准备去执行一个 request 请求,一个 call 只能负责去执行一个请求，不能被执行两次。因为 OkHttpClient 是实现了 Call.Factory 因此它具备创建 Call 对象的功能，内部创建的就是 RealCall 对象。Call 是封装 request 的，它表示一个可以执行的请求。
Call 的实现类 RealCall
因为 Call 是接口，内部定义了同步（execute）与异步(enqueue)的请求，以及取消请求等操作，这些操作是由 RealCall 真正去实现的。
一、RealCall同步流程 OkHttp源码(二（同步异步流程源码)）
文章图片
其中，executed表示当前Call是否已经执行，synchronized同步代码块保证了一个 Call 只能被执行一次。
核心代码：
1 调用dispatcher的executed
2 调用拦截器链getResponseWithInterceptorChain获取Response
3 最终会调用dispatcher的finished主动回收http的请求。
OkHttp源码(二（同步异步流程源码)）
文章图片
在finished中calls.remove(call)移除请求，移除后计算队列中Http请求总数（runningCallsCount），当请求总数为0而且idleCallback不为空的时候调用idleCallback.run
二、RealCall异步调用流程 OkHttp源码(二（同步异步流程源码)）
文章图片
AsyncCall 是RealCall中的内部类，在 Dispatcher 中分发的异步请求任务就是 AsyncCall。AsyncCall 就是一个Runnable，用表示一个异步任务的，在 Dispatcher 内部有维护了两个队列来存储 AsyncCall，分别是 readyAsyncCalls 和runningAsyncCalls 它们分别表示准备要执行的 AsyncCall 队列和正在执行的 AsycnCall 队列。当然还有一个 runningSyncCalls 这个队列，但是它适用于存放 RealCall ，也就是用于存储同步请求的任务。
OkHttp源码(二（同步异步流程源码)）
文章图片
Dispatcher
下面是对成员变量的解释：
【OkHttp源码(二（同步异步流程源码)）】int maxRequests = 64 会去指定并发 call 的最大个数。
maxRequestsPerHost = 5: 每个主机最大请求数为5 ，也就是最多 5 个call公用一个 host。这个host 就是在 RealCall 中通过 originalRequest.url().host() 去获取的，例如www.baidu.com
executorService 就是执行异步任务的线程池，在内部中已经指定好了线程池，当然也可以在 Dispacther 中通过构造方法去指定一个线程池。
Deque readyAsyncCalls 表示在队列中已经准备好的请求。
Deque runningAsyncCalls 正在执行的异步请求，包括已经取消的请求（还没有执行finish操作的请求。）
Deque runningSyncCalls 正在运行的同步请求，包括已经取消的请求（还没有执行finish操作的请求。）
OkHttp源码(二（同步异步流程源码)）
文章图片
Dispatcher 中的enqueue方法： 在 OKHTTP 中正在执行的请求不能超过 64 个，并且同一个主机不能超过 5 请求，当满足这两个条件，即可将任务添加到正在执行的队列 runningAsyncCalls 中，并且通知线程池安排线程去执行这个异步任务，否则就会被添加到等待队列中 readyAsyncCalls。
Dispatcher 会将 AsyncCall 交给指定的线程去执行executorService().execute(call)，而 AsyncCall 是 NamedRunnable 的子类，因此它也具备 Runnble 的特性，换句话说，在线程池中执行的任务就是 AsyncCall 了。当线程池执行这个异步任务时，那么该 Runnable 的 run 方法就会被执行。NamedRunnable 源码如下，在 run 方法内部会去调用 AsyncCall 的 execute 方法。
OkHttp源码(二（同步异步流程源码)）
文章图片
OkHttp源码(二（同步异步流程源码)）
文章图片
AsyncCall 的 execute才是真正的异步执行方法。
1 得到 HTTP 请求的响应 Response ：Response response = getResponseWithInterceptorChain(); 得到一个 response 响应。(这个是一个递归的调用过程，拦截器链)
2 给调用进行接口回调异步任务执行的结果：responseCallback.onResponse 或者 responseCallback.onFailure
3 结束该请求，并且执行下一个等待的异步任务：client.dispatcher().finished(this);
OkHttp源码(二（同步异步流程源码)）
文章图片
总结该finished方法中它主要做了这 3 件事：
1 从 calls 中移除该 AysyncCall 对象，而这个 calls 就是 Dispatcher 中的 runningAsyncCalls。
2 promoteCalls() 调用该方法就可以实现从等待队列中取出下一个异步任务去执行。
3 idleCallback.run(); 重新计算正在执行的Http请求数，没有正在执行的任务时，那么就回调这个接口，该回调接口需要通过 setIdleCallback 方法传递进来。它可以通知当没有任务正在执行时，通知外界。runningCallsCount 这个是同步执行的任务数和异步执行任务数之和。
通过 promoteCalls() 去执行下一个异步任务
OkHttp源码(二（同步异步流程源码)）
文章图片
该方法是用于在等待队列中获取下一个异步任务去执行。在内部会还是会对 Dispatcher 内部的几个属性进行判断，例如对正在执行的请求数量是否超过了 64 个，还有遍历等待队列里的所有的 AsyncCall ，每遍历出一个 AsycnCall 都校验它的主机是否有超过 5 个正在执行的异步请求在使用了，在满足条件的情况下，就马上会线程池去执行这个任务，以此类推，任务就这样一个一个的被执行。
总结Dispatcher流程


OkHttp源码(二（同步异步流程源码)）
文章图片
每当有新的异步Http请求（Call）到Dispatcher中的时候（call.enqueue），Dispatcher内部通过判断当前请求数是否超过最大请求数，以及当前主机请求最大数。如果条件满足就直接放入运行队列中立即执行；当不满足时（运行队列已满）就进入到就绪队列中，等运行队列有空间了，就放入运行队列进行执行。同时，当任务完成之后，调用finished中的promoteCalls方法手动的清除缓存区。

    推荐阅读


    上一篇：js结构——1

    下一篇：燕子