OKhttp源碼分析

版本:com.squareup.okhttp3:okhttp:3.11.0

1、call.eventListener = client.eventListenerFactory().create(call)
建立連接(tcp锄禽、tls)

2吓妆、client.dispatcher().enqueue(new AsyncCall(responseCallback));

dispatcher(): 處理線程

enqueue(..): 成立的情況下就會去讓線程管理去管理線程,讓 call 在后臺去執(zhí)行瓮钥,
如果不成立則會添加到 readyAsyncCalls 隊(duì)列中,一個(gè)待用的隊(duì)列,隨時(shí)可能發(fā)送請求

AsyncCall:會調(diào)用父類run方法中的 execute()汉匙,實(shí)現(xiàn)在 RealCall 的 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 {
          eventListener.callFailed(RealCall.this, e);
          responseCallback.onFailure(RealCall.this, e);
        }
      } finally {
        client.dispatcher().finished(this);
      }
    }
  }

3生蚁、okhttpclient配置項(xiàng)

 final Dispatcher dispatcher;線程調(diào)度管理器

  final @Nullable Proxy proxy;設(shè)置代理服務(wù)器噩翠,如果我們無法訪問或訪問失敗我們的目標(biāo)服務(wù)器,可以交給代理服務(wù)器去幫我們訪問想要訪問的目標(biāo)服務(wù)器

  final List<Protocol> protocols; 所支持的 http 協(xié)議版本

  final List<ConnectionSpec> connectionSpecs;配置使用http還是https;包括SSL和TLS版本的選擇配置
  final List<Interceptor> interceptors;
  final List<Interceptor> networkInterceptors;
  final EventListener.Factory eventListenerFactory;
  final ProxySelector proxySelector;

  final CookieJar cookieJar;cookie存儲器

  final @Nullable Cache cache;http的cache

  final @Nullable InternalCache internalCache;

  final SocketFactory socketFactory;創(chuàng)建tcp端口

  final @Nullable SSLSocketFactory sslSocketFactory;創(chuàng)建SSL端口

  final @Nullable CertificateChainCleaner certificateChainCleaner;整理服務(wù)器傳輸而來的證書

  final HostnameVerifier hostnameVerifier;用于https中邦投,驗(yàn)證對方服務(wù)器的host

  final CertificatePinner certificatePinner;做自簽名

  final Authenticator proxyAuthenticator;Head中添加Authorizaion伤锚,訪問權(quán)限配置
  final Authenticator authenticator;

  final ConnectionPool connectionPool;連接池

  final Dns dns;
  final boolean followSslRedirects;當(dāng)遇到http與https互相跳轉(zhuǎn),是否跳志衣?
  final boolean followRedirects;如果遇到需要跳轉(zhuǎn)的情況下屯援,是否去跳轉(zhuǎn),比如返回3xx念脯,默認(rèn)是true
  final boolean retryOnConnectionFailure;請求失敗狞洋,是否重新連接
  final int connectTimeout;tcp鏈接時(shí)間
  final int readTimeout;下載等待響應(yīng)時(shí)間
  final int writeTimeout;寫入響應(yīng)時(shí)間
  final int pingInterval;針對wbsocket的,多久ping一次绿店,客戶端發(fā)送ping吉懊,服務(wù)端發(fā)送pong
//自簽名
public void mySingn() {
        String hostname = "hencoder.com";
        CertificatePinner certificatePinner = new CertificatePinner.Builder()
//                .add(hostname, "sha256/AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA=")
                .add(hostname, "sha256/rZ/xwvaoWYYzhWGtTUCUNO07mHKM82JCfdvWZm1Z7nU=")
                .add(hostname, "sha256/GI75anSEdkuHj05mreE0Sd9jE6dVqUIzzXRHHlZBVbI=")
                .add(hostname, "sha256/r/mIkG3eEpVdm+u/ko/cwxzOMo1bk4TyHIlByibiA5E=")
                .build();
        OkHttpClient client = new OkHttpClient.Builder()
                .certificatePinner(certificatePinner)
                .build();

        Request request = new Request.Builder()
                .url("https://" + hostname)
                .build();
        client.newCall(request).enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.i("qqq","onFailure...");

                e.printStackTrace();
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                Log.i("qqq","onSuccess...");

            }
        });
    }

