Request,RealCall 分析
源碼地址:https://github.com/square/okhttp
上一篇 對okHttpClient做了簡單的分析床玻,現(xiàn)在就對另外兩個比較重要的類進(jìn)行學(xué)習(xí)分析(Request, RealCall)卿捎,這兩個類是我們調(diào)用時候的請求相關(guān)的類骡苞。
這里做簡單的學(xué)習(xí)分析,便于后面流程的理解伟墙。
Request
Request這個請求類,同樣的使用了Bulider模式滴铅,不過這個比OkhttpClient簡單多了戳葵,主要用于添加請求需要的一些基本屬性。
final HttpUrl url;
final String method;
final Headers headers;
final RequestBody body;
final Object tag;
Request(Builder builder) {
this.url = builder.url;
this.method = builder.method;
this.headers = builder.headers.build();
this.body = builder.body;
this.tag = builder.tag != null ? builder.tag : this;
}
- url汉匙,傳入的String ,經(jīng)過進(jìn)一步加工處理拱烁,還有一些錯誤的判斷,最后轉(zhuǎn)換為HttpUrl的類噩翠。
- method戏自,確定請求的類型,默認(rèn)使用GET绎秒。支持http 基本的請求方式浦妄。
- headers, 我們可以自定義添加對應(yīng)的Header , 最后轉(zhuǎn)換成Header類。也可以對其中的Header進(jìn)行操作见芹。
- body剂娄,請求的實體,RequestBody 玄呛,傳輸?shù)腸ontentType阅懦,把傳輸?shù)腸ontent,進(jìn)行簡單處理徘铝。
- tag耳胎,標(biāo)簽惯吕。
RealCall
RealCall, 實現(xiàn)了Call接口,也是OkHttp里面唯一一個Call的實現(xiàn)類怕午。
1. RealCall幾個重要的變量:
final OkHttpClient client;
final RetryAndFollowUpInterceptor retryAndFollowUpInterceptor;
final Request originalRequest;
client : 在上節(jié)中已經(jīng)對其進(jìn)行介紹废登,RealCall 在構(gòu)造方法中以參數(shù)的形式傳進(jìn)來,供內(nèi)部使用郁惜。
retryAndFollowUpInterceptor : 在第一節(jié)中也做過簡單介紹堡距,是一個攔截器,處理重試兆蕉,網(wǎng)絡(luò)錯誤羽戒,取消請求,以及請求重定向的一些操作虎韵。(后面會詳細(xì)學(xué)習(xí)分析)
**originalRequest : ** 原始的請求類易稠。
2. RealCall里面有個幾個重要的方法:
execute() 同步請求
@Override
public Response execute() throws IOException {
synchronized (this) {
if (executed) throw new IllegalStateException("Already Executed");
executed = true;
}
captureCallStackTrace();
try {
client.dispatcher().executed(this);
Response result = getResponseWithInterceptorChain();
if (result == null) throw new IOException("Canceled");
return result;
} finally {
client.dispatcher().finished(this);
}
}
發(fā)起的一個同步的請求,如果重復(fù)調(diào)用會拋出異常包蓝。
captureCallStackTrace()是用來跟蹤調(diào)用棧的信息的驶社。
后面就是把這個Call 加入到client的調(diào)度器里面,進(jìn)行相應(yīng)的線程管理测萎。
最后就是調(diào)用getResponseWithInterceptorChain衬吆,這個在第一節(jié)做過分析,就是經(jīng)過一堆攔截器绳泉,然后得到結(jié)果逊抡。
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));
}
發(fā)起異步請求。如果重復(fù)調(diào)用會拋出異常零酪。
captureCallStackTrace()同樣是用來跟蹤調(diào)用棧的信息的冒嫡。
接下來,會新建一個AsyncCall四苇,這個AsyncCall其實是一個Runnable線程孝凌,簡單過一下這個AsyncCall的代碼:
final class AsyncCall extends NamedRunnable {
// 回調(diào)
private final Callback responseCallback;
AsyncCall(Callback responseCallback) {
super("OkHttp %s", redactedUrl());
this.responseCallback = responseCallback;
}
String host() {
return originalRequest.url().host();
}
Request request() {
return originalRequest;
}
RealCall get() {
return RealCall.this;
}
//run的時候調(diào)用的方法
@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);
}
}
}
在execute的調(diào)用中,其實和同步調(diào)用時一樣的月腋,只是這個是在異步線程中進(jìn)行蟀架。
最后這個新建的AsyncCall ,同樣會通過client 添加到dispatcher當(dāng)中,但是值得注意的是榆骚,同步和異步片拍,其實是添加到dispatcher不同的List當(dāng)中,進(jìn)行管理的妓肢。
getResponseWithInterceptorChain()
調(diào)用一系列的攔截器捌省,得到最終的結(jié)果,在第一節(jié)中對此做過解析碉钠,可以參考第一節(jié)最后的部分纲缓。這里就不做過多的說明卷拘,具體每個攔截器的作用,在后面會做學(xué)習(xí)分析祝高。
cancel()
調(diào)用里面比較簡單栗弟,就是通過retryAndFollowUpInterceptor這個攔截器去對請求進(jìn)行取消。對于正在執(zhí)行的call 進(jìn)行取消工闺,但是對于已經(jīng)是在讀寫數(shù)據(jù)階段的請求無法取消横腿,而且會拋出異常。
@Override public void cancel() {
retryAndFollowUpInterceptor.cancel();
}
總結(jié)
Request和RealCall, 在發(fā)起請求階段斤寂,是兩個重要的類。Request主要是接收了調(diào)用者的數(shù)據(jù)并進(jìn)行加工處理揪惦;RealCall主要提供方法遍搞,進(jìn)行同步或者異步的調(diào)用請求,還有就是取消請求的方法器腋。
對于okhttp的整體以及前期的初始化的一些類也有所了解溪猿,接下來就是對每個攔截器進(jìn)行解剖學(xué)習(xí)了。
系列:
OKhttp源碼學(xué)習(xí)(一)—— 基本請求流程
OKhttp源碼學(xué)習(xí)(二)—— OkHttpClient
OKhttp源碼學(xué)習(xí)(四)——RetryAndFollowUpInterceptor攔截器分析
OKhttp源碼學(xué)習(xí)(五)—— BridgeInterceptor
OKhttp源碼學(xué)習(xí)(六)—— CacheInterceptor攔截器
OKhttp源碼學(xué)習(xí)(七)—— ConnectInterceptor攔截器
OKhttp源碼學(xué)習(xí)(八)——CallServerInterceptor攔截器
OKhttp源碼學(xué)習(xí)(九)—— 任務(wù)管理(Dispatcher)