日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

?[[422495]]??

本文轉(zhuǎn)載自微信公眾號「Android開發(fā)編程」，作者Android開發(fā)編程。轉(zhuǎn)載本文請聯(lián)系A(chǔ)ndroid開發(fā)編程公眾號。

前言

Retrofit是一個基于AOP思想，對RestfulApi注解進(jìn)行動態(tài)代理的網(wǎng)絡(luò)框架;

今天我們就來探討下實(shí)現(xiàn)原理，一起進(jìn)步

一、使用Retrofit

1、包引用

在gradle文件中引用retrofit

compile 'com.squareup.retrofit2:retrofit:2.3.0'     compile 'com.squareup.retrofit2:retrofit-converters:2.3.0'     compile 'com.squareup.retrofit2:retrofit-adapters:2.3.0' 

如果需要使用更多擴(kuò)展功能，比如gson轉(zhuǎn)換，rxjava適配等，可以視自己需要繼續(xù)添加引用;

compile 'com.squareup.retrofit2:converter-gson:2.3.0'     compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0' 

如果現(xiàn)有的擴(kuò)展包不能滿足需要，還可以自己擴(kuò)展converter，adapter等;

2、定義接口

Retrofit要求定義一個網(wǎng)絡(luò)請求的接口，接口函數(shù)里要定義url路徑、請求參數(shù)、返回類型;

public interface INetApiService {     @GET("/demobiz/api.php")     Call getBizInfo(@Query("id") String id); } 

在這個接口定義中，用注解@GET("/demobiz/api.php")聲明了url路徑，用注解@Query("id") 聲明了請求參數(shù);

最重要的是，用Call聲明了返回值是一個Retrofit的Call對象，并且聲明了這個對象處理的數(shù)據(jù)類型為BizEntity，BizEntity是我們自定義的數(shù)據(jù)模型;

3、依次獲得Retrofit對象、接口實(shí)例對象、網(wǎng)絡(luò)工作對象

首先，需要新建一個retrofit對象;

然后，根據(jù)上一步的接口，實(shí)現(xiàn)一個retrofit加工過的接口對象;

最后，調(diào)用接口函數(shù)，得到一個可以執(zhí)行網(wǎng)絡(luò)訪問的網(wǎng)絡(luò)工作對象;

//新建一個Retrofit對象 Retrofit retrofit=new Retrofit.Builder() .baseUrl(Config.DOMAIN)//要訪問的網(wǎng)絡(luò)地址域名，如http://www.zhihu.com .addConverterFactory(GsonConverterFactory.create()) .build(); ... //用retrofit加工出對應(yīng)的接口實(shí)例對象 INetApiService netApiService= retrofit.create(INetApiService.class); //可以繼續(xù)加工出其他接口實(shí)例對象 IOtherService otherService= retrofit.create(IOtherService.class); ··· //調(diào)用接口函數(shù)，獲得網(wǎng)絡(luò)工作對象 Call callWorker= netApiService.getBizInfo("id001"); 

這個復(fù)雜的過程下來，最終得到的callWorker對象，才可以執(zhí)行網(wǎng)絡(luò)訪問。

4、訪問網(wǎng)絡(luò)數(shù)據(jù)

用上一步獲取的worker對象，執(zhí)行網(wǎng)絡(luò)請求

callWorker.enqueue(new Callback() {             @Override             public void onResponse(Call call, Response response) {...}             @Override             public void onFailure(Call call, Throwable t) {...}         }); 

在回調(diào)函數(shù)里，取得我們需要的BizEntity數(shù)據(jù)對象

二、Retrofit實(shí)現(xiàn)原理

???

1、Retrofit對象的構(gòu)建就是簡單的builder模式，直接看create

//Retrofit.java public  T create(final Class service) {     //驗證     validateServiceInterface(service);     return (T)         //動態(tài)代理         Proxy.newProxyInstance(         service.getClassLoader(), //類加載器         new Class[] {service}, //一組接口         new InvocationHandler() {             //判斷android和jvm平臺及其版本             private final Platform platform = Platform.get();             @Override             public Object invoke(Object proxy, Method method, Object[] args){                 //如果該方法是Object的方法，直接執(zhí)行不用管                 if (method.getDeclaringClass() == Object.class) {                     return method.invoke(this, args);                 }                 //isDefaultMethod：檢查是否是java8開始支持的接口默認(rèn)方法                 return platform.isDefaultMethod(method)                     ? platform.invokeDefaultMethod(method, service, proxy, args)                     : loadServiceMethod(method).invoke(args); //我們關(guān)注這里             }         }); } 

Proxy.newProxyInstance動態(tài)代理，運(yùn)行期會生成一個類(字節(jié)碼)如$ProxyN，實(shí)現(xiàn)傳入的接口即WanApi，重寫接口方法然后轉(zhuǎn)發(fā)給InvocationHandler的invoke