4、分析execute中的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, this, eventListener, client.connectTimeoutMillis(),
        client.readTimeoutMillis(), client.writeTimeoutMillis());

    return chain.proceed(originalRequest);
  }

作用:將準(zhǔn)備好的請求去做網(wǎng)絡(luò)請求,然后得到響應(yīng)(response)

image.png

責(zé)任鏈模式

chain.proceed 的流程如上圖借嗽。

先做請求的前置工作怕午,然后調(diào)用proceed()方法,如果proceed()方法返回成功淹魄,則會接著去做響應(yīng)后置工作郁惜;在proceed()方法執(zhí)行過程中,又會去調(diào)用下一個(gè)攔截器的請求前置工作甲锡、proceed()兆蕉、響應(yīng)后置工作。缤沦。虎韵。

client.interceptors():做攔截工作,可以在請求前做一些處理缸废,或者在請求之后做一些處理

retryAndFollowUpInterceptor:用于網(wǎng)絡(luò)的重試工作

BridgeInterceptor:封裝request和response的過濾器包蓝,各種http參數(shù)的設(shè)置,Content-Type企量、User-Agent等等

CacheInterceptor:如果已有的cache信息测萎,還在保存期內(nèi),那么就直接使用cache中的數(shù)據(jù)届巩,則不會再去做接下來的網(wǎng)絡(luò)請求

ConnectInterceptor:在該攔截器中與TCP硅瞧、HTTPS的TLS來做交互,即建立一個(gè)TCP連接或者在TCP的連接上再疊加一個(gè)TLS連接恕汇。(該攔截器沒有后置工作)

client.networkInterceptors():配置 OkHttpClient 時(shí)設(shè)置的 networkInterceptors腕唧,一般很少用,主要用 client.interceptors()

CallServerInterceptor:負(fù)責(zé)向服務(wù)器發(fā)送請求數(shù)據(jù)瘾英、從服務(wù)器讀取響應(yīng)數(shù)據(jù)(實(shí)際網(wǎng)絡(luò)請求)

image.png

優(yōu)點(diǎn):
可以看到枣接,這里首先new了一個(gè)Interceptor的ArrayList,然后分別加入了各種各樣的Interceptor缺谴,所以當(dāng)我們默認(rèn)創(chuàng)建okHttpClient時(shí)但惶,okHttp默認(rèn)會給我們實(shí)現(xiàn)這些過濾器,每個(gè)過濾器執(zhí)行不同的任務(wù)瓣赂,這個(gè)思想太屌了有木有榆骚,每個(gè)過濾器負(fù)責(zé)自己的任務(wù)片拍,各個(gè)過濾器間相互不耦合煌集,高內(nèi)聚,低耦合捌省,對拓展放開巴拉巴拉等一系列設(shè)計(jì)思想有木有苫纤,這里可以對比一下Volley源碼中的思想,Volley的處理是將緩存,網(wǎng)絡(luò)請求等一系列操作揉在一起寫卷拘,導(dǎo)致用戶對于Volley的修改只能通過修改源碼方式喊废,而修改就必須要充分閱讀理解volley整個(gè)的流程,可能一部分的修改會影響全局的流程栗弟,而這里污筷,將不同的職責(zé)的過濾器分別單獨(dú)出來,用戶只需要對關(guān)注的某一個(gè)功能項(xiàng)進(jìn)行理解乍赫,并可以進(jìn)行擴(kuò)充修改瓣蛀,一對比,okHttp在這方面的優(yōu)勢立馬體現(xiàn)出來了雷厂。這里大概先描述一下幾個(gè)過濾器的功能

面試題

