Carson帶你學(xué)Android:手把手帶你深入讀懂Retrofit 2.0源碼


前言

  • Android開發(fā)中炫彩,網(wǎng)絡(luò)請(qǐng)求十分常用
  • 而在Android網(wǎng)絡(luò)請(qǐng)求庫中,Retrofit是當(dāng)下最熱的一個(gè)網(wǎng)絡(luò)請(qǐng)求庫
Github截圖
  • 今天斯够,我將手把手帶你深入剖析Retrofit v2.0的源碼囚玫,希望你們會(huì)喜歡
  1. 請(qǐng)盡量在PC端而不要在移動(dòng)端看,否則圖片可能看不清读规。
  2. 在閱讀本文前抓督,建議先閱讀文章:這是一份很詳細(xì)的 Retrofit 2.0 使用教程(含實(shí)例講解)
    Carson帶你學(xué)Android開源庫系列文章:
    Carson帶你學(xué)Android:主流開源圖片加載庫對(duì)比(UIL、Picasso掖桦、Glide本昏、Fresco)
    Carson帶你學(xué)Android:主流開源網(wǎng)絡(luò)請(qǐng)求庫對(duì)比(Volley涌穆、OkHttp、Retrofit)
    Carson帶你學(xué)Android:網(wǎng)絡(luò)請(qǐng)求庫Retrofit使用教程
    Carson帶你學(xué)Android:網(wǎng)絡(luò)請(qǐng)求庫Retrofit源碼分析
    Carson帶你學(xué)Android:圖片加載庫Glide使用教程
    Carson帶你學(xué)Android:圖片加載庫Glide源碼分析
    Carson帶你學(xué)Android:V-Layout押框,淘寶忘伞、天貓都在用的UI框架,趕緊用起來吧胞皱!

目錄

目錄

1. 簡介

示意圖

特別注意:

  • 準(zhǔn)確來說邪意,Retrofit 是一個(gè) RESTful 的 HTTP 網(wǎng)絡(luò)請(qǐng)求框架的封裝。
  • 原因:網(wǎng)絡(luò)請(qǐng)求的工作本質(zhì)上是 OkHttp 完成反砌,而 Retrofit 僅負(fù)責(zé) 網(wǎng)絡(luò)請(qǐng)求接口的封裝
流程圖
  • App應(yīng)用程序通過 Retrofit 請(qǐng)求網(wǎng)絡(luò)雾鬼,實(shí)際上是使用 Retrofit 接口層封裝請(qǐng)求參數(shù)、Header宴树、Url 等信息策菜,之后由 OkHttp 完成后續(xù)的請(qǐng)求操作
  • 在服務(wù)端返回?cái)?shù)據(jù)之后,OkHttp 將原始的結(jié)果交給 Retrofit酒贬,Retrofit根據(jù)用戶的需求對(duì)結(jié)果進(jìn)行解析

2. 與其他網(wǎng)絡(luò)請(qǐng)求開源庫對(duì)比

除了Retrofit又憨,如今Android中主流的網(wǎng)絡(luò)請(qǐng)求框架有:

  • Android-Async-Http
  • Volley
  • OkHttp

下面是簡單介紹:

網(wǎng)絡(luò)請(qǐng)求加載 - 介紹

一圖讓你了解全部的網(wǎng)絡(luò)請(qǐng)求庫和他們之間的區(qū)別!

網(wǎng)絡(luò)請(qǐng)求庫 - 對(duì)比

附:各個(gè)主流網(wǎng)絡(luò)請(qǐng)求庫的Github地址


3. Retrofit 的具體使用

具體請(qǐng)看我寫的文章:這是一份很詳細(xì)的 Retrofit 2.0 使用教程(含實(shí)例講解)


4. 源碼分析

4.1 Retrofit的本質(zhì)流程

一般從網(wǎng)絡(luò)通信過程如下圖:

網(wǎng)絡(luò)請(qǐng)求的過程
  • 其實(shí)Retrofit的本質(zhì)和上面是一樣的套路
  • 只是Retrofit通過使用大量的設(shè)計(jì)模式進(jìn)行功能模塊的解耦同衣,使得上面的過程進(jìn)行得更加簡單 & 流暢

如下圖:

Retrofit的本質(zhì)

具體過程解釋如下:

  1. 通過解析 網(wǎng)絡(luò)請(qǐng)求接口的注解 配置 網(wǎng)絡(luò)請(qǐng)求參數(shù)
  2. 通過 動(dòng)態(tài)代理 生成 網(wǎng)絡(luò)請(qǐng)求對(duì)象
  3. 通過 網(wǎng)絡(luò)請(qǐng)求適配器 將 網(wǎng)絡(luò)請(qǐng)求對(duì)象 進(jìn)行平臺(tái)適配

平臺(tái)包括:Android竟块、Rxjava、Guava和java8

  1. 通過 網(wǎng)絡(luò)請(qǐng)求執(zhí)行器 發(fā)送網(wǎng)絡(luò)請(qǐng)求
  2. 通過 數(shù)據(jù)轉(zhuǎn)換器 解析服務(wù)器返回的數(shù)據(jù)
  3. 通過 回調(diào)執(zhí)行器 切換線程(子線程 ->>主線程)
  4. 用戶在主線程處理返回結(jié)果

下面介紹上面提到的幾個(gè)角色

角色說明

特別注意:因下面的 源碼分析 是根據(jù) 使用步驟 逐步帶你debug進(jìn)去的耐齐,所以必須先看文章這是一份很詳細(xì)的 Retrofit 2.0 使用教程(含實(shí)例講解)

4.2 源碼分析

先來回憶Retrofit的使用步驟:

  1. 創(chuàng)建Retrofit實(shí)例
  2. 創(chuàng)建 網(wǎng)絡(luò)請(qǐng)求接口實(shí)例 并 配置網(wǎng)絡(luò)請(qǐng)求參數(shù)
  3. 發(fā)送網(wǎng)絡(luò)請(qǐng)求

封裝了 數(shù)據(jù)轉(zhuǎn)換浪秘、線程切換的操作

  1. 處理服務(wù)器返回的數(shù)據(jù)

4.2.1 創(chuàng)建Retrofit實(shí)例

a. 使用步驟

 Retrofit retrofit = new Retrofit.Builder()
                                 .baseUrl("http://fanyi.youdao.com/")
                                 .addConverterFactory(GsonConverterFactory.create())
                                 .build();

b. 源碼分析

Retrofit實(shí)例是使用建造者模式通過Builder類進(jìn)行創(chuàng)建的

建造者模式:將一個(gè)復(fù)雜對(duì)象的構(gòu)建與表示分離,使得用戶在不知道對(duì)象的創(chuàng)建細(xì)節(jié)情況下就可以直接創(chuàng)建復(fù)雜的對(duì)象埠况。具體請(qǐng)看文章:建造者模式(Builder Pattern)- 最易懂的設(shè)計(jì)模式解析

接下來耸携,我將分五個(gè)步驟對(duì)創(chuàng)建Retrofit實(shí)例進(jìn)行逐步分析

分析步驟

步驟1

