retrofit源碼分析

//分析1
 Retrofit build = new Retrofit.Builder().baseUrl("xxxxxxx")
                .addConverterFactory(GsonConverterFactory.create())
                .build();



//分析2
        ServiceDemo serviceDemo = build.create(ServiceDemo.class);

//分析3
        Call string = serviceDemo.getString("111", "222");

//分析4
        string.enqueue(new Callback() {
            @Override
            public void onResponse(Call call, Response response) {

            }

            @Override
            public void onFailure(Call call, Throwable t) {

            }
        });

分析1

創(chuàng)建retrofit 是使用建造者模式建造者模式

可以設(shè)置的參數(shù)很多,列舉幾個(gè)。


角色 作用 備注
converterFactory 格式轉(zhuǎn)換工廠 支持gson json xml
callAdapterFactory 網(wǎng)絡(luò)請(qǐng)求適配器工廠 ExecutorCalladapter(默認(rèn))彭雾、RxJava2CallAdapterFactory
client 網(wǎng)絡(luò)請(qǐng)求所使用的具體okhttp對(duì)象 可以用來(lái)設(shè)置超時(shí)時(shí)間等等一系列okhttp的屬性
callBackExecutor 用于做線程切換

分析2

public <T> T create(final Class<T> service) {
    Utils.validateServiceInterface(service);
    if (validateEagerly) {
      eagerlyValidateMethods(service);
    }
    return (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[] { service },
        new InvocationHandler() {
          private final Platform platform = Platform.get();

          @Override public Object invoke(Object proxy, Method method, @Nullable Object[] args)
              throws Throwable {
            // If the method is a method from Object then defer to normal invocation.
            if (method.getDeclaringClass() == Object.class) {
              return method.invoke(this, args);
            }
            if (platform.isDefaultMethod(method)) {
              return platform.invokeDefaultMethod(method, service, proxy, args);
            }
            ServiceMethod<Object, Object> serviceMethod =
                (ServiceMethod<Object, Object>) loadServiceMethod(method);
            OkHttpCall<Object> okHttpCall = new OkHttpCall<>(serviceMethod, args);
            return serviceMethod.callAdapter.adapt(okHttpCall);
          }
        });
  }

可以看到這里使用的是java的動(dòng)態(tài)代理滞谢。這里是retrofit的核心串稀。通過(guò)動(dòng)態(tài)代理,可以輕易拿到Method狮杨,進(jìn)而讀取Method的注解母截。

動(dòng)態(tài)代理,在運(yùn)行時(shí)動(dòng)態(tài)的創(chuàng)建代理類橄教,這個(gè)類就是Proxy類清寇,調(diào)用Proxy類的方法都會(huì)調(diào)用InvacationHandler的invoke方法。

先判斷這個(gè)方法的類护蝶,如果是object华烟,直接調(diào)用。
Platform:對(duì)不同的平臺(tái)持灰,有不同的行為盔夜。
ServiceMethod:把接口中的方法適配為符合http的call

分析3

實(shí)際就會(huì)調(diào)用

@Override public Object invoke(Object proxy, Method method, @Nullable Object[] args)
              throws Throwable {
            // If the method is a method from Object then defer to normal invocation.
            if (method.getDeclaringClass() == Object.class) {
              return method.invoke(this, args);
            }
            if (platform.isDefaultMethod(method)) {
              return platform.invokeDefaultMethod(method, service, proxy, args);
            }
            ServiceMethod<Object, Object> serviceMethod =
                (ServiceMethod<Object, Object>) loadServiceMethod(method);
            OkHttpCall<Object> okHttpCall = new OkHttpCall<>(serviceMethod, args);
            return serviceMethod.callAdapter.adapt(okHttpCall);
          }
        });

我們要詳細(xì)分析

ServiceMethod<Object, Object> serviceMethod =
                (ServiceMethod<Object, Object>) loadServiceMethod(method);
            OkHttpCall<Object> okHttpCall = new OkHttpCall<>(serviceMethod, args);
            return serviceMethod.callAdapter.adapt(okHttpCall);

  ServiceMethod<?, ?> loadServiceMethod(Method method) {
    ServiceMethod<?, ?> result = serviceMethodCache.get(method);
    if (result != null) return result;

    synchronized (serviceMethodCache) {
      result = serviceMethodCache.get(method);
      if (result == null) {
        result = new ServiceMethod.Builder<>(this, method).build();
        serviceMethodCache.put(method, result);
      }
    }
    return result;
  }

key = method,value = ServiceMethod堤魁。用來(lái)存儲(chǔ)的是CorrentHashMap喂链。我們要進(jìn)而認(rèn)識(shí)一下什么是ServiceMethod,簡(jiǎn)而言之就是解析Method,存儲(chǔ)網(wǎng)絡(luò)請(qǐng)求的數(shù)據(jù)妥泉。什么是okHttpCall椭微。