1惋增、okhttp 的原理。先重定向再查緩存改鲫?請求池诈皿?

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市像棘,隨后出現(xiàn)的幾起案子稽亏,更是在濱河造成了極大的恐慌,老刑警劉巖缕题,帶你破解...
    沈念sama閱讀 216,470評論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件措左,死亡現(xiàn)場離奇詭異,居然都是意外死亡避除,警方通過查閱死者的電腦和手機(jī)怎披,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,393評論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來瓶摆,“玉大人凉逛,你說我怎么就攤上這事∪壕” “怎么了状飞?”我有些...
    開封第一講書人閱讀 162,577評論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長书斜。 經(jīng)常有香客問我诬辈,道長,這世上最難降的妖魔是什么荐吉? 我笑而不...
    開封第一講書人閱讀 58,176評論 1 292
  • 正文 為了忘掉前任焙糟,我火速辦了婚禮,結(jié)果婚禮上样屠,老公的妹妹穿的比我還像新娘穿撮。我一直安慰自己缺脉,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,189評論 6 388
  • 文/花漫 我一把揭開白布悦穿。 她就那樣靜靜地躺著攻礼,像睡著了一般。 火紅的嫁衣襯著肌膚如雪栗柒。 梳的紋絲不亂的頭發(fā)上礁扮,一...
    開封第一講書人閱讀 51,155評論 1 299
  • 那天,我揣著相機(jī)與錄音瞬沦,去河邊找鬼深员。 笑死,一個(gè)胖子當(dāng)著我的面吹牛蛙埂,可吹牛的內(nèi)容都是我干的倦畅。 我是一名探鬼主播,決...
    沈念sama閱讀 40,041評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼绣的,長吁一口氣:“原來是場噩夢啊……” “哼叠赐!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起屡江,我...
    開封第一講書人閱讀 38,903評論 0 274
  • 序言:老撾萬榮一對情侶失蹤芭概,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后惩嘉,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體罢洲,經(jīng)...
    沈念sama閱讀 45,319評論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,539評論 2 332
  • 正文 我和宋清朗相戀三年文黎,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了惹苗。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,703評論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡耸峭,死狀恐怖桩蓉,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情劳闹,我是刑警寧澤院究,帶...
    沈念sama閱讀 35,417評論 5 343
  • 正文 年R本政府宣布,位于F島的核電站本涕,受9級特大地震影響业汰,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜菩颖,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,013評論 3 325
  • 文/蒙蒙 一样漆、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧位他,春花似錦氛濒、人聲如沸产场。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,664評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至窿冯,卻和暖如春骗奖,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背醒串。 一陣腳步聲響...
    開封第一講書人閱讀 32,818評論 1 269
  • 我被黑心中介騙來泰國打工执桌, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人芜赌。 一個(gè)月前我還...
    沈念sama閱讀 47,711評論 2 368
  • 正文 我出身青樓仰挣,卻偏偏與公主長得像,于是被迫代替她去往敵國和親缠沈。 傳聞我的和親對象是個(gè)殘疾皇子膘壶,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,601評論 2 353

推薦閱讀更多精彩內(nèi)容

  • 1.okhttp源碼分析(一)——基本流程(超詳細(xì))2.okhttp源碼分析(二)——RetryAndFollow...
    被代碼淹沒的小伙子閱讀 21,827評論 9 83
  • 流程分析 我們從一個(gè)簡單的 HTTP 請求開始: 上面的代碼將會發(fā)起兩個(gè)簡單的 HTTP 請求,請求流程如下圖所示...
    張可_閱讀 890評論 0 2
  • 本文概述結(jié)合使用從源碼層面分析OkHttp的原理洲愤。 使用回顧public static String getByO...
    Horps閱讀 430評論 0 1
  • OkHttp源碼分析 在現(xiàn)在的Android開發(fā)中颓芭,請求網(wǎng)絡(luò)獲取數(shù)據(jù)基本上成了我們的標(biāo)配。在早期的Android開...
    BlackFlag閱讀 326評論 0 5
  • 如對網(wǎng)絡(luò)知識不熟悉柬赐,可跳到最后補(bǔ)一下網(wǎng)絡(luò)基礎(chǔ)文字總結(jié):先創(chuàng)建我們的request里面包括我們的Host請求參數(shù)等亡问,...
    isLJli閱讀 235評論 0 1