步驟1
<-- Retrofit類 -->
 public final class Retrofit {
  
  private final Map<Method, ServiceMethod> serviceMethodCache = new LinkedHashMap<>();
  // 網(wǎng)絡(luò)請(qǐng)求配置對(duì)象(對(duì)網(wǎng)絡(luò)請(qǐng)求接口中方法注解進(jìn)行解析后得到的對(duì)象)
  // 作用:存儲(chǔ)網(wǎng)絡(luò)請(qǐng)求相關(guān)的配置,如網(wǎng)絡(luò)請(qǐng)求的方法辕翰、數(shù)據(jù)轉(zhuǎn)換器夺衍、網(wǎng)絡(luò)請(qǐng)求適配器、網(wǎng)絡(luò)請(qǐng)求工廠喜命、基地址等
  
  private final HttpUrl baseUrl;
  // 網(wǎng)絡(luò)請(qǐng)求的url地址

  private final okhttp3.Call.Factory callFactory;
  // 網(wǎng)絡(luò)請(qǐng)求器的工廠
  // 作用:生產(chǎn)網(wǎng)絡(luò)請(qǐng)求器(Call)
  // Retrofit是默認(rèn)使用okhttp
  
   private final List<CallAdapter.Factory> adapterFactories;
  // 網(wǎng)絡(luò)請(qǐng)求適配器工廠的集合
  // 作用:放置網(wǎng)絡(luò)請(qǐng)求適配器工廠
  // 網(wǎng)絡(luò)請(qǐng)求適配器工廠作用:生產(chǎn)網(wǎng)絡(luò)請(qǐng)求適配器(CallAdapter)
  // 下面會(huì)詳細(xì)說明


  private final List<Converter.Factory> converterFactories;
  // 數(shù)據(jù)轉(zhuǎn)換器工廠的集合
  // 作用:放置數(shù)據(jù)轉(zhuǎn)換器工廠
  // 數(shù)據(jù)轉(zhuǎn)換器工廠作用:生產(chǎn)數(shù)據(jù)轉(zhuǎn)換器(converter)

  private final Executor callbackExecutor;
  // 回調(diào)方法執(zhí)行器

private final boolean validateEagerly; 
// 標(biāo)志位
// 作用:是否提前對(duì)業(yè)務(wù)接口中的注解進(jìn)行驗(yàn)證轉(zhuǎn)換的標(biāo)志位


<-- Retrofit類的構(gòu)造函數(shù) -->
Retrofit(okhttp3.Call.Factory callFactory, HttpUrl baseUrl,  
      List<Converter.Factory> converterFactories, List<CallAdapter.Factory> adapterFactories,  
      Executor callbackExecutor, boolean validateEagerly) {  
    this.callFactory = callFactory;  
    this.baseUrl = baseUrl;  
    this.converterFactories = unmodifiableList(converterFactories); 
    this.adapterFactories = unmodifiableList(adapterFactories);   
    // unmodifiableList(list)近似于UnmodifiableList<E>(list)
    // 作用:創(chuàng)建的新對(duì)象能夠?qū)ist數(shù)據(jù)進(jìn)行訪問沟沙,但不可通過該對(duì)象對(duì)list集合中的元素進(jìn)行修改
    this.callbackExecutor = callbackExecutor;  
    this.validateEagerly = validateEagerly;  
  ...
  // 僅貼出關(guān)鍵代碼
}

成功建立一個(gè)Retrofit對(duì)象的標(biāo)準(zhǔn):配置好Retrofit類里的成員變量,即配置好:

  • serviceMethod:包含所有網(wǎng)絡(luò)請(qǐng)求信息的對(duì)象
  • baseUrl:網(wǎng)絡(luò)請(qǐng)求的url地址
  • callFactory:網(wǎng)絡(luò)請(qǐng)求工廠
  • adapterFactories:網(wǎng)絡(luò)請(qǐng)求適配器工廠的集合
  • converterFactories:數(shù)據(jù)轉(zhuǎn)換器工廠的集合
  • callbackExecutor:回調(diào)方法執(zhí)行器

所謂xxxFactory壁榕、“xxx工廠”其實(shí)是設(shè)計(jì)模式中工廠模式的體現(xiàn):將“類實(shí)例化的操作”與“使用對(duì)象的操作”分開矛紫,使得使用者不用知道具體參數(shù)就可以實(shí)例化出所需要的“產(chǎn)品”類。

具體請(qǐng)看我寫的文章
簡單工廠模式(SimpleFactoryPattern)- 最易懂的設(shè)計(jì)模式解析
工廠方法模式(Factory Method)- 最易懂的設(shè)計(jì)模式解析
抽象工廠模式(Abstract Factory)- 最易懂的設(shè)計(jì)模式解析

這里詳細(xì)介紹一下:CallAdapterFactory:該Factory生產(chǎn)的是CallAdapter牌里,那么CallAdapter又是什么呢颊咬?

CallAdapter詳細(xì)介紹

  • 定義:網(wǎng)絡(luò)請(qǐng)求執(zhí)行器(Call)的適配器
  1. Call在Retrofit里默認(rèn)是OkHttpCall
  2. 在Retrofit中提供了四種CallAdapterFactory: ExecutorCallAdapterFactory(默認(rèn))、GuavaCallAdapterFactory、Java8CallAdapterFactory喳篇、RxJavaCallAdapterFactory
  • 作用:將默認(rèn)的網(wǎng)絡(luò)請(qǐng)求執(zhí)行器(OkHttpCall)轉(zhuǎn)換成適合被不同平臺(tái)來調(diào)用的網(wǎng)絡(luò)請(qǐng)求執(zhí)行器形式
  1. 如:一開始Retrofit只打算利用OkHttpCall通過ExecutorCallbackCall切換線程敞临;但后來發(fā)現(xiàn)使用Rxjava更加方便(不需要Handler來切換線程)。想要實(shí)現(xiàn)Rxjava的情況麸澜,那就得使用RxJavaCallAdapterFactoryCallAdapterOkHttpCall轉(zhuǎn)換成Rxjava(Scheduler)
// 把response封裝成rxjava的Observeble挺尿,然后進(jìn)行流式操作
Retrofit.Builder.addCallAdapterFactory(newRxJavaCallAdapterFactory().create()); 
// 關(guān)于RxJava的使用這里不作更多的展開
  1. Retrofit還支持java8、Guava平臺(tái)痰憎。
  • 好處:用最小代價(jià)兼容更多平臺(tái)票髓,即能適配更多的使用場景

所以,接下來需要分析的步驟2铣耘、步驟3洽沟、步驟4、步驟4的目的是配置好上述所有成員變量

步驟2

步驟2

我們先來看Builder類

請(qǐng)按下面提示的步驟進(jìn)行查看

<-- Builder類-->
public static final class Builder {
    private Platform platform;
    private okhttp3.Call.Factory callFactory;
    private HttpUrl baseUrl;
    private List<Converter.Factory> converterFactories = new ArrayList<>();
    private List<CallAdapter.Factory> adapterFactories = new ArrayList<>();
    private Executor callbackExecutor;
    private boolean validateEagerly;

// 從上面可以發(fā)現(xiàn)蜗细, Builder類的成員變量與Retrofit類的成員變量是對(duì)應(yīng)的
// 所以Retrofit類的成員變量基本上是通過Builder類進(jìn)行配置
// 開始看步驟1

<-- 步驟1 -->
// Builder的構(gòu)造方法(無參)
 public Builder() {
      this(Platform.get());
// 用this調(diào)用自己的有參構(gòu)造方法public Builder(Platform platform) ->>步驟5(看完步驟2裆操、3、4再看)
// 并通過調(diào)用Platform.get()傳入了Platform對(duì)象
// 繼續(xù)看Platform.get()方法 ->>步驟2
// 記得最后繼續(xù)看步驟5的Builder有參構(gòu)造方法
    }
...
}

<-- 步驟2 -->
class Platform {

  private static final Platform PLATFORM = findPlatform();
  // 將findPlatform()賦給靜態(tài)變量

  static Platform get() {
    return PLATFORM;    
    // 返回靜態(tài)變量PLATFORM炉媒,即findPlatform() ->>步驟3
  }

<-- 步驟3 -->
private static Platform findPlatform() {
    try {

      Class.forName("android.os.Build");
      // Class.forName(xxx.xx.xx)的作用:要求JVM查找并加載指定的類(即JVM會(huì)執(zhí)行該類的靜態(tài)代碼段)
      if (Build.VERSION.SDK_INT != 0) {
        return new Android(); 
        // 此處表示:如果是Android平臺(tái)踪区,就創(chuàng)建并返回一個(gè)Android對(duì)象 ->>步驟4
      }
    } catch (ClassNotFoundException ignored) {
    }

    try {
      // 支持Java平臺(tái)
      Class.forName("java.util.Optional");
      return new Java8();
    } catch (ClassNotFoundException ignored) {
    }

    try {
      // 支持iOS平臺(tái)
      Class.forName("org.robovm.apple.foundation.NSObject");
      return new IOS();
    } catch (ClassNotFoundException ignored) {
    }

// 從上面看出:Retrofit2.0支持3個(gè)平臺(tái):Android平臺(tái)、Java平臺(tái)吊骤、IOS平臺(tái)
// 最后返回一個(gè)Platform對(duì)象(指定了Android平臺(tái))給Builder的有參構(gòu)造方法public Builder(Platform platform)  --> 步驟5
// 說明Builder指定了運(yùn)行平臺(tái)為Android
    return new Platform();
  }
...
}

<-- 步驟4 -->
// 用于接收服務(wù)器返回?cái)?shù)據(jù)后進(jìn)行線程切換在主線程顯示結(jié)果

static class Android extends Platform {

    @Override
      CallAdapter.Factory defaultCallAdapterFactory(Executor callbackExecutor) {

      return new ExecutorCallAdapterFactory(callbackExecutor);
    // 創(chuàng)建默認(rèn)的網(wǎng)絡(luò)請(qǐng)求適配器工廠
    // 該默認(rèn)工廠生產(chǎn)的 adapter 會(huì)使得Call在異步調(diào)用時(shí)在指定的 Executor 上執(zhí)行回調(diào)
    // 在Retrofit中提供了四種CallAdapterFactory: ExecutorCallAdapterFactory(默認(rèn))缎岗、GuavaCallAdapterFactory、Java8CallAdapterFactory、RxJavaCallAdapterFactory
    // 采用了策略模式
    
    }

    @Override 
      public Executor defaultCallbackExecutor() {
      // 返回一個(gè)默認(rèn)的回調(diào)方法執(zhí)行器
      // 該執(zhí)行器作用:切換線程(子->>主線程),并在主線程(UI線程)中執(zhí)行回調(diào)方法
      return new MainThreadExecutor();
    }

    static class MainThreadExecutor implements Executor {
   
      private final Handler handler = new Handler(Looper.getMainLooper());
      // 獲取與Android 主線程綁定的Handler 

      @Override 
      public void execute(Runnable r) {
        
        
        handler.post(r);
        // 該Handler是上面獲取的與Android 主線程綁定的Handler 
        // 在UI線程進(jìn)行對(duì)網(wǎng)絡(luò)請(qǐng)求返回?cái)?shù)據(jù)處理等操作甘萧。
      }
    }

// 切換線程的流程:
// 1. 回調(diào)ExecutorCallAdapterFactory生成了一個(gè)ExecutorCallbackCall對(duì)象
//2. 通過調(diào)用ExecutorCallbackCall.enqueue(CallBack)從而調(diào)用MainThreadExecutor的execute()通過handler切換到主線程
  }

// 下面繼續(xù)看步驟5的Builder有參構(gòu)造方法
<-- 步驟5 -->
//  Builder類的構(gòu)造函數(shù)2(有參)
  public  Builder(Platform platform) {

  // 接收Platform對(duì)象(Android平臺(tái))
      this.platform = platform;

// 通過傳入BuiltInConverters()對(duì)象配置數(shù)據(jù)轉(zhuǎn)換器工廠(converterFactories)

// converterFactories是一個(gè)存放數(shù)據(jù)轉(zhuǎn)換器Converter.Factory的數(shù)組
// 配置converterFactories即配置里面的數(shù)據(jù)轉(zhuǎn)換器
      converterFactories.add(new BuiltInConverters());

// BuiltInConverters是一個(gè)內(nèi)置的數(shù)據(jù)轉(zhuǎn)換器工廠(繼承Converter.Factory類)
// new BuiltInConverters()是為了初始化數(shù)據(jù)轉(zhuǎn)換器
    }

對(duì)Builder類分析完畢诀浪,總結(jié):Builder設(shè)置了默認(rèn)的

  • 平臺(tái)類型對(duì)象:Android
  • 網(wǎng)絡(luò)請(qǐng)求適配器工廠:CallAdapterFactory

CallAdapter用于對(duì)原始Call進(jìn)行再次封裝粱坤,如Call<R>到Observable<R>

  • 數(shù)據(jù)轉(zhuǎn)換器工廠: converterFactory
  • 回調(diào)執(zhí)行器:callbackExecutor

特別注意,這里只是設(shè)置了默認(rèn)值,但未真正配置到具體的Retrofit類的成員變量當(dāng)中

步驟3

步驟3

還是按部就班按步驟來觀看

<-- 步驟1 -->
public Builder baseUrl(String baseUrl) {

      // 把String類型的url參數(shù)轉(zhuǎn)化為適合OKhttp的HttpUrl類型
      HttpUrl httpUrl = HttpUrl.parse(baseUrl);     

    // 最終返回帶httpUrl類型參數(shù)的baseUrl()
    // 下面繼續(xù)看baseUrl(httpUrl) ->> 步驟2
      return baseUrl(httpUrl);
    }


<-- 步驟2 -->
    public Builder baseUrl(HttpUrl baseUrl) {

      //把URL參數(shù)分割成幾個(gè)路徑碎片
      List<String> pathSegments = baseUrl.pathSegments();   

      // 檢測(cè)最后一個(gè)碎片來檢查URL參數(shù)是不是以"/"結(jié)尾
      // 不是就拋出異常    
      if (!"".equals(pathSegments.get(pathSegments.size() - 1))) {
        throw new IllegalArgumentException("baseUrl must end in /: " + baseUrl);
      }     
      this.baseUrl = baseUrl;
      return this;
    }
  • 至此,步驟3分析完畢
  • 總結(jié):baseUrl()用于配置Retrofit類的網(wǎng)絡(luò)請(qǐng)求url地址

將傳入的String類型url轉(zhuǎn)化為適合OKhttp的HttpUrl類型的url

步驟4

步驟4

我們從里往外看溪椎,即先看GsonConverterFactory.creat()

public final class GsonConverterFactory extends Converter.Factory {

<-- 步驟1 -->
  public static GsonConverterFactory create() {
    // 創(chuàng)建一個(gè)Gson對(duì)象
    return create(new Gson()); ->>步驟2
  }

<-- 步驟2 -->
  public static GsonConverterFactory create(Gson gson) {
    // 創(chuàng)建了一個(gè)含有Gson對(duì)象實(shí)例的GsonConverterFactory
    return new GsonConverterFactory(gson); ->>步驟3
  }

  private final Gson gson;

<-- 步驟3 -->
  private GsonConverterFactory(Gson gson) {
    if (gson == null) throw new NullPointerException("gson == null");
    this.gson = gson;
  }


  • 所以,GsonConverterFactory.creat()是創(chuàng)建了一個(gè)含有Gson對(duì)象實(shí)例的GsonConverterFactory恬口,并返回給addConverterFactory()
  • 接下來繼續(xù)看:addConverterFactory()

// 將上面創(chuàng)建的GsonConverterFactory放入到 converterFactories數(shù)組
// 在第二步放入一個(gè)內(nèi)置的數(shù)據(jù)轉(zhuǎn)換器工廠BuiltInConverters()后又放入了一個(gè)GsonConverterFactory
  public Builder addConverterFactory(Converter.Factory factory) {
      converterFactories.add(checkNotNull(factory, "factory == null"));
      return this;
    }


  • 至此校读,分析完畢
  • 總結(jié):步驟4用于創(chuàng)建一個(gè)含有Gson對(duì)象實(shí)例的GsonConverterFactory并放入到數(shù)據(jù)轉(zhuǎn)換器工廠converterFactories里
  1. 即Retrofit默認(rèn)使用Gson進(jìn)行解析
  2. 若使用其他解析方式(如Json、XML或Protocobuf)祖能,也可通過自定義數(shù)據(jù)解析器來實(shí)現(xiàn)(必須繼承 Converter.Factory)

步驟5

步驟5

終于到了最后一個(gè)步驟了地熄。

    public Retrofit build() {
 
 <--  配置網(wǎng)絡(luò)請(qǐng)求執(zhí)行器(callFactory)-->
      okhttp3.Call.Factory callFactory = this.callFactory;
      // 如果沒指定,則默認(rèn)使用okhttp
      // 所以Retrofit默認(rèn)使用okhttp進(jìn)行網(wǎng)絡(luò)請(qǐng)求
      if (callFactory == null) {
        callFactory = new OkHttpClient();
      }

 <--  配置回調(diào)方法執(zhí)行器(callbackExecutor)-->
      Executor callbackExecutor = this.callbackExecutor;
      // 如果沒指定芯杀,則默認(rèn)使用Platform檢測(cè)環(huán)境時(shí)的默認(rèn)callbackExecutor
      // 即Android默認(rèn)的callbackExecutor
      if (callbackExecutor == null) {
        callbackExecutor = platform.defaultCallbackExecutor();
      }

 <--  配置網(wǎng)絡(luò)請(qǐng)求適配器工廠(CallAdapterFactory)-->
      List<CallAdapter.Factory> adapterFactories = new ArrayList<>(this.adapterFactories);
      // 向該集合中添加了步驟2中創(chuàng)建的CallAdapter.Factory請(qǐng)求適配器(添加在集合器末尾)
      adapterFactories.add(platform.defaultCallAdapterFactory(callbackExecutor));
    // 請(qǐng)求適配器工廠集合存儲(chǔ)順序:自定義1適配器工廠、自定義2適配器工廠...默認(rèn)適配器工廠(ExecutorCallAdapterFactory)

 <--  配置數(shù)據(jù)轉(zhuǎn)換器工廠:converterFactory -->
      // 在步驟2中已經(jīng)添加了內(nèi)置的數(shù)據(jù)轉(zhuǎn)換器BuiltInConverters()(添加到集合器的首位)
      // 在步驟4中又插入了一個(gè)Gson的轉(zhuǎn)換器 - GsonConverterFactory(添加到集合器的首二位)
      List<Converter.Factory> converterFactories = new ArrayList<>(this.converterFactories);
      // 數(shù)據(jù)轉(zhuǎn)換器工廠集合存儲(chǔ)的是:默認(rèn)數(shù)據(jù)轉(zhuǎn)換器工廠( BuiltInConverters)、自定義1數(shù)據(jù)轉(zhuǎn)換器工廠(GsonConverterFactory)揭厚、自定義2數(shù)據(jù)轉(zhuǎn)換器工廠....

// 注:
//1. 獲取合適的網(wǎng)絡(luò)請(qǐng)求適配器和數(shù)據(jù)轉(zhuǎn)換器都是從adapterFactories和converterFactories集合的首位-末位開始遍歷
// 因此集合中的工廠位置越靠前就擁有越高的使用權(quán)限

      // 最終返回一個(gè)Retrofit的對(duì)象却特,并傳入上述已經(jīng)配置好的成員變量
      return new Retrofit(callFactory, baseUrl, converterFactories, adapterFactories,
          callbackExecutor, validateEagerly);
    }
  • 至此,步驟5分析完畢
  • 總結(jié):在最后一步中筛圆,通過前面步驟設(shè)置的變量裂明,將Retrofit類的所有成員變量都配置完畢。
  • 所以太援,成功創(chuàng)建了Retrofit的實(shí)例

總結(jié)

Retrofit使用建造者模式通過Builder類建立了一個(gè)Retrofit實(shí)例闽晦,具體創(chuàng)建細(xì)節(jié)是配置了:

  • 平臺(tái)類型對(duì)象(Platform - Android)
  • 網(wǎng)絡(luò)請(qǐng)求的url地址(baseUrl)
  • 網(wǎng)絡(luò)請(qǐng)求工廠(callFactory)

默認(rèn)使用OkHttpCall

  • 網(wǎng)絡(luò)請(qǐng)求適配器工廠的集合(adapterFactories)

本質(zhì)是配置了網(wǎng)絡(luò)請(qǐng)求適配器工廠- 默認(rèn)是ExecutorCallAdapterFactory

  • 數(shù)據(jù)轉(zhuǎn)換器工廠的集合(converterFactories)

本質(zhì)是配置了數(shù)據(jù)轉(zhuǎn)換器工廠

  • 回調(diào)方法執(zhí)行器(callbackExecutor)

默認(rèn)回調(diào)方法執(zhí)行器作用是:切換線程(子線程 - 主線程)

由于使用了建造者模式,所以開發(fā)者并不需要關(guān)心配置細(xì)節(jié)就可以創(chuàng)建好Retrofit實(shí)例提岔,建造者模式get仙蛉。

在創(chuàng)建Retrofit對(duì)象時(shí),你可以通過更多更靈活的方式去處理你的需求碱蒙,如使用不同的Converter荠瘪、使用不同的CallAdapter,這也就提供了你使用RxJava來調(diào)用Retrofit的可能


2. 創(chuàng)建網(wǎng)絡(luò)請(qǐng)求接口的實(shí)例

2.1 使用步驟

<-- 步驟1:定義接收網(wǎng)絡(luò)數(shù)據(jù)的類 -->
<-- JavaBean.java -->
public class JavaBean {
  .. // 這里就不介紹了
  }

<-- 步驟2:定義網(wǎng)絡(luò)請(qǐng)求的接口類 -->
<-- AccessApi.java -->
public interface AccessApi {
    // 注解GET:采用Get方法發(fā)送網(wǎng)絡(luò)請(qǐng)求
    // Retrofit把網(wǎng)絡(luò)請(qǐng)求的URL分成了2部分:1部分baseurl放在創(chuàng)建Retrofit對(duì)象時(shí)設(shè)置赛惩;另一部分在網(wǎng)絡(luò)請(qǐng)求接口設(shè)置(即這里)
    // 如果接口里的URL是一個(gè)完整的網(wǎng)址哀墓,那么放在創(chuàng)建Retrofit對(duì)象時(shí)設(shè)置的部分可以不設(shè)置
    @GET("openapi.do?keyfrom=Yanzhikai&key=2032414398&type=data&doctype=json&version=1.1&q=car")

    // 接受網(wǎng)絡(luò)請(qǐng)求數(shù)據(jù)的方法
    Call<JavaBean> getCall();
    // 返回類型為Call<*>,*是解析得到的數(shù)據(jù)類型喷兼,即JavaBean
}

<-- 步驟3:在MainActivity創(chuàng)建接口類實(shí)例  -->
AccessApi NetService = retrofit.create(AccessApi.class);
       
<-- 步驟4:對(duì)發(fā)送請(qǐng)求的url進(jìn)行封裝篮绰,即生成最終的網(wǎng)絡(luò)請(qǐng)求對(duì)象  --> 
        Call<JavaBean> call = NetService.getCall();

2.2 源碼分析

  • 結(jié)論:Retrofit是通過外觀模式 & 代理模式 使用create()方法創(chuàng)建網(wǎng)絡(luò)請(qǐng)求接口的實(shí)例(同時(shí),通過網(wǎng)絡(luò)請(qǐng)求接口里設(shè)置的注解進(jìn)行了網(wǎng)絡(luò)請(qǐng)求參數(shù)的配置)
  1. 外觀模式:定義一個(gè)統(tǒng)一接口季惯,外部與通過該統(tǒng)一的接口對(duì)子系統(tǒng)里的其他接口進(jìn)行訪問吠各。具體請(qǐng)看:外觀模式(Facade Pattern) - 最易懂的設(shè)計(jì)模式解析
  2. 代理模式:通過訪問代理對(duì)象的方式來間接訪問目標(biāo)對(duì)象。具體請(qǐng)看:代理模式(Proxy Pattern)- 最易懂的設(shè)計(jì)模式解析
  • 下面主要分析步驟3和步驟4:
<-- 步驟3:在MainActivity創(chuàng)建接口類實(shí)例  -->
AccessApi NetService = retrofit.create(NetService.class);

<-- 步驟4:對(duì)發(fā)送請(qǐng)求的url進(jìn)行封裝星瘾,即生成最終的網(wǎng)絡(luò)請(qǐng)求對(duì)象  --> 
        Call<JavaBean> call = NetService.getCall();

步驟3講解:AccessApi NetService = retrofit.create(NetService.class);

 public <T> T create(final Class<T> service) {

       if (validateEagerly) {  
      // 判斷是否需要提前驗(yàn)證
      eagerlyValidateMethods(service); 
      // 具體方法作用:
      // 1. 給接口中每個(gè)方法的注解進(jìn)行解析并得到一個(gè)ServiceMethod對(duì)象
      // 2. 以Method為鍵將該對(duì)象存入LinkedHashMap集合中
     // 特別注意:如果不是提前驗(yàn)證則進(jìn)行動(dòng)態(tài)解析對(duì)應(yīng)方法(下面會(huì)詳細(xì)說明)走孽,得到一個(gè)ServiceMethod對(duì)象,最后存入到LinkedHashMap集合中琳状,類似延遲加載(默認(rèn))
    }  


        // 創(chuàng)建了網(wǎng)絡(luò)請(qǐng)求接口的動(dòng)態(tài)代理對(duì)象磕瓷,即通過動(dòng)態(tài)代理創(chuàng)建網(wǎng)絡(luò)請(qǐng)求接口的實(shí)例 (并最終返回)
        // 該動(dòng)態(tài)代理是為了拿到網(wǎng)絡(luò)請(qǐng)求接口實(shí)例上所有注解
    return (T) Proxy.newProxyInstance(
          service.getClassLoader(),      // 動(dòng)態(tài)生成接口的實(shí)現(xiàn)類 
          new Class<?>[] { service },    // 動(dòng)態(tài)創(chuàng)建實(shí)例
          new InvocationHandler() {     // 將代理類的實(shí)現(xiàn)交給 InvocationHandler類作為具體的實(shí)現(xiàn)(下面會(huì)解釋)
          private final Platform platform = Platform.get();

         // 在 InvocationHandler類的invoke()實(shí)現(xiàn)中,除了執(zhí)行真正的邏輯(如再次轉(zhuǎn)發(fā)給真正的實(shí)現(xiàn)類對(duì)象)念逞,還可以進(jìn)行一些有用的操作
         // 如統(tǒng)計(jì)執(zhí)行時(shí)間困食、進(jìn)行初始化和清理、對(duì)接口調(diào)用進(jìn)行檢查等翎承。
          @Override 
           public Object invoke(Object proxy, Method method, Object... args)
              throws Throwable {
          
            // 下面會(huì)詳細(xì)介紹 invoke()的實(shí)現(xiàn)
            // 即下面三行代碼
            ServiceMethod serviceMethod = loadServiceMethod(method);     
            OkHttpCall okHttpCall = new OkHttpCall<>(serviceMethod, args);
            return serviceMethod.callAdapter.adapt(okHttpCall);
          }
        });
  }

// 特別注意
// return (T) roxy.newProxyInstance(ClassLoader loader, Class<?>[] interfaces,  InvocationHandler invocationHandler)
// 可以解讀為:getProxyClass(loader, interfaces) .getConstructor(InvocationHandler.class).newInstance(invocationHandler);
// 即通過動(dòng)態(tài)生成的代理類硕盹,調(diào)用interfaces接口的方法實(shí)際上是通過調(diào)用InvocationHandler對(duì)象的invoke()來完成指定的功能
// 先記住結(jié)論,在講解步驟4的時(shí)候會(huì)再次詳細(xì)說明


<-- 關(guān)注點(diǎn)1:eagerlyValidateMethods() -->
private void eagerlyValidateMethods(Class<?> service) {  
    Platform platform = Platform.get();  
    for (Method method : service.getDeclaredMethods()) {  
      if (!platform.isDefaultMethod(method)) {  loadServiceMethod(method); } 
      // 將傳入的ServiceMethod對(duì)象加入LinkedHashMap<Method, ServiceMethod>集合
     // 使用LinkedHashMap集合的好處:lruEntries.values().iterator().next()獲取到的是集合最不經(jīng)常用到的元素叨咖,提供了一種Lru算法的實(shí)現(xiàn)
    }  
}  

創(chuàng)建網(wǎng)絡(luò)接口實(shí)例用了外觀模式 & 代理模式:

使用外觀模式進(jìn)行訪問瘩例,里面用了代理模式

1. 外觀模式

  • 外觀模式:定義一個(gè)統(tǒng)一接口啊胶,外部與通過該統(tǒng)一的接口對(duì)子系統(tǒng)里的其他接口進(jìn)行訪問。具體請(qǐng)看:外觀模式(Facade Pattern) - 最易懂的設(shè)計(jì)模式解析

  • Retrofit對(duì)象的外觀(門店) = retrofit.create()

  • 通過這一外觀方法就可以在內(nèi)部調(diào)用各個(gè)方法創(chuàng)建網(wǎng)絡(luò)請(qǐng)求接口的實(shí)例配置網(wǎng)絡(luò)請(qǐng)求參數(shù)

大大降低了系統(tǒng)的耦合度

2. 代理模式

  • 代理模式:通過訪問代理對(duì)象的方式來間接訪問目標(biāo)對(duì)象

分為靜態(tài)代理 & 動(dòng)態(tài)代理:

  1. 靜態(tài)代理:代理類在程序運(yùn)行前已經(jīng)存在的代理方式
  2. 動(dòng)態(tài)代理:代理類在程序運(yùn)行前不存在垛贤、運(yùn)行時(shí)由程序動(dòng)態(tài)生成的代理方式
    具體請(qǐng)看文章代理模式(Proxy Pattern)- 最易懂的設(shè)計(jì)模式解析
  • return (T) roxy.newProxyInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler invocationHandler)通過代理模式中的動(dòng)態(tài)代理模式焰坪,動(dòng)態(tài)生成網(wǎng)絡(luò)請(qǐng)求接口的代理類,并將代理類的實(shí)例創(chuàng)建交給InvocationHandler類 作為具體的實(shí)現(xiàn)聘惦,并最終返回一個(gè)動(dòng)態(tài)代理對(duì)象某饰。

生成實(shí)例過程中含有生成實(shí)現(xiàn)類的緩存機(jī)制(單例模式),下面會(huì)詳細(xì)分析

使用動(dòng)態(tài)代理的好處:

  • 當(dāng)NetService對(duì)象調(diào)用getCall()接口中方法時(shí)會(huì)進(jìn)行攔截善绎,調(diào)用都會(huì)集中轉(zhuǎn)發(fā)到 InvocationHandler#invoke ()黔漂,可集中進(jìn)行處理
  • 獲得網(wǎng)絡(luò)請(qǐng)求接口實(shí)例上的所有注解
  • 更方便封裝ServiceMethod

下面看源碼分析

下面將詳細(xì)分析InvocationHandler類 # invoke()里的具體實(shí)現(xiàn)

 new InvocationHandler() {   
          private final Platform platform = Platform.get();

  @Override 
           public Object invoke(Object proxy, Method method, Object... args)
              throws Throwable {

            // 將詳細(xì)介紹下面代碼
            // 關(guān)注點(diǎn)1
            // 作用:讀取網(wǎng)絡(luò)請(qǐng)求接口里的方法,并根據(jù)前面配置好的屬性配置serviceMethod對(duì)象
            ServiceMethod serviceMethod = loadServiceMethod(method);     
           
            // 關(guān)注點(diǎn)2
            // 作用:根據(jù)配置好的serviceMethod對(duì)象創(chuàng)建okHttpCall對(duì)象 
            OkHttpCall okHttpCall = new OkHttpCall<>(serviceMethod, args);

            // 關(guān)注點(diǎn)3
            // 作用:調(diào)用OkHttp禀酱,并根據(jù)okHttpCall返回rejava的Observe對(duì)象或者返回Call
            return serviceMethod.callAdapter.adapt(okHttpCall);
          }

下面將詳細(xì)介紹3個(gè)關(guān)注點(diǎn)的代碼炬守。

關(guān)注點(diǎn)1: ServiceMethod serviceMethod = loadServiceMethod(method);

<-- loadServiceMethod(method)方法講解 -->
// 一個(gè) ServiceMethod 對(duì)象對(duì)應(yīng)于網(wǎng)絡(luò)請(qǐng)求接口里的一個(gè)方法
// loadServiceMethod(method)負(fù)責(zé)加載 ServiceMethod:

  ServiceMethod loadServiceMethod(Method method) {
    ServiceMethod result;
      // 設(shè)置線程同步鎖
    synchronized (serviceMethodCache) {

      result = serviceMethodCache.get(method);
      // ServiceMethod類對(duì)象采用了單例模式進(jìn)行創(chuàng)建
      // 即創(chuàng)建ServiceMethod對(duì)象前,先看serviceMethodCache有沒有緩存之前創(chuàng)建過的網(wǎng)絡(luò)請(qǐng)求實(shí)例
      
      // 若沒緩存比勉,則通過建造者模式創(chuàng)建 serviceMethod 對(duì)象
      if (result == null) {
      // 下面會(huì)詳細(xì)介紹ServiceMethod生成實(shí)例的過程
        result = new ServiceMethod.Builder(this, method).build();
        serviceMethodCache.put(method, result);
      }
    }
    return result;
  }
// 這里就是上面說的創(chuàng)建實(shí)例的緩存機(jī)制:采用單例模式從而實(shí)現(xiàn)一個(gè) ServiceMethod 對(duì)象對(duì)應(yīng)于網(wǎng)絡(luò)請(qǐng)求接口里的一個(gè)方法
// 注:由于每次獲取接口實(shí)例都是傳入 class 對(duì)象
// 而 class 對(duì)象在進(jìn)程內(nèi)單例的劳较,所以獲取到它的同一個(gè)方法 Method 實(shí)例也是單例的,所以這里的緩存是有效的浩聋。

下面观蜗,我將分3個(gè)步驟詳細(xì)分析serviceMethod實(shí)例的創(chuàng)建過程:

Paste_Image.png

步驟1:ServiceMethod類 構(gòu)造函數(shù)

Paste_Image.png

<-- ServiceMethod 類 -->
public final class ServiceMethod {
final okhttp3.Call.Factory callFactory;   // 網(wǎng)絡(luò)請(qǐng)求工廠  
final CallAdapter<?> callAdapter;  
// 網(wǎng)絡(luò)請(qǐng)求適配器工廠
// 具體創(chuàng)建是在new ServiceMethod.Builder(this, method).build()最后的build()中
// 下面會(huì)詳細(xì)說明

private final Converter<ResponseBody, T> responseConverter; 
// Response內(nèi)容轉(zhuǎn)換器  
// 作用:負(fù)責(zé)把服務(wù)器返回的數(shù)據(jù)(JSON或者其他格式,由 ResponseBody 封裝)轉(zhuǎn)化為 T 類型的對(duì)象衣洁;
  
private final HttpUrl baseUrl; // 網(wǎng)絡(luò)請(qǐng)求地址  
private final String relativeUrl; // 網(wǎng)絡(luò)請(qǐng)求的相對(duì)地址  
private final String httpMethod;   // 網(wǎng)絡(luò)請(qǐng)求的Http方法  
private final Headers headers;  // 網(wǎng)絡(luò)請(qǐng)求的http請(qǐng)求頭 鍵值對(duì)  
private final MediaType contentType; // 網(wǎng)絡(luò)請(qǐng)求的http報(bào)文body的類型  

private final ParameterHandler<?>[] parameterHandlers;  
  // 方法參數(shù)處理器
  // 作用:負(fù)責(zé)解析 API 定義時(shí)每個(gè)方法的參數(shù)墓捻,并在構(gòu)造 HTTP 請(qǐng)求時(shí)設(shè)置參數(shù);
  // 下面會(huì)詳細(xì)說明

// 說明:從上面的成員變量可以看出坊夫,ServiceMethod對(duì)象包含了訪問網(wǎng)絡(luò)的所有基本信息

<-- ServiceMethod 類的構(gòu)造函數(shù) -->
// 作用:傳入各種網(wǎng)絡(luò)請(qǐng)求參數(shù)
ServiceMethod(Builder<T> builder) {

    this.callFactory = builder.retrofit.callFactory();  
    this.callAdapter = builder.callAdapter;   
    this.responseConverter = builder.responseConverter;   
  
    this.baseUrl = builder.retrofit.baseUrl();   
    this.relativeUrl = builder.relativeUrl;   
    this.httpMethod = builder.httpMethod;  
    this.headers = builder.headers;  
    this.contentType = builder.contentType; .  
    this.hasBody = builder.hasBody; y  
    this.isFormEncoded = builder.isFormEncoded;   
    this.isMultipart = builder.isMultipart;  
    this.parameterHandlers = builder.parameterHandlers;  
}


步驟2:ServiceMethod的Builder()

Paste_Image.png

   public Builder(Retrofit retrofit, Method method) {
      this.retrofit = retrofit;
      this.method = method;

      // 獲取網(wǎng)絡(luò)請(qǐng)求接口方法里的注釋
      this.methodAnnotations = method.getAnnotations();
      // 獲取網(wǎng)絡(luò)請(qǐng)求接口方法里的參數(shù)類型       
      this.parameterTypes = method.getGenericParameterTypes();  
      //獲取網(wǎng)絡(luò)請(qǐng)求接口方法里的注解內(nèi)容    
      this.parameterAnnotationsArray = method.getParameterAnnotations();    
    }

步驟3:ServiceMethod的build()

Paste_Image.png

// 作用:控制ServiceMethod對(duì)象的生成流程

 public ServiceMethod build() {

      callAdapter = createCallAdapter();    
      // 根據(jù)網(wǎng)絡(luò)請(qǐng)求接口方法的返回值和注解類型砖第,從Retrofit對(duì)象中獲取對(duì)應(yīng)的網(wǎng)絡(luò)請(qǐng)求適配器  -->關(guān)注點(diǎn)1
     
      responseType = callAdapter.responseType();    
     // 根據(jù)網(wǎng)絡(luò)請(qǐng)求接口方法的返回值和注解類型,從Retrofit對(duì)象中獲取該網(wǎng)絡(luò)適配器返回的數(shù)據(jù)類型
     
      responseConverter = createResponseConverter();    
      // 根據(jù)網(wǎng)絡(luò)請(qǐng)求接口方法的返回值和注解類型环凿,從Retrofit對(duì)象中獲取對(duì)應(yīng)的數(shù)據(jù)轉(zhuǎn)換器  -->關(guān)注點(diǎn)3
      // 構(gòu)造 HTTP 請(qǐng)求時(shí)梧兼,我們傳遞的參數(shù)都是String
      // Retrofit 類提供 converter把傳遞的參數(shù)都轉(zhuǎn)化為 String 
      // 其余類型的參數(shù)都利用 Converter.Factory 的stringConverter 進(jìn)行轉(zhuǎn)換
      // @Body 和 @Part 類型的參數(shù)利用Converter.Factory 提供的 requestBodyConverter 進(jìn)行轉(zhuǎn)換
      // 這三種 converter 都是通過“詢問”工廠列表進(jìn)行提供,而工廠列表我們可以在構(gòu)造 Retrofit 對(duì)象時(shí)進(jìn)行添加智听。
      
       
       for (Annotation annotation : methodAnnotations) {
        parseMethodAnnotation(annotation);
      }
      // 解析網(wǎng)絡(luò)請(qǐng)求接口中方法的注解
      // 主要是解析獲取Http請(qǐng)求的方法
     // 注解包括:DELETE羽杰、GET、POST到推、HEAD考赛、PATCH、PUT莉测、OPTIONS颜骤、HTTP、retrofit2.http.Headers捣卤、Multipart忍抽、FormUrlEncoded
     // 處理主要是調(diào)用方法 parseHttpMethodAndPath(String httpMethod, String value, boolean hasBody) ServiceMethod中的httpMethod八孝、hasBody、relativeUrl鸠项、relativeUrlParamNames域進(jìn)行賦值
      
     int parameterCount = parameterAnnotationsArray.length;
     // 獲取當(dāng)前方法的參數(shù)數(shù)量
      
      parameterHandlers = new ParameterHandler<?>[parameterCount];
      for (int p = 0; p < parameterCount; p++) {
        Type parameterType = parameterTypes[p];
        Annotation[] parameterAnnotations = parameterAnnotationsArray[p];
        // 為方法中的每個(gè)參數(shù)創(chuàng)建一個(gè)ParameterHandler<?>對(duì)象并解析每個(gè)參數(shù)使用的注解類型
        // 該對(duì)象的創(chuàng)建過程就是對(duì)方法參數(shù)中注解進(jìn)行解析
        // 這里的注解包括:Body唆阿、PartMap、Part锈锤、FieldMap、Field闲询、Header久免、QueryMap、Query扭弧、Path阎姥、Url 
        parameterHandlers[p] = parseParameter(p, parameterType, parameterAnnotations);
      } 
      return new ServiceMethod<>(this);

<-- 總結(jié) -->
// 1. 根據(jù)返回值類型和方法標(biāo)注從Retrofit對(duì)象的的網(wǎng)絡(luò)請(qǐng)求適配器工廠集合和內(nèi)容轉(zhuǎn)換器工廠集合中分別獲取到該方法對(duì)應(yīng)的網(wǎng)絡(luò)請(qǐng)求適配器和Response內(nèi)容轉(zhuǎn)換器;
// 2. 根據(jù)方法的標(biāo)注對(duì)ServiceMethod的域進(jìn)行賦值
// 3. 最后為每個(gè)方法的參數(shù)的標(biāo)注進(jìn)行解析鸽捻,獲得一個(gè)ParameterHandler<?>對(duì)象
// 該對(duì)象保存有一個(gè)Request內(nèi)容轉(zhuǎn)換器——根據(jù)參數(shù)的類型從Retrofit的內(nèi)容轉(zhuǎn)換器工廠集合中獲取一個(gè)Request內(nèi)容轉(zhuǎn)換器或者一個(gè)String內(nèi)容轉(zhuǎn)換器呼巴。
    }


<-- 關(guān)注點(diǎn)1:createCallAdapter() -->
 private CallAdapter<?> createCallAdapter() {

      // 獲取網(wǎng)絡(luò)請(qǐng)求接口里方法的返回值類型
      Type returnType = method.getGenericReturnType();      

      // 獲取網(wǎng)絡(luò)請(qǐng)求接口接口里的注解
      // 此處使用的是@Get
      Annotation[] annotations = method.getAnnotations();       
      try {

      return retrofit.callAdapter(returnType, annotations); 
      // 根據(jù)網(wǎng)絡(luò)請(qǐng)求接口方法的返回值和注解類型,從Retrofit對(duì)象中獲取對(duì)應(yīng)的網(wǎng)絡(luò)請(qǐng)求適配器
      // 下面會(huì)詳細(xì)說明retrofit.callAdapter() -- >關(guān)注點(diǎn)2
      }
...


<-- 關(guān)注點(diǎn)2:retrofit.callAdapter()  -->
 public CallAdapter<?> callAdapter(Type returnType, Annotation[] annotations) {
    return nextCallAdapter(null, returnType, annotations);
  }

 public CallAdapter<?> nextCallAdapter(CallAdapter.Factory skipPast, Type returnType,
      Annotation[] annotations) {

    // 創(chuàng)建 CallAdapter 如下
    // 遍歷 CallAdapter.Factory 集合尋找合適的工廠(該工廠集合在第一步構(gòu)造 Retrofit 對(duì)象時(shí)進(jìn)行添加(第一步時(shí)已經(jīng)說明))
    // 如果最終沒有工廠提供需要的 CallAdapter御蒲,將拋出異常
    for (int i = start, count = adapterFactories.size(); i < count; i++) {
      CallAdapter<?> adapter = adapterFactories.get(i).get(returnType, annotations, this);      
      if (adapter != null) {
        return adapter;
      }
    }


<--   關(guān)注點(diǎn)3:createResponseConverter() -->

 private Converter<ResponseBody, T> createResponseConverter() {
      Annotation[] annotations = method.getAnnotations();
      try {
    
        // responseConverter 還是由 Retrofit 類提供  -->關(guān)注點(diǎn)4
        return retrofit.responseBodyConverter(responseType, annotations);
      } catch (RuntimeException e) { 
        throw methodError(e, "Unable to create converter for %s", responseType);
      }
    }

<--   關(guān)注點(diǎn)4:responseBodyConverter() -->
  public <T> Converter<ResponseBody, T> responseBodyConverter(Type type, Annotation[] annotations) {
    return nextResponseBodyConverter(null, type, annotations);
  }

 public <T> Converter<ResponseBody, T> nextResponseBodyConverter(Converter.Factory skipPast,

    int start = converterFactories.indexOf(skipPast) + 1;
    for (int i = start, count = converterFactories.size(); i < count; i++) {

       // 獲取Converter 過程:(和獲取 callAdapter 基本一致)
         Converter<ResponseBody, ?> converter =
          converterFactories.get(i).responseBodyConverter(type, annotations, this); 
       // 遍歷 Converter.Factory 集合并尋找合適的工廠(該工廠集合在構(gòu)造 Retrofit 對(duì)象時(shí)進(jìn)行添加(第一步時(shí)已經(jīng)說明))
       // 由于構(gòu)造Retroifit采用的是Gson解析方式衣赶,所以取出的是GsonResponseBodyConverter
       // Retrofit - Converters 還提供了 JSON,XML厚满,ProtoBuf 等類型數(shù)據(jù)的轉(zhuǎn)換功能府瞄。
       // 繼續(xù)看responseBodyConverter() -->關(guān)注點(diǎn)5    
    }


<--   關(guān)注點(diǎn)5:responseBodyConverter() -->
@Override
public Converter<ResponseBody, ?> responseBodyConverter(Type type, 
    Annotation[] annotations, Retrofit retrofit) {

  
  TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
  // 根據(jù)目標(biāo)類型,利用 Gson#getAdapter 獲取相應(yīng)的 adapter
  return new GsonResponseBodyConverter<>(gson, adapter);
}

// 做數(shù)據(jù)轉(zhuǎn)換時(shí)調(diào)用 Gson 的 API 即可碘箍。
final class GsonResponseBodyConverter<T> implements Converter<ResponseBody, T> {
  private final Gson gson;
  private final TypeAdapter<T> adapter;

  GsonResponseBodyConverter(Gson gson, TypeAdapter<T> adapter) {
    this.gson = gson;
    this.adapter = adapter;
  }

  @Override 
   public T convert(ResponseBody value) throws IOException {
    JsonReader jsonReader = gson.newJsonReader(value.charStream());
    try {
      return adapter.read(jsonReader);
    } finally {
      value.close();
    }
  }
}
  • 當(dāng)選擇了RxjavaCallAdapterFactory后遵馆,Rxjava通過策略模式選擇對(duì)應(yīng)的adapter

關(guān)于策略模式的講解,請(qǐng)看文章策略模式(Strategy Pattern)- 最易懂的設(shè)計(jì)模式解析

  • 具體過程是:根據(jù)網(wǎng)絡(luò)接口方法的返回值類型來選擇具體要用哪種CallAdapterFactory丰榴,然后創(chuàng)建具體的CallAdapter實(shí)例

采用工廠模式使得各功能模塊高度解耦

  • 上面提到了兩種工廠:CallAdapter.Factory & Converter.Factory分別負(fù)責(zé)提供不同的功能模塊
  • 工廠負(fù)責(zé)如何提供货邓、提供何種功能模塊
  • Retrofit 只負(fù)責(zé)提供選擇何種工廠的決策信息(如網(wǎng)絡(luò)接口方法的參數(shù)、返回值類型四濒、注解等)

這正是所謂的高內(nèi)聚低耦合换况,工廠模式get。

關(guān)于工廠模式請(qǐng)看我寫的文章:
簡單工廠模式(SimpleFactoryPattern)- 最易懂的設(shè)計(jì)模式解析
工廠方法模式(Factory Method)- 最易懂的設(shè)計(jì)模式解析
抽象工廠模式(Abstract Factory)- 最易懂的設(shè)計(jì)模式解析

終于配置完網(wǎng)絡(luò)請(qǐng)求參數(shù)(即配置好ServiceMethod對(duì)象)峻黍。接下來將講解第二行代碼:okHttpCall對(duì)象的創(chuàng)建

第二行:OkHttpCall okHttpCall = new OkHttpCall<>(serviceMethod, args);

根據(jù)第一步配置好的ServiceMethod對(duì)象和輸入的請(qǐng)求參數(shù)創(chuàng)建okHttpCall對(duì)象

<--OkHttpCall類 -->
public class OkHttpCall {
    private final ServiceMethod<T> serviceMethod; // 含有所有網(wǎng)絡(luò)請(qǐng)求參數(shù)信息的對(duì)象  
    private final Object[] args; // 網(wǎng)絡(luò)請(qǐng)求接口的參數(shù) 
    private okhttp3.Call rawCall; //實(shí)際進(jìn)行網(wǎng)絡(luò)訪問的類  
    private Throwable creationFailure; //幾個(gè)狀態(tài)標(biāo)志位  
    private boolean executed;  
    private volatile boolean canceled;  
  
<--OkHttpCall構(gòu)造函數(shù) -->
  public OkHttpCall(ServiceMethod<T> serviceMethod, Object[] args) {  
    // 傳入了配置好的ServiceMethod對(duì)象和輸入的請(qǐng)求參數(shù)
    this.serviceMethod = serviceMethod;  
    this.args = args;  
}  

第三行:return serviceMethod.callAdapter.adapt(okHttpCall);

將第二步創(chuàng)建的OkHttpCall對(duì)象傳給第一步創(chuàng)建的serviceMethod對(duì)象中對(duì)應(yīng)的網(wǎng)絡(luò)請(qǐng)求適配器工廠的adapt()

返回對(duì)象類型:Android默認(rèn)的是Call<>复隆;若設(shè)置了RxJavaCallAdapterFactory,返回的則是Observable<>

<--  adapt()詳解-->
public <R> Call<R> adapt(Call<R> call) {
        return new ExecutorCallbackCall<>(callbackExecutor, call);  
      }

   ExecutorCallbackCall(Executor callbackExecutor, Call<T> delegate) {
      this.delegate = delegate; 
      // 把上面創(chuàng)建并配置好參數(shù)的OkhttpCall對(duì)象交給靜態(tài)代理delegate
      // 靜態(tài)代理和動(dòng)態(tài)代理都屬于代理模式
     // 靜態(tài)代理作用:代理執(zhí)行被代理者的方法姆涩,且可在要執(zhí)行的方法前后加入自己的動(dòng)作挽拂,進(jìn)行對(duì)系統(tǒng)功能的拓展
      
      this.callbackExecutor = callbackExecutor;
      // 傳入上面定義的回調(diào)方法執(zhí)行器
      // 用于進(jìn)行線程切換   
    }
  • 采用了裝飾模式:ExecutorCallbackCall = 裝飾者,而里面真正去執(zhí)行網(wǎng)絡(luò)請(qǐng)求的還是OkHttpCall
  • 使用裝飾模式的原因:希望在OkHttpCall發(fā)送請(qǐng)求時(shí)做一些額外操作骨饿。這里的額外操作是線程轉(zhuǎn)換亏栈,即將子線程切換到主線程
  1. OkHttpCall的enqueue()是進(jìn)行網(wǎng)絡(luò)異步請(qǐng)求的:當(dāng)你調(diào)用OkHttpCall.enqueue()時(shí)台腥,回調(diào)的callback是在子線程中,需要通過Handler轉(zhuǎn)換到主線程進(jìn)行回調(diào)绒北。ExecutorCallbackCall就是用于線程回調(diào)黎侈;
  2. 當(dāng)然以上是原生Retrofit使用的切換線程方式。如果你用Rxjava闷游,那就不會(huì)用到這個(gè)ExecutorCallbackCall而是RxJava的Call峻汉,此處不過多展開

步驟4講解:Call<JavaBean> call = NetService.getCall();

  • NetService對(duì)象實(shí)際上是動(dòng)態(tài)代理對(duì)象Proxy.newProxyInstance()(步驟3中已說明),并不是真正的網(wǎng)絡(luò)請(qǐng)求接口創(chuàng)建的對(duì)象
  • 當(dāng)NetService對(duì)象調(diào)用getCall()時(shí)會(huì)被動(dòng)態(tài)代理對(duì)象Proxy.newProxyInstance()攔截脐往,然后調(diào)用自身的InvocationHandler # invoke()
  • invoke(Object proxy, Method method, Object... args)會(huì)傳入3個(gè)參數(shù):Object proxy:(代理對(duì)象)休吠、
    Method method(調(diào)用的getCall()
    Object... args(方法的參數(shù),即getCall(*)中的*)
  • 接下來利用Java反射獲取到getCall()的注解信息业簿,配合args參數(shù)創(chuàng)建ServiceMethod對(duì)象瘤礁。

如上面步驟3描述,此處不再次講解

最終創(chuàng)建并返回一個(gè)OkHttpCall類型的Call對(duì)象

  1. OkHttpCall類是OkHttp的包裝類
  2. 創(chuàng)建了OkHttpCall類型的Call對(duì)象還不能發(fā)送網(wǎng)絡(luò)請(qǐng)求梅尤,需要?jiǎng)?chuàng)建Request對(duì)象才能發(fā)送網(wǎng)絡(luò)請(qǐng)求

總結(jié)

Retrofit采用了外觀模式統(tǒng)一調(diào)用創(chuàng)建網(wǎng)絡(luò)請(qǐng)求接口實(shí)例和網(wǎng)絡(luò)請(qǐng)求參數(shù)配置的方法柜思,具體細(xì)節(jié)是:

  • 動(dòng)態(tài)創(chuàng)建網(wǎng)絡(luò)請(qǐng)求接口的實(shí)例(代理模式 - 動(dòng)態(tài)代理)
  • 創(chuàng)建 serviceMethod 對(duì)象(建造者模式 & 單例模式(緩存機(jī)制))
  • 對(duì) serviceMethod 對(duì)象進(jìn)行網(wǎng)絡(luò)請(qǐng)求參數(shù)配置:通過解析網(wǎng)絡(luò)請(qǐng)求接口方法的參數(shù)、返回值和注解類型巷燥,從Retrofit對(duì)象中獲取對(duì)應(yīng)的網(wǎng)絡(luò)請(qǐng)求的url地址赡盘、網(wǎng)絡(luò)請(qǐng)求執(zhí)行器、網(wǎng)絡(luò)請(qǐng)求適配器 & 數(shù)據(jù)轉(zhuǎn)換器矾湃。(策略模式)
  • 對(duì) serviceMethod 對(duì)象加入線程切換的操作亡脑,便于接收數(shù)據(jù)后通過Handler從子線程切換到主線程從而對(duì)返回?cái)?shù)據(jù)結(jié)果進(jìn)行處理(裝飾模式)
  • 最終創(chuàng)建并返回一個(gè)OkHttpCall類型的網(wǎng)絡(luò)請(qǐng)求對(duì)象

3. 執(zhí)行網(wǎng)絡(luò)請(qǐng)求

  • Retrofit默認(rèn)使用OkHttp,即OkHttpCall類(實(shí)現(xiàn)了 retrofit2.Call<T>接口)

但可以自定義選擇自己需要的Call類

  • OkHttpCall提供了兩種網(wǎng)絡(luò)請(qǐng)求方式:
    1. 同步請(qǐng)求:OkHttpCall.execute()
    2. 異步請(qǐng)求:OkHttpCall.enqueue()

下面將詳細(xì)介紹這兩種網(wǎng)絡(luò)請(qǐng)求方式邀跃。

對(duì)于OkHttpCall的enqueue()霉咨、execute()此處不往下分析,有興趣的讀者可以看OkHttp的源碼

3.1 同步請(qǐng)求OkHttpCall.execute()

3.1.1 發(fā)送請(qǐng)求過程

  • 步驟1:對(duì)網(wǎng)絡(luò)請(qǐng)求接口的方法中的每個(gè)參數(shù)利用對(duì)應(yīng)ParameterHandler進(jìn)行解析拍屑,再根據(jù)ServiceMethod對(duì)象創(chuàng)建一個(gè)OkHttpRequest對(duì)象
  • 步驟2:使用OkHttpRequest發(fā)送網(wǎng)絡(luò)請(qǐng)求途戒;
  • 步驟3:對(duì)返回的數(shù)據(jù)使用之前設(shè)置的數(shù)據(jù)轉(zhuǎn)換器(GsonConverterFactory)解析返回的數(shù)據(jù),最終得到一個(gè)Response<T>對(duì)象

3.1.2 具體使用

Response<JavaBean> response = call.execute();  

上面簡單的一行代碼僵驰,其實(shí)包含了整個(gè)發(fā)送網(wǎng)絡(luò)同步請(qǐng)求的三個(gè)步驟喷斋。

3.1.3 源碼分析

@Override 
public Response<T> execute() throws IOException {
  okhttp3.Call call;

 // 設(shè)置同步鎖
  synchronized (this) {
    call = rawCall;
    if (call == null) {
      try {
        call = rawCall = createRawCall();
        // 步驟1:創(chuàng)建一個(gè)OkHttp的Request對(duì)象請(qǐng)求 -->關(guān)注1
      } catch (IOException | RuntimeException e) {
        creationFailure = e;
        throw e;
      }
    }
  }

  return parseResponse(call.execute());
  // 步驟2:調(diào)用OkHttpCall的execute()發(fā)送網(wǎng)絡(luò)請(qǐng)求(同步)
  // 步驟3:解析網(wǎng)絡(luò)請(qǐng)求返回的數(shù)據(jù)parseResponse() -->關(guān)注2
}

<-- 關(guān)注1:createRawCall()  -->
private okhttp3.Call createRawCall() throws IOException {
  
  Request request = serviceMethod.toRequest(args);
  // 從ServiceMethod的toRequest()返回一個(gè)Request對(duì)象
  okhttp3.Call call = serviceMethod.callFactory.newCall(request);
  // 根據(jù)serviceMethod和request對(duì)象創(chuàng)建 一個(gè)okhttp3.Request

  if (call == null) {
    throw new NullPointerException("Call.Factory returned null.");
  }
  return call;
}

<--  關(guān)注2:parseResponse()-->
Response<T> parseResponse(okhttp3.Response rawResponse) throws IOException {
  ResponseBody rawBody = rawResponse.body();

  rawResponse = rawResponse.newBuilder()
      .body(new NoContentResponseBody(rawBody.contentType(), rawBody.contentLength()))
      .build();
  // 收到返回?cái)?shù)據(jù)后進(jìn)行狀態(tài)碼檢查
  // 具體關(guān)于狀態(tài)碼說明下面會(huì)詳細(xì)介紹
  int code = rawResponse.code();
  if (code < 200 || code >= 300) {
  }

  if (code == 204 || code == 205) {
    return Response.success(null, rawResponse);
  }

  ExceptionCatchingRequestBody catchingBody = new ExceptionCatchingRequestBody(rawBody);
  try {
    T body = serviceMethod.toResponse(catchingBody);
   // 等Http請(qǐng)求返回后 & 通過狀態(tài)碼檢查后,將response body傳入ServiceMethod中蒜茴,ServiceMethod通過調(diào)用Converter接口(之前設(shè)置的GsonConverterFactory)將response body轉(zhuǎn)成一個(gè)Java對(duì)象星爪,即解析返回的數(shù)據(jù)
 

// 生成Response類
    return Response.success(body, rawResponse);
  } catch (RuntimeException e) {
    ... // 異常處理
  }
}

特別注意:

  • ServiceMethod幾乎保存了一個(gè)網(wǎng)絡(luò)請(qǐng)求所需要的數(shù)據(jù)
  • 發(fā)送網(wǎng)絡(luò)請(qǐng)求時(shí),OkHttpCall需要從ServiceMethod中獲得一個(gè)Request對(duì)象
  • 解析數(shù)據(jù)時(shí)粉私,還需要通過ServiceMethod使用Converter(數(shù)據(jù)轉(zhuǎn)換器)轉(zhuǎn)換成Java對(duì)象進(jìn)行數(shù)據(jù)解析

為了提高效率顽腾,Retrofit還會(huì)對(duì)解析過的請(qǐng)求ServiceMethod進(jìn)行緩存,存放在Map<Method, ServiceMethod> serviceMethodCache = new LinkedHashMap<>();對(duì)象中诺核,即第二步提到的單例模式

  • 關(guān)于狀態(tài)碼檢查時(shí)的狀態(tài)碼說明:
Paste_Image.png

以上便是整個(gè)以同步的方式發(fā)送網(wǎng)絡(luò)請(qǐng)求的過程抄肖。

3.2 異步請(qǐng)求OkHttpCall.enqueue()

3.2.1 發(fā)送請(qǐng)求過程
  • 步驟1:對(duì)網(wǎng)絡(luò)請(qǐng)求接口的方法中的每個(gè)參數(shù)利用對(duì)應(yīng)ParameterHandler進(jìn)行解析久信,再根據(jù)ServiceMethod對(duì)象創(chuàng)建一個(gè)OkHttpRequest對(duì)象
  • 步驟2:使用OkHttpRequest發(fā)送網(wǎng)絡(luò)請(qǐng)求;
  • 步驟3:對(duì)返回的數(shù)據(jù)使用之前設(shè)置的數(shù)據(jù)轉(zhuǎn)換器(GsonConverterFactory)解析返回的數(shù)據(jù)漓摩,最終得到一個(gè)Response<T>對(duì)象
  • 步驟4:進(jìn)行線程切換從而在主線程處理返回的數(shù)據(jù)結(jié)果

若使用了RxJava裙士,則直接回調(diào)到主線程

異步請(qǐng)求的過程跟同步請(qǐng)求類似,唯一不同之處在于:異步請(qǐng)求會(huì)將回調(diào)方法交給回調(diào)執(zhí)行器在指定的線程中執(zhí)行管毙。

指定的線程此處是指主線程(UI線程)

3.2.2 具體使用
call.enqueue(new Callback<JavaBean>() {
            @Override
            public void onResponse(Call<JavaBean> call, Response<JavaBean> response) {
                System.out.println(response.isSuccessful());
                if (response.isSuccessful()) {
                    response.body().show();
                }
                else {
                    try {
                        System.out.println(response.errorBody().string());
                    } catch (IOException e) {
                        e.printStackTrace();
                    } ;
                }
            }
  • 從上面分析有:call是一個(gè)靜態(tài)代理
  • 使用靜態(tài)代理的作用是:在okhttpCall發(fā)送網(wǎng)絡(luò)請(qǐng)求的前后進(jìn)行額外操作

這里的額外操作是:線程切換腿椎,即將子線程切換到主線程,從而在主線程對(duì)返回的數(shù)據(jù)結(jié)果進(jìn)行處理

3.2.3 源碼分析
<--  call.enqueue()解析  -->
@Override 
public void enqueue(final Callback<T> callback) {

      delegate.enqueue(new Callback<T>() {
     // 使用靜態(tài)代理 delegate進(jìn)行異步請(qǐng)求 ->>分析1
     // 等下記得回來
        @Override 
        public void onResponse(Call<T> call, final Response<T> response) {
          // 步驟4:線程切換夭咬,從而在主線程顯示結(jié)果
          callbackExecutor.execute(new Runnable() {
          // 最后Okhttp的異步請(qǐng)求結(jié)果返回到callbackExecutor
          // callbackExecutor.execute()通過Handler異步回調(diào)將結(jié)果傳回到主線程進(jìn)行處理(如顯示在Activity等等)酥诽,即進(jìn)行了線程切換
          // 具體是如何做線程切換 ->>分析2
              @Override 
               public void run() {
              if (delegate.isCanceled()) {
                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);
            }
          });
        }
      });
    }


<-- 分析1:delegate.enqueue()解析 -->
@Override 
public void enqueue(final Callback<T> callback) {
   
    okhttp3.Call call;
    Throwable failure;

// 步驟1:創(chuàng)建OkHttp的Request對(duì)象,再封裝成OkHttp.call
     // delegate代理在網(wǎng)絡(luò)請(qǐng)求前的動(dòng)作:創(chuàng)建OkHttp的Request對(duì)象皱埠,再封裝成OkHttp.call
    synchronized (this) {
      if (executed) throw new IllegalStateException("Already executed.");
      executed = true;

      call = rawCall;
      failure = creationFailure;
      if (call == null && failure == null) {
        try {
         
          call = rawCall = createRawCall(); 
          // 創(chuàng)建OkHttp的Request對(duì)象,再封裝成OkHttp.call
         // 方法同發(fā)送同步請(qǐng)求咖驮,此處不作過多描述  
        } catch (Throwable t) {
          failure = creationFailure = t;
        }
      }

// 步驟2:發(fā)送網(wǎng)絡(luò)請(qǐng)求
    // delegate是OkHttpcall的靜態(tài)代理
    // delegate靜態(tài)代理最終還是調(diào)用Okhttp.enqueue進(jìn)行網(wǎng)絡(luò)請(qǐng)求
    call.enqueue(new okhttp3.Callback() {
      @Override 
        public void onResponse(okhttp3.Call call, okhttp3.Response rawResponse)
          throws IOException {
        Response<T> response;
        try {
        
          // 步驟3:解析返回?cái)?shù)據(jù)
          response = parseResponse(rawResponse);
        } catch (Throwable e) {
          callFailure(e);
          return;
        }
        callSuccess(response);
      }

      @Override 
         public void onFailure(okhttp3.Call call, IOException e) {
        try {
          callback.onFailure(OkHttpCall.this, e);
        } catch (Throwable t) {
          t.printStackTrace();
        }
      }

      private void callFailure(Throwable e) {
        try {
          callback.onFailure(OkHttpCall.this, e);
        } catch (Throwable t) {
          t.printStackTrace();
        }
      }

      private void callSuccess(Response<T> response) {
        try {
          callback.onResponse(OkHttpCall.this, response);
        } catch (Throwable t) {
          t.printStackTrace();
        }
      }
    });
  }

// 請(qǐng)回去上面分析1的起點(diǎn)

<-- 分析2:異步請(qǐng)求后的線程切換-->
// 線程切換是通過一開始創(chuàng)建Retrofit對(duì)象時(shí)Platform在檢測(cè)到運(yùn)行環(huán)境是Android時(shí)進(jìn)行創(chuàng)建的:(之前已分析過)
// 采用適配器模式
static class Android extends Platform {

    // 創(chuàng)建默認(rèn)的回調(diào)執(zhí)行器工廠
    // 如果不將RxJava和Retrofit一起使用边器,一般都是使用該默認(rèn)的CallAdapter.Factory
    // 后面會(huì)對(duì)RxJava和Retrofit一起使用的情況進(jìn)行分析
    @Override
      CallAdapter.Factory defaultCallAdapterFactory(Executor callbackExecutor) {
      return new ExecutorCallAdapterFactory(callbackExecutor);
    }

    @Override 
      public Executor defaultCallbackExecutor() {
      // 返回一個(gè)默認(rèn)的回調(diào)方法執(zhí)行器
      // 該執(zhí)行器負(fù)責(zé)在主線程(UI線程)中執(zhí)行回調(diào)方法
      return new MainThreadExecutor();
    }

    // 獲取主線程Handler
    static class MainThreadExecutor implements Executor {
      private final Handler handler = new Handler(Looper.getMainLooper());


      @Override 
      public void execute(Runnable r) {
        // Retrofit獲取了主線程的handler
        // 然后在UI線程執(zhí)行網(wǎng)絡(luò)請(qǐng)求回調(diào)后的數(shù)據(jù)顯示等操作。
        handler.post(r);
      }
    }

// 切換線程的流程:
// 1. 回調(diào)ExecutorCallAdapterFactory生成了一個(gè)ExecutorCallbackCall對(duì)象
// 2. 通過調(diào)用ExecutorCallbackCall.enqueue(CallBack)從而調(diào)用MainThreadExecutor的execute()通過handler切換到主線程處理返回結(jié)果(如顯示在Activity等等)
  }

以上便是整個(gè)以異步方式發(fā)送網(wǎng)絡(luò)請(qǐng)求的過程托修。


5. 總結(jié)

Retrofit 本質(zhì)上是一個(gè) RESTfulHTTP 網(wǎng)絡(luò)請(qǐng)求框架的封裝忘巧,即通過 大量的設(shè)計(jì)模式 封裝了 OkHttp ,使得簡潔易用睦刃。具體過程如下:

  1. RetrofitHttp請(qǐng)求 抽象 成 Java接口
  2. 在接口里用 注解 描述和配置 網(wǎng)絡(luò)請(qǐng)求參數(shù)
  3. 用動(dòng)態(tài)代理 的方式砚嘴,動(dòng)態(tài)將網(wǎng)絡(luò)請(qǐng)求接口的注解 解析 成HTTP請(qǐng)求
  4. 最后執(zhí)行HTTP請(qǐng)求

最后貼一張非常詳細(xì)的Retrofit源碼分析圖:

Retrofit源碼分析圖

6. 最后

Carson帶你學(xué)Android開源庫系列文章:
Carson帶你學(xué)Android:主流開源圖片加載庫對(duì)比(UIL际长、Picasso、Glide兴泥、Fresco)
Carson帶你學(xué)Android:主流開源網(wǎng)絡(luò)請(qǐng)求庫對(duì)比(Volley工育、OkHttp、Retrofit)
Carson帶你學(xué)Android:網(wǎng)絡(luò)請(qǐng)求庫Retrofit使用教程
Carson帶你學(xué)Android:網(wǎng)絡(luò)請(qǐng)求庫Retrofit源碼分析
Carson帶你學(xué)Android:圖片加載庫Glide使用教程
Carson帶你學(xué)Android:圖片加載庫Glide源碼分析
Carson帶你學(xué)Android:V-Layout搓彻,淘寶如绸、天貓都在用的UI框架,趕緊用起來吧旭贬!


歡迎關(guān)注Carson_Ho的簡書

不定期分享關(guān)于安卓開發(fā)的干貨怔接,追求短、平稀轨、快扼脐,但卻不缺深度


請(qǐng)點(diǎn)贊靶端!因?yàn)槟愕墓膭?lì)是我寫作的最大動(dòng)力谎势!

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末凛膏,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子脏榆,更是在濱河造成了極大的恐慌猖毫,老刑警劉巖,帶你破解...
    沈念sama閱讀 206,839評(píng)論 6 482
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件须喂,死亡現(xiàn)場離奇詭異吁断,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)坞生,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,543評(píng)論 2 382
  • 文/潘曉璐 我一進(jìn)店門仔役,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人是己,你說我怎么就攤上這事又兵。” “怎么了卒废?”我有些...
    開封第一講書人閱讀 153,116評(píng)論 0 344
  • 文/不壞的土叔 我叫張陵沛厨,是天一觀的道長。 經(jīng)常有香客問我摔认,道長逆皮,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 55,371評(píng)論 1 279
  • 正文 為了忘掉前任参袱,我火速辦了婚禮电谣,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘抹蚀。我一直安慰自己剿牺,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 64,384評(píng)論 5 374
  • 文/花漫 我一把揭開白布环壤。 她就那樣靜靜地躺著牢贸,像睡著了一般。 火紅的嫁衣襯著肌膚如雪镐捧。 梳的紋絲不亂的頭發(fā)上潜索,一...
    開封第一講書人閱讀 49,111評(píng)論 1 285
  • 那天,我揣著相機(jī)與錄音懂酱,去河邊找鬼竹习。 笑死,一個(gè)胖子當(dāng)著我的面吹牛列牺,可吹牛的內(nèi)容都是我干的整陌。 我是一名探鬼主播,決...
    沈念sama閱讀 38,416評(píng)論 3 400
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢(mèng)啊……” “哼泌辫!你這毒婦竟也來了随夸?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 37,053評(píng)論 0 259
  • 序言:老撾萬榮一對(duì)情侶失蹤震放,失蹤者是張志新(化名)和其女友劉穎宾毒,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體殿遂,經(jīng)...
    沈念sama閱讀 43,558評(píng)論 1 300
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡诈铛,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,007評(píng)論 2 325
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了墨礁。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片幢竹。...
    茶點(diǎn)故事閱讀 38,117評(píng)論 1 334
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖恩静,靈堂內(nèi)的尸體忽然破棺而出焕毫,到底是詐尸還是另有隱情,我是刑警寧澤驶乾,帶...
    沈念sama閱讀 33,756評(píng)論 4 324
  • 正文 年R本政府宣布咬荷,位于F島的核電站,受9級(jí)特大地震影響轻掩,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜懦底,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,324評(píng)論 3 307
  • 文/蒙蒙 一唇牧、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧聚唐,春花似錦丐重、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,315評(píng)論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至亲桦,卻和暖如春崖蜜,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背客峭。 一陣腳步聲響...
    開封第一講書人閱讀 31,539評(píng)論 1 262
  • 我被黑心中介騙來泰國打工豫领, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人舔琅。 一個(gè)月前我還...
    沈念sama閱讀 45,578評(píng)論 2 355
  • 正文 我出身青樓等恐,卻偏偏與公主長得像,于是被迫代替她去往敵國和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子课蔬,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,877評(píng)論 2 345

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

  • Retrofit是squareup公司的開源力作二跋,和同屬squareup公司開源的OkHttp战惊,一個(gè)負(fù)責(zé)網(wǎng)絡(luò)調(diào)度,...
    藍(lán)灰_q閱讀 41,264評(píng)論 23 281
  • 簡介 剛接觸Retrofit的時(shí)候同欠,就寫了一篇簡單的使用介紹:Retrofit 2.0基本使用方法,算是對(duì)Retr...
    Whyn閱讀 2,836評(píng)論 4 24
  • 安卓開發(fā)領(lǐng)域中样傍,很多重要的問題都有很好的開源解決方案,例如Square公司提供網(wǎng)絡(luò)請(qǐng)求 OkHttp , Retr...
    aaron688閱讀 1,903評(píng)論 1 20
  • 適配器模式上一篇文章我們已經(jīng)分析了Retrofit解析注解封裝進(jìn)ServiceMethod的流程铺遂,讀者在這里要記住...
    andcoder閱讀 644評(píng)論 0 2
  • 執(zhí)手相看淚眼衫哥,竟無語凝咽 -------柳永 不知什么時(shí)候起,愛成了等待的親友襟锐,有愛的地方撤逢,等待便靜靜的站在那里;...
    隨遇而安的葉子閱讀 668評(píng)論 0 2