class $ProxyN extends Proxy implements WanApi{     Call articleList(@Path("page") int page){         //轉(zhuǎn)發(fā)給invocationHandler         invocationHandler.invoke(this,method,args);     } } 

2、validateServiceInterface驗證邏輯

//Retrofit.java private void validateServiceInterface(Class service) {     //檢查：WanApi不是接口就拋異常...     //檢查：WanApi不能有泛型參數(shù)，不能實(shí)現(xiàn)其他接口...     if (validateEagerly) { //是否進(jìn)行嚴(yán)格檢查，默認(rèn)關(guān)閉         Platform platform = Platform.get();         for (Method method : service.getDeclaredMethods()) { //遍歷WanApi方法             //不是默認(rèn)方法，并且不是靜態(tài)方法             if (!platform.isDefaultMethod(method) && !Modifier.isStatic(method.getModifiers())) {                 //把方法提前加載進(jìn)來（檢查下有沒有問題）                 loadServiceMethod(method);             }         }     } } 

如果開了validateEagerly，會一次性把接口WanApi的所有方法都檢查一遍并加載進(jìn)來，可以在debug模式下開啟，提前發(fā)現(xiàn)錯誤寫法，比如在@GET請求設(shè)置了@Body這種錯誤就會拋出異常：

java.lang.IllegalArgumentException: Non-body HTTP method cannot contain @Body. 

3、loadServiceMethod

然后是loadServiceMethod(method).invoke(args)，看名字可知是先找方法，然后執(zhí)行

//Retrofit.java //緩存，用了線程安全ConcurrentHashMap final Map> serviceMethodCache = new ConcurrentHashMap<>(); ServiceMethod loadServiceMethod(Method method) {     ServiceMethod result = serviceMethodCache.get(method);     //WanApi的articleList方法已緩存，直接返回     if (result != null) return result;     synchronized (serviceMethodCache) {         result = serviceMethodCache.get(method);         if (result == null) {             //解析articleList的注解，創(chuàng)建ServiceMethod并緩存起來             result = ServiceMethod.parseAnnotations(this, method);             serviceMethodCache.put(method, result);         }     }     return result; } 

跟進(jìn)ServiceMethod.parseAnnotations

//ServiceMethod.java static  ServiceMethod parseAnnotations(Retrofit retrofit, Method method) {     //1.     RequestFactory requestFactory = RequestFactory.parseAnnotations(retrofit, method);     //檢查：articleList方法返回類型不能用通配符和void...     //2.     return HttpServiceMethod.parseAnnotations(retrofit, method, requestFactory); } 

4、 RequestFactory.parseAnnotations

//RequestFactory.java static RequestFactory parseAnnotations(Retrofit retrofit, Method method) {     return new Builder(retrofit, method).build(); } class Builder {     RequestFactory build() {         //解析方法注解如GET         for (Annotation annotation : methodAnnotations) {             parseMethodAnnotation(annotation);         }         //省略各種檢查...         //解析參數(shù)注解如Path         int parameterCount = parameterAnnotationsArray.length;         parameterHandlers = new ParameterHandler[parameterCount];         for (int p = 0, lastParameter = parameterCount - 1; p < parameterCount; p++) {             parameterHandlers[p] =                 parseParameter(p, parameterTypes[p], parameterAnnotationsArray[p], p == lastParameter);         }         //省略各種檢查...         return new RequestFactory(this);     } } 

得到RequestFactory后， HttpServiceMethod.parseAnnotations，HttpServiceMethod負(fù)責(zé)適配和轉(zhuǎn)換處理，將接口方法的調(diào)用調(diào)整為HTTP調(diào)用

//HttpServiceMethod.java //ResponseT響應(yīng)類型如WanArticleBean，ReturnT返回類型如Call static  HttpServiceMethod parseAnnotations(     Retrofit retrofit, Method method, RequestFactory requestFactory) {     //省略kotlin協(xié)程邏輯...     Annotation[] annotations = method.getAnnotations();     //遍歷找到合適的適配器     CallAdapter callAdapter =         createCallAdapter(retrofit, method, adapterType, annotations);     //得到響應(yīng)類型，如WanArticleBean     Type responseType = callAdapter.responseType();     //遍歷找到合適的轉(zhuǎn)換器     Converter responseConverter =         createResponseConverter(retrofit, method, responseType);     okhttp3.Call.Factory callFactory = retrofit.callFactory;     return new CallAdapted<>(requestFactory, callFactory, responseConverter, callAdapter); } 

5、最終返回了一個CallAdapted，看到CallAdapted

//CallAdapted extends HttpServiceMethod extends ServiceMethod class CallAdapted extends HttpServiceMethod {     private final CallAdapter callAdapter;     CallAdapted(         RequestFactory requestFactory,         okhttp3.Call.Factory callFactory,         Converter responseConverter,         CallAdapter callAdapter) {         super(requestFactory, callFactory, responseConverter);         this.callAdapter = callAdapter;     }     @Override     protected ReturnT adapt(Call call, Object[] args) {         //適配器         return callAdapter.adapt(call);     } } 

回到Retrofit.Builder

//Retrofit.Builder.java public Retrofit build() {     Executor callbackExecutor = this.callbackExecutor;     //如果沒設(shè)置線程池，則給android平臺設(shè)置一個默認(rèn)的MainThreadExecutor（用Handler將回調(diào)切回主線程）     if (callbackExecutor == null) {         callbackExecutor = platform.defaultCallbackExecutor();     }     List callAdapterFactories = new ArrayList<>(this.callAdapterFactories);     //添加默認(rèn)的DefaultCallAdapterFactory     callAdapterFactories.addAll(platform.defaultCallAdapterFactories(callbackExecutor)); } 

DefaultCallAdapterFactory這個工廠創(chuàng)建具體的CallAdapter實(shí)例

//DefaultCallAdapterFactory.java public CallAdapter get(Type returnType, Annotation[] annotations, Retrofit retrofit) {     final Type responseType = Utils.getParameterUpperBound(0, (ParameterizedType) returnType);     //如果指定了SkipCallbackExecutor注解，就表示不需要切回主線程     final Executor executor =         Utils.isAnnotationPresent(annotations, SkipCallbackExecutor.class)         ? null         : callbackExecutor;     return new CallAdapter>() {         @Override         public Type responseType() {             return responseType;         }         @Override         public Call