OkHttp這個庫有多優(yōu)秀作為Androider大家心里都明白咬扇，應該說合格的開發(fā)者都認識它。那么耸成，這里簡單看個OKHttp的接口請求姿勢：
OkHttpClient okHttpClient = new OkHttpClient();
Request request = new Request.Builder()
.url("https://www.xxxx.com/xxx/xxx/xxx")
.build();
Call call = okHttpClient.newCall(request);
//開始執(zhí)行異步接口請求
call.enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
// 這里接口請求失敗
}
@Override
public void onResponse(Call call, Response response) throws IOException {
// 這里接口請求成功
}
});
所以很明顯了弄懂了上面幾個類的是干嘛、上個幾個流程做了什么自然就明白了OKHttp的執(zhí)行流程了，那么就開始分析吧堆生。
OKHttp請求中需要的對象
Request這個類是典型的'Builder'設計模式，看一眼他的成員屬性就知道這個類是干嘛的了雷酪。
public final class Request {
final HttpUrl url;
final String method;
final Headers headers;
final @Nullable RequestBody body;
final Object tag;
.
.
.
}
看看變量名就知道了這個類封裝那些玩意淑仆，還是很愉快的完成了一小步。
OkHttpClient這個類類似個Manager類哥力，里面的成員屬性自然也比較多了蔗怠。
我們重點關注Dispatcher這個線程池屬性：
// 可以傳入線程池，從而自定義OKHttp線程池
public Dispatcher(ExecutorService executorService) {
this.executorService = executorService;
}
public Dispatcher() {
}
// 初始化線程池
public synchronized ExecutorService executorService() {
if (executorService == null) {
executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
}
return executorService;
}
所以Dispatcher就是一個線程池管理類吩跋，用于分發(fā)每一次的Http請求寞射。
Call是接口真正的實現(xiàn)類是RealCall，而RealCall有個內(nèi)部類叫AsyncCall是個接口锌钮，最終加入Dispatcher線程池的就是AsyncCall對象桥温。
執(zhí)行Http請求操作
我們從okHttpClient.newCall操作開始閱讀：
/**
* Prepares the {@code request} to be executed at some point in the future.
*/
@Override public Call newCall(Request request) {
return new RealCall(this, request, false /* for web socket */);
}
所以這里封裝了一個RealCall對象然后執(zhí)行enqueue方法，我們進入該方法看看一下代碼：
@Override public void enqueue(Callback responseCallback) {
synchronized (this) {
if (executed) throw new IllegalStateException("Already Executed");
executed = true;
}
captureCallStackTrace();
client.dispatcher().enqueue(new AsyncCall(responseCallback));
}
再看最后一行代碼會執(zhí)行Dispatcher.enqueue方法梁丘，同樣的進入看看代碼怎么執(zhí)行的：
synchronized void enqueue(AsyncCall call) {
if (runningAsyncCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) {
runningAsyncCalls.add(call);
executorService().execute(call);
} else {
readyAsyncCalls.add(call);
}
}
由于AsyncCall是實現(xiàn)了NamedRunnable接口侵浸，所以線程池就會執(zhí)行NamedRunnable.run方法，這樣子自然就執(zhí)行到AsyncCall.execute方法氛谜。
@Override protected void execute() {
boolean signalledCallback = false;
try {
Response response = getResponseWithInterceptorChain();
if (retryAndFollowUpInterceptor.isCanceled()) {
signalledCallback = true;
responseCallback.onFailure(RealCall.this, new IOException("Canceled"));
} else {
signalledCallback = true;
responseCallback.onResponse(RealCall.this, response);
}
} catch (IOException e) {
if (signalledCallback) {
// Do not signal the callback twice!
Platform.get().log(INFO, "Callback failure for " + toLoggableString(), e);
} else {
responseCallback.onFailure(RealCall.this, e);
}
} finally {
client.dispatcher().finished(this);
}
}
}
我們可以看到這里直接通過getResponseWithInterceptorChain()方法直接得到Response然后通過Callback回調(diào)數(shù)據(jù)回去掏觉。
攔截器Interceptor
通過上面我們知道已經(jīng)得到Response基本上可以說已經(jīng)結束了一個流程，這里并不細節(jié)的解釋每個攔截器的代碼值漫，只是介紹一下攔截器的調(diào)用時序澳腹，所以仍然先看一下getResponseWithInterceptorChain方法：
Response getResponseWithInterceptorChain() throws IOException {
// Build a full stack of interceptors.
List<Interceptor> interceptors = new ArrayList<>();
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));
Interceptor.Chain chain = new RealInterceptorChain(
interceptors, null, null, null, 0, originalRequest);
return chain.proceed(originalRequest);
}
我們可以看到系統(tǒng)已經(jīng)為我們定義幾個默認的攔截器，他們的作用一起調(diào)用時序如下：
這里知道了調(diào)用時序，那從什么時候觸發(fā)調(diào)用遵湖？
Interceptor.Chain chain = new RealInterceptorChain(interceptors, null, null, null, 0, originalRequest);
return chain.proceed(originalRequest);
我們可以看到是先封裝一個RealInterceptorChain對象悔政，然后執(zhí)行proceed方法自然就會執(zhí)行每一個interceptor.intercept方法。OKHttp的所有精髓之一就是攔截器的使用..
最后延旧，這里我們也可以明白一點addInterceptor / addNetworkInterceptor兩者之間有何不同了谋国，因為他們倆的調(diào)用時序不一樣。
更多攔截器的分析迁沫，將在未來找時間分析芦瘾。
