利用java中的注解,反射,动态代理实现Retrofit

静态代理

静态代理我们都知道只能代理某一个接口,我记得之前有一个项目中使用的是httpClient,但是Google后来将httpclient移除了,我们后来使用了volley,但是发现需要修改的地方太多了,后来使用静态代理写了一个中间层,在代码中不直接调用具体的请求网络框架,而是使用中间代理层,这样以后换网络框架的时候只需要让新的框架实现请求网络接口就好了。

Retrofit的用法

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("xxx")
    .build();

XXService service = retrofit.create(XXService.class);

interface XXService {
    @GET("xx/xxx")
    public Call getXX(@Query("xx") String xx);

    @POST("xx/xxx")
    public Call postXX(@Field("xx") String xx);
}

定义注解

注解的生命周期
1.SOURCE 用来对代码进行检测,添加辅助类。
2.CLASS 字节码增强,修改字节码代码。
3.RUNTIME 反射,在运行时赋值等。
1.定一个GET,POST注解

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface GET{
      String value();
}
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface POST{
      String value();
}

2.定义Field,Query注解

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.PARAMETER)
public @interface Query {
    String value();
}
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.PARAMETER)
public @interface Field {
    String value();
}

定义Retrofit类

我们在使用的时候是用建造者模式来生成Retrofit对象的,建造者模式可以在build方法中对设置的数据进行判断,并且设置了baseurl和callAdapterFactory等

public class Retrofit{

    static class Builder{
        private HttpUrl baseUrl;
        private Call.Factory callFactory;

        public Builder baseUrl(String url){
            this.baseUrl=HttpUrl.get(url);
            return this;
        }

        public Builder callFactory(Call.Factory factory){
            this.callFactory=factory;

            return this;
        }

        public Retrofit build(){
            if (baseUrl==null){
                throw new IllegalArgumentException("baseurl can not null");
            }

            if (callFactory==null){
                callFactory=new OkHttpClient();
            }

            return new Retrofit(baseUrl,callFactory);
        }
    }
}

在Retrofit中创建create方法

通过create方法生成接口的代理对象,当调用接口中的某一个方法的时候对该方法上的注解进行解析
在解析的过程中我们为了保证不是每次调用都需要解析,所以我们使用map集合将解析的数据都保存下来

public <T> T create(Class<T> clazz) {
        return (T) Proxy.newProxyInstance(this.getClass().getClassLoader(), new Class[]{clazz}, new InvocationHandler() {
            @Override
            public Object invoke(Object proxy, Method method, Object[] args){
                ServiceMethod serviceMethod=loadServiceMethod(method);
                return serviceMethod.invoke(args);
            }
        });
    }
private ServiceMethod loadServiceMethod(Method method) {
        ServiceMethod result = serviceMethodCache.get(method);
        if (result!=null)
            return result;
        //A线程如果还没有将数据put待集合中,B线程也会走到这里,所以在锁里面需要再判断一次
        synchronized (serviceMethodCache){
            result=serviceMethodCache.get(method);
            if (result==null){
                result=new ServiceMethod.Builder(this,method).build();
                serviceMethodCache.put(method,result);
            }
        }
        return result;
    }

ServiceMethod

在ServiceMethod中来解析并存放数据,在调用invoke方法的时候使用okhttp进行网络请求

public class ServiceMethod {

    private final String requestMethod;
    private final boolean hasBody;
    private final ParameterHandler[] parameterHandlers;
    private final String releativeUrl;
    private final HttpUrl baseUrl;
    private final Call.Factory callFactory;
    private FormBody.Builder formBuild;
    private HttpUrl.Builder urlBuilder;

    public ServiceMethod(Builder builder) {
        requestMethod = builder.requestMethod;

        hasBody = builder.hasBody;

        parameterHandlers = builder.parameterHandlers;

        releativeUrl = builder.releativeUrl;

        baseUrl = builder.retrofit.baseUrl;

        callFactory = builder.retrofit.callFactory;

        if (hasBody){
            formBuild = new FormBody.Builder();
        }
    }

