AndroidInject项目使用动态代理增加对网络请求的支持

  1 package com.wangjie.androidinject.annotation.core.net;
  2 
  3 import android.text.TextUtils;
  4 import com.google.gson.Gson;
  5 import com.wangjie.androidinject.annotation.annotations.net.AIGet;
  6 import com.wangjie.androidinject.annotation.annotations.net.AIParam;
  7 import com.wangjie.androidinject.annotation.annotations.net.AIPost;
  8 import com.wangjie.androidinject.annotation.util.Params;
  9 import com.wangjie.androidinject.annotation.util.StringUtil;
 10 
 11 import java.lang.annotation.Annotation;
 12 import java.lang.reflect.InvocationHandler;
 13 import java.lang.reflect.Method;
 14 import java.lang.reflect.Proxy;
 15 import java.util.HashMap;
 16 import java.util.Map;
 17 
 18 /**
 19  * Created with IntelliJ IDEA.
 20  * Author: wangjie  email:[email protected]
 21  * Date: 14-2-7
 22  * Time: 下午1:40
 23  */
 24 public class NetInvoHandler implements InvocationHandler{
 25     private static HashMap<Class<?>, NetInvoHandler> invoHandlers = new HashMap<Class<?>, NetInvoHandler>();
 26 
 27     private Object proxy; // 代理对象
 28 
 29     public synchronized  static<T> T getWorker(Class<T> clazz){
 30         NetInvoHandler netInvoHandler = invoHandlers.get(clazz);
 31         if(null == netInvoHandler){
 32             netInvoHandler = new NetInvoHandler();
 33             netInvoHandler.setProxy(Proxy.newProxyInstance(clazz.getClassLoader(), new Class[]{clazz}, netInvoHandler));
 34             invoHandlers.put(clazz, netInvoHandler);
 35         }
 36         return (T)netInvoHandler.getProxy();
 37     }
 38 
 39     @Override
 40     public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
 41 
 42         // get请求
 43         if(method.isAnnotationPresent(AIGet.class)){
 44             AIGet aiGet = method.getAnnotation(AIGet.class);
 45             String url = aiGet.value();
 46             if(TextUtils.isEmpty(url)){
 47                 throw new Exception("net work [" + method.getName() + "]@AIGet value()[url] is empty!!");
 48             }
 49             Annotation[][] annotaions = method.getParameterAnnotations();
 50             for(int i = 0; i < args.length; i++){
 51                 if(Params.class.isAssignableFrom(args[i].getClass())){ // 如果属性为Params，则追加在后面
 52                     url = StringUtil.appendParamsAfterUrl(url, (Params)args[i]);
 53                 }else{ // 如果属性添加了@AIParam注解，则替换链接中#{xxx}
 54                     String repName = ((AIParam)annotaions[i][0]).value();
 55                     url = url.replace("#{" + repName + "}", args[i] + "");
 56                 }
 57 
 58             }
 59             StringBuilder sb = NetWork.getStringFromUrl(url);
 60             if(null == sb){
 61                 return null;
 62             }
 63             return new Gson().fromJson(sb.toString(), method.getReturnType());
 64         }
 65 
 66         // post请求
 67         if(method.isAnnotationPresent(AIPost.class)){
 68             AIPost aiPost = method.getAnnotation(AIPost.class);
 69             String url = aiPost.value();
 70             if(TextUtils.isEmpty(url)){
 71                 throw new Exception("net work [" + method.getName() + "]@AIPost value()[url] is empty!!");
 72             }
 73             Annotation[][] annotaions = method.getParameterAnnotations();
 74             Map<String, String> map = new HashMap<String, String>();
 75             for(int i = 0; i < args.length; i++){
 76                 if(Params.class.isAssignableFrom(args[i].getClass())){ // 如果属性为Params，则追加在后面
 77                     map.putAll((Params)args[i]);
 78                 }else{
 79                     String repName = ((AIParam)annotaions[i][0]).value();
 80                     map.put(repName, args[i] + "");
 81                 }
 82 
 83             }
 84             StringBuilder sb = NetWork.postStringFromUrl(url, map);
 85             if(null == sb){
 86                 return null;
 87             }
 88             return new Gson().fromJson(sb.toString(), method.getReturnType());
 89 
 90         }
 91 
 92 
 93         return null;
 94     }
 95 
 96 
 97     public Object getProxy() {
 98         return proxy;
 99     }
100 
101     public void setProxy(Object proxy) {
102         this.proxy = proxy;
103     }
104 }