ParameterHandler 方法參數(shù)處理器

 public ServiceMethod build() {
      callAdapter = createCallAdapter();
      responseType = callAdapter.responseType();
      if (responseType == Response.class || responseType == okhttp3.Response.class) {
        throw methodError("'"
            + Utils.getRawType(responseType).getName()
            + "' is not a valid response body type. Did you mean ResponseBody?");
      }
      responseConverter = createResponseConverter();

CallAdapter<?, ?> adapter = adapterFactories.get(i).get(returnType, annotations, this);
Executor callbackExecutor = this.callbackExecutor;
      if (callbackExecutor == null) {
        callbackExecutor = platform.defaultCallbackExecutor();
      }

      // Make a defensive copy of the adapters and add the default Call adapter.
      List<CallAdapter.Factory> adapterFactories = new ArrayList<>(this.adapterFactories);
      adapterFactories.add(platform.defaultCallAdapterFactory(callbackExecutor));
 static class Android extends Platform {
    @Override public Executor defaultCallbackExecutor() {
      return new MainThreadExecutor();
    }

    @Override CallAdapter.Factory defaultCallAdapterFactory(@Nullable Executor callbackExecutor) {
      if (callbackExecutor == null) throw new AssertionError();
      return new ExecutorCallAdapterFactory(callbackExecutor);
    }

    static class MainThreadExecutor implements Executor {
      private final Handler handler = new Handler(Looper.getMainLooper());

      @Override public void execute(Runnable r) {
        handler.post(r);
      }
    }
  }
final class ExecutorCallAdapterFactory extends CallAdapter.Factory {
  final Executor callbackExecutor;

  ExecutorCallAdapterFactory(Executor callbackExecutor) {
    this.callbackExecutor = callbackExecutor;
  }

  @Override
  public CallAdapter<?, ?> get(Type returnType, Annotation[] annotations, Retrofit retrofit) {
    if (getRawType(returnType) != Call.class) {
      return null;
    }
    final Type responseType = Utils.getCallResponseType(returnType);
    return new CallAdapter<Object, Call<?>>() {
      @Override public Type responseType() {
        return responseType;
      }

      @Override public Call<Object> adapt(Call<Object> call) {
        return new ExecutorCallbackCall<>(callbackExecutor, call);
      }
    };
  }

  static final class ExecutorCallbackCall<T> implements Call<T> {
    final Executor callbackExecutor;
    final Call<T> delegate;

    ExecutorCallbackCall(Executor callbackExecutor, Call<T> delegate) {
      this.callbackExecutor = callbackExecutor;
      this.delegate = delegate;
    }

    @Override public void enqueue(final Callback<T> callback) {
      checkNotNull(callback, "callback == null");

      delegate.enqueue(new Callback<T>() {
        @Override public void onResponse(Call<T> call, final Response<T> response) {
          callbackExecutor.execute(new Runnable() {
            @Override public void run() {
              if (delegate.isCanceled()) {
                // Emulate OkHttp's behavior of throwing/delivering an IOException on cancellation.
                callback.onFailure(ExecutorCallbackCall.this, new IOException("Canceled"));
              } else {
                callback.onResponse(ExecutorCallbackCall.this, response);
              }
            }
          });
        }

        @Override public void onFailure(Call<T> call, final Throwable t) {
          callbackExecutor.execute(new Runnable() {
            @Override public void run() {
              callback.onFailure(ExecutorCallbackCall.this, t);
            }
          });
        }
      });
    }

    @Override public boolean isExecuted() {
      return delegate.isExecuted();
    }

    @Override public Response<T> execute() throws IOException {
      return delegate.execute();
    }

    @Override public void cancel() {
      delegate.cancel();
    }

    @Override public boolean isCanceled() {
      return delegate.isCanceled();
    }

    @SuppressWarnings("CloneDoesntCallSuperClone") // Performing deep clone.
    @Override public Call<T> clone() {
      return new ExecutorCallbackCall<>(callbackExecutor, delegate.clone());
    }

    @Override public Request request() {
      return delegate.request();
    }
  }
}

ServiceMethod<Object, Object> serviceMethod =
                (ServiceMethod<Object, Object>) loadServiceMethod(method);
            OkHttpCall<Object> okHttpCall = new OkHttpCall<>(serviceMethod, args);
            return serviceMethod.callAdapter.adapt(okHttpCall);

okhttpcall:真正執(zhí)行okhttp的call。創(chuàng)建ServiceMethod時(shí)創(chuàng)建了一個(gè)CallAdapter的實(shí)例盲链。CallAdapter是一個(gè)接口蝇率。在ExecutorCallAdapterFactory中創(chuàng)建了這個(gè)實(shí)例。ExecutorCallAdapterFactory是在platfrom中創(chuàng)建的匈仗,創(chuàng)建時(shí)傳入了一個(gè)MainThreadExecutor用來(lái)做線程切換瓢剿。CallAdapter.adapt時(shí),返回了一個(gè)okhttpcall的代理對(duì)象悠轩,這個(gè)對(duì)象中包括了一個(gè)MainThreadExecutor 和okhttpcall。代理的作用是做線程的切換攻泼。

看完源碼:發(fā)現(xiàn)了retrofit的核心是動(dòng)態(tài)代理火架。底層使用okhttp。動(dòng)態(tài)代理的好處是可以輕易拿到Method忙菠,我們通過(guò)注解去設(shè)置和配置的數(shù)據(jù)何鸡,通過(guò)讀取Method讀取每個(gè)方法的注解,參數(shù)的注解牛欢。去配置網(wǎng)絡(luò)請(qǐng)求參數(shù)骡男,然后封裝成okttpcall去做網(wǎng)絡(luò)請(qǐng)求。

讀到這里傍睹,retrofit的機(jī)制大概已經(jīng)明白了隔盛。那么okhttp又做了什么犹菱。還要讀okhttp的源碼。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末吮炕,一起剝皮案震驚了整個(gè)濱河市腊脱,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌龙亲,老刑警劉巖陕凹,帶你破解...
    沈念sama閱讀 219,490評(píng)論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異鳄炉,居然都是意外死亡杜耙,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,581評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門拂盯,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)佑女,“玉大人,你說(shuō)我怎么就攤上這事磕仅∩罕” “怎么了?”我有些...
    開(kāi)封第一講書(shū)人閱讀 165,830評(píng)論 0 356
  • 文/不壞的土叔 我叫張陵榕订,是天一觀的道長(zhǎng)店茶。 經(jīng)常有香客問(wèn)我,道長(zhǎng)劫恒,這世上最難降的妖魔是什么贩幻? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,957評(píng)論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮两嘴,結(jié)果婚禮上丛楚,老公的妹妹穿的比我還像新娘。我一直安慰自己憔辫,他們只是感情好趣些,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,974評(píng)論 6 393
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著贰您,像睡著了一般坏平。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上锦亦,一...
    開(kāi)封第一講書(shū)人閱讀 51,754評(píng)論 1 307
  • 那天舶替,我揣著相機(jī)與錄音,去河邊找鬼杠园。 笑死顾瞪,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播陈醒,決...
    沈念sama閱讀 40,464評(píng)論 3 420
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼惕橙,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了孵延?” 一聲冷哼從身側(cè)響起吕漂,我...
    開(kāi)封第一講書(shū)人閱讀 39,357評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎尘应,沒(méi)想到半個(gè)月后惶凝,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,847評(píng)論 1 317
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡犬钢,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,995評(píng)論 3 338
  • 正文 我和宋清朗相戀三年苍鲜,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片玷犹。...
    茶點(diǎn)故事閱讀 40,137評(píng)論 1 351
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡混滔,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出歹颓,到底是詐尸還是另有隱情坯屿,我是刑警寧澤,帶...
    沈念sama閱讀 35,819評(píng)論 5 346
  • 正文 年R本政府宣布巍扛,位于F島的核電站领跛,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏撤奸。R本人自食惡果不足惜吠昭,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,482評(píng)論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望胧瓜。 院中可真熱鬧矢棚,春花似錦、人聲如沸府喳。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 32,023評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)钝满。三九已至肉津,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間舱沧,已是汗流浹背。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,149評(píng)論 1 272
  • 我被黑心中介騙來(lái)泰國(guó)打工偶洋, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留熟吏,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 48,409評(píng)論 3 373
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像牵寺,于是被迫代替她去往敵國(guó)和親悍引。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,086評(píng)論 2 355

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

  • ??今天我來(lái)記錄一下我對(duì)Retrofit框架的理解帽氓。不得不說(shuō)趣斤,Retrofit的架構(gòu)設(shè)計(jì)極其優(yōu)秀,既保證了使用上的...
    瓊珶和予閱讀 3,838評(píng)論 0 21
  • 最近非常流行 Retrofit+RxJava+OkHttp 這一整套的網(wǎng)絡(luò)請(qǐng)求和異步操作的開(kāi)源框架黎休,從 Jake ...
    慌不要慌閱讀 1,974評(píng)論 1 7
  • Retrofit Version:2.2.0分析代碼地址:https://github.com/Blankeer/...
    Blankeer閱讀 223評(píng)論 0 1
  • 我在半年前才開(kāi)始接觸 Retrofit浓领,在那個(gè)時(shí)候這個(gè)框架已經(jīng)很火了。作為入門學(xué)習(xí)势腮,簡(jiǎn)單梳理了一下寫(xiě)成一篇文章联贩。有...
    龐哈哈哈12138閱讀 138評(píng)論 0 1
  • 我也不知道該怎么定義自己,在我眼里自己還算是一個(gè)比較成功的例子吧捎拯,因?yàn)槲乙呀?jīng)得到了我想要的泪幌,做到了自己當(dāng)...
    生活比夢(mèng)更浪漫閱讀 296評(píng)論 0 10