    public Object invoke(Object[] args) {
        for (int i = 0; i < parameterHandlers.length; i++) {
            ParameterHandler parameterHandler = parameterHandlers[i];

            parameterHandler.apply(this,args[i].toString());
        }

        if (urlBuilder==null){
            urlBuilder=baseUrl.newBuilder(releativeUrl);
        }

        HttpUrl httpUrl = urlBuilder.build();

        FormBody build = null;
        if (formBuild!=null){
            build = formBuild.build();
        }

        Request request = new Request.Builder().url(httpUrl).method(requestMethod, build).build();

        return callFactory.newCall(request);
    }

    public void addQueryParameter(String key,String value) {
        if (urlBuilder==null){
            urlBuilder=baseUrl.newBuilder(releativeUrl);
        }
        urlBuilder.addQueryParameter(key,value);
    }

    public void addFieldParameter(String key,String value) {
        formBuild.add(key,value);
    }

    public static class Builder{
        private final Retrofit retrofit;
        private final Annotation[] methodAnnotations;
        private final Annotation[][] parameterAnnotations;
        private String requestMethod;
        private String releativeUrl;
        private boolean hasBody;
        private ParameterHandler[] parameterHandlers;

        public Builder(Retrofit retrofit, Method method) {

            this.retrofit=retrofit;


            methodAnnotations = method.getAnnotations();

            parameterAnnotations = method.getParameterAnnotations();

        }

        public ServiceMethod build(){
            for (Annotation methodAnnotation :
                    methodAnnotations) {
                if (methodAnnotation instanceof POST){
                    this.releativeUrl = ((POST) methodAnnotation).value();
                    this.requestMethod="POST";
                    this.hasBody=true;
                }else if (methodAnnotation instanceof GET){
                    this.releativeUrl = ((GET) methodAnnotation).value();
                    this.requestMethod="GET";
                    this.hasBody=false;
                }
            }

            int length = parameterAnnotations.length;

            parameterHandlers = new ParameterHandler[length];
            for (int i = 0; i < length; i++) {
                Annotation[] parameterAnnotation = parameterAnnotations[i];
                for (Annotation annotation :
                        parameterAnnotation) {
                    if (annotation instanceof Query) {
                        String value = ((Query) annotation).value();
                        if (requestMethod.equals("POST")){
                            throw new IllegalArgumentException("post request can not use query");
                        }
                        parameterHandlers[i]=new ParameterHandler.QueryParameterHandler(value);
                    }else if (annotation instanceof Field){
                        String value = ((Field) annotation).value();
                        if (requestMethod.equals("GET")){
                            throw new IllegalArgumentException("get request can not use field");
                        }

                        parameterHandlers[i]=new ParameterHandler.FieldParameterHandler(value);
                    }
                }
            }


            return new ServiceMethod(this);
        }
    }
}

ParameterHandler

在这个类里面存储参数的键值对

public abstract class ParameterHandler{
    public abstract void apply(ServiceMethod serviceMethod,String value);


    static class QueryParameterHandler extends ParameterHandler{
        private final String key;

        public QueryParameterHandler(String value) {
            this.key=value;
        }

        @Override
        public void apply(ServiceMethod serviceMethod, String value) {
            serviceMethod.addQueryParameter(key,value);
        }
    }

    static class FieldParameterHandler extends ParameterHandler{
        private final String key;

        public FieldParameterHandler(String value) {
            this.key=value;
        }

        @Override
        public void apply(ServiceMethod serviceMethod, String value) {
            serviceMethod.addFieldParameter(key,value);
        }
    }
}

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,937评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,503评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,712评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,668评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,677评论 5 366
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,601评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,975评论 3 396
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,637评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,881评论 1 298
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,621评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,710评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,387评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,971评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,947评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,189评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,805评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,449评论 2 342