簡單實現Retrofit（替代Okhttp）
1.定義注解參數
@Documented
@Target(PARAMETER)
@Retention(RUNTIME)
public @interface Field {String value();
}
復制代碼@Documented
@Target(METHOD)
@Retention(RUNTIME)
public @interface Get {String value() default "";
}
復制代碼@Documented
@Target(METHOD)
@Retention(RUNTIME)
public @interface Post {String value() default "";
}
復制代碼2.實現回調接口Call和Callback MyCall .class
public interface MyCall {//執行網絡請求（同步：在當前網絡）String execute() throws Exception;//在子線程請求網絡void enqueue(MyCallback callback);
}
復制代碼MyCallback .class
/*** 網絡請求回調接口*/
public interface MyCallback {void onResponse( String response);void onFailure( Exception e);
}
復制代碼SystemHttpCall .class
/*** Created by Xionghu on 2017/8/14.* Desc: 具體的實現類發送請求*/public class SystemHttpCall implements MyCall {private MyServiceMethod serviceMethod;public SystemHttpCall(MyServiceMethod serviceMethod) {this.serviceMethod = serviceMethod;}@Overridepublic String execute() throws Exception {if (serviceMethod.isPost()) {return HttpUtils.post(serviceMethod.baseUrl(), serviceMethod.getParam());} else {return HttpUtils.get(serviceMethod.baseUrl());}}@Overridepublic void enqueue(MyCallback callback) {HttpTask httpTask = new HttpTask(this, callback);httpTask.execute();}public class HttpTask extends AsyncTask<Void, Void, String> {private SystemHttpCall httpCall;private MyCallback callback;private HttpTask(SystemHttpCall httpCall, MyCallback callback) {this.httpCall = httpCall;this.callback = callback;}@Overrideprotected String doInBackground(Void... params) {try {return httpCall.execute();} catch (Exception e) {e.printStackTrace();}return null;}@Overrideprotected void onPostExecute(String result) {if (this.callback != null) {if (result != null) {this.callback.onResponse(result);} else {this.callback.onFailure(new Exception("網絡異常！"));}}}}
}
復制代碼3.解析注解方法獲取相應參數
public class MyServiceMethod {private Builder builder;public MyServiceMethod(Builder builder) {this.builder = builder;}public boolean isPost() {return this.builder.isPost;}public Map<String, Object> getParam() {return this.builder.paramMap;}public String baseUrl() {StringBuffer buffer = new StringBuffer(this.builder.retrofit.getBaseUrl() + this.builder.relativeUrl);if (!isPost()) {// 如果你不是Post請求，是get請求，需要拼接參數地址if (this.builder.paramMap != null) {Set<String> keySet = this.builder.paramMap.keySet();if (keySet.size() > 0) {buffer.append("?");}for (String key : keySet) {Object value = this.builder.paramMap.get(key);buffer.append(key);buffer.append("=");buffer.append(value);buffer.append("&");}buffer.deleteCharAt(buffer.length() - 1);}}return buffer.toString();}static final class Builder {final MyRetrofit retrofit;final Method method;final Annotation[] methodAnnotations;final Annotation[][] parameterAnnotationsArray;String relativeUrl;// 參數集合Map<String, Object> paramMap;Object[] args;boolean isPost;public Builder(MyRetrofit retrofit, Method method, Object[] args) {this.retrofit = retrofit;this.method = method;// 方法注解列表(相當于我們的LoginService中的: @POST和@FormUrlEncoded......)this.methodAnnotations = method.getAnnotations();// 方法參數注解列表(相當于我們的LoginService中的: @Field......)this.parameterAnnotationsArray = method.getParameterAnnotations();this.args = args;this.paramMap = new HashMap<String, Object>();}public MyServiceMethod build() {// 循環遍歷方法注解列表for (Annotation annotation : methodAnnotations) {parseMethodAnnotation(annotation);}int parameterCount = parameterAnnotationsArray.length;for (int p = 0; p < parameterCount; p++) {Annotation[] parameterAnnotations = parameterAnnotationsArray[p];parseParameterAnnotation(p, parameterAnnotations);}return new MyServiceMethod(this);}/*** 解析方法注解** @param annotation*/public void parseMethodAnnotation(Annotation annotation) {// 首先判斷注解類型(解析目的：獲取接口名稱,用于拼接地址)if (annotation instanceof Get) {this.relativeUrl = ((Get) annotation).value();isPost = false;} else if (annotation instanceof Post) {this.relativeUrl = ((Post) annotation).value();isPost = true;}}/*** 解析參數注解** @param p* @param parameterAnnotations*/private void parseParameterAnnotation(int p,Annotation[] parameterAnnotations) {// 方法參數值Object value = args[p];// 遍歷方法參數注解for (Annotation annotation : parameterAnnotations) {// 首先需要判斷該注解的類型if (annotation instanceof Field) {Field field = (Field) annotation;// 參數的名稱(接口參數名稱，服務器接口規定的)String key = field.value();paramMap.put(key, value);}}}}
}
復制代碼4.定義MyRetrofit框架
public class MyRetrofit {// 緩存方法(為了避免重復加載方法注解，從而耗費性能)private final Map<Method, MyServiceMethod> serviceMethodCache = new LinkedHashMap<Method, MyServiceMethod>();public String getBaseUrl() {return baseUrl;}public void setBaseUrl(String baseUrl) {this.baseUrl = baseUrl;}private String baseUrl;private MyRetrofit(String baseUrl){this.baseUrl = baseUrl;}public <T> T create(Class<T> service){//動態代理實現return (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[]{service}, new InvocationHandler() {@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {MyServiceMethod serviceMethod = loadServiceMethod(method, args);SystemHttpCall httpCall = new SystemHttpCall(serviceMethod);return httpCall;}});}// 第一步：解析方法（說白了解析方法注解和方法參數注解）// 第二步：實現網絡請求protected MyServiceMethod loadServiceMethod(Method method, Object[] args) {MyServiceMethod result;synchronized (serviceMethodCache) {result = serviceMethodCache.get(method);if (result == null) {result = new MyServiceMethod.Builder(this, method, args).build();serviceMethodCache.put(method, result);}}return result;}public static final class Builder{private String baseUrl;public Builder baseUrl(String baseUrl){this.baseUrl = baseUrl;return this;}public MyRetrofit build(){if(baseUrl == null){throw new IllegalStateException("Base URL required.");}return new MyRetrofit(baseUrl);}}}
復制代碼5.具體實現網絡請求類 定義接口方法類
public interface MyRetrofitLoginService {
@Post("user/login?platform=android&city_id=101&type=pwd&channel=baiduxi&version=3.2.0&os_version=6.0.1&device_id=866622020797175")MyCall login(@Field("mobile") String name, @Field("password") String pwd);
}
復制代碼簡單封裝請求工具類
public class MyRetrofitTest {private static String URL_SERVER = "http://api.cloud.test.haocaisong.cn/v2.0/";public static void login(String name, String pwd, final SimpleSystemLogin.OnHttpResultListener onHttpResultListener) {MyRetrofit myRetrofit = new MyRetrofit.Builder().baseUrl(URL_SERVER).build();MyRetrofitLoginService loginService = myRetrofit.create(MyRetrofitLoginService.class);MyCall myCall = loginService.login(name,pwd);myCall.enqueue(new MyCallback() {@Overridepublic void onResponse(String response) {onHttpResultListener.onHttpResult(response);}@Overridepublic void onFailure(Exception e) {}});}
}
復制代碼
