美文网首页编程学习码农进阶之旅Net
一起实现一下网络请求吧(Retrofit2+rxjava)

一起实现一下网络请求吧(Retrofit2+rxjava)

作者: We7ex | 来源:发表于2017-01-02 23:57 被阅读910次

    关于Retrofit+RxJava的基本用法,本文不作详细介绍,可以参考
    Retrofit官方文档
    Retrofit官方文档
    给 Android 开发者的 RxJava 详解

    使用gradle导入对应的库

    //retrofit
    compile 'com.squareup.retrofit2:retrofit:2.0.2'
    //网络请求拦截器
    compile 'com.squareup.okhttp3:logging-interceptor:3.2.0'
    //gson解析
    compile 'com.squareup.retrofit2:converter-gson:2.0.2'
    //rxjavacompile 'io.reactivex:rxandroid:1.1.0'
    compile 'com.squareup.retrofit2:adapter-rxjava:2.0.2'
    //dragger2 <不使用Dragger2可以选择不导入下面的库>
    provided 'org.glassfish:javax.annotation:10.0-b28'
    apt 'com.google.dagger:dagger-compiler:2.0.2'
    compile 'com.google.dagger:dagger:2.0.2'
    

    先上例子

    BaseApplication.get(BaseApplication.getAppContext()).
         getComponent()
        .getAPIModule()
        .getConvstGroup(uid, token)
        .subscribe(new BaseSubscribe<GroupBean>(groupView) {    
            @Override    
         public void onResponse(GroupBean bean) {        
                  groupView.addGroups(bean.list);    
      }
    });
    

    我们一个一个来看

    首先是getConvstGroup()前面的是Dragger2在这里就先不做解释了
    code1

    @Provides
    @Singleton
    public Observable<GroupBean> getConvstGroup(int uid, String token) {    
        return getService().getConvstGroup(uid, token).map(new HttpResultFunc<GroupBean>()).compose(this.<GroupBean>applySchedulers());
    }
    

    code2

    /** 
    * 获取最近小组相关的列表 * 
    * @param uid 
    * @param token 
    * @return  包裹数据源的Observable
    */
    @FormUrlEncoded
    @POST("msg/GetGroupConversationList")
    Observable<BaseBean<GroupBean>> getConvstGroup(@Field("uid") int uid, @Field("token") String token);
    

    ---code2---
    关于Retrofit请求参数注解字段可以参考
    http://blog.csdn.net/yangxi_pekin/article/details/5338205
    而此处我们是POST请求所以采取表单提交数据以 @field("paramName") type paramName 的形式请求连接地址<msg/GetGroupConversationList>并将结果通过gsonConverterFactory解析为本地的类并以泛型Obervable<BaseBean<GroupBean>>返回 (PS:basebean将会在下面给出)

    ---code1---
    将返回的被观察者进行转换map(new HttpResultFunc<GroupBean>()) 这里牵涉到一个比较重要的地方:服务器返回码统一处理

    /** 
      * 用来统一处理Http的resultCode,并将HttpResult的Data部分剥离出来返回给subscriber 
      * 假设code:204是token对应的返回码,那么我们可以进行相应的操作logout
      * 当返回码不为204且不为0(返回成功)时,抛出异常
      * 否则返回对应的bean
      * @param <T> Subscriber真正需要的数据类型,也就是Data部分的数据类型
      */
    private class HttpResultFunc<T> implements Func1<BaseBean<T>, T> {    
        @Override    
        public T call(BaseBean<T> baseBean) {        
            if (baseBean.code == 204) {            
              if (!PollService.isForceLogout)                
                //logout      
            } else if (baseBean.code != 0 && baseBean.code != 204) {            
                throw new APIException(baseBean.desc);        
            }       
          return baseBean.ret;    
        }
    }
    

    ---BaseBean---

    /**
     * Created by Mr.Xu on 16/9/7.
     */
    public class BaseBean<T>{    
    /**    
     *  code 状态码    
     *  desc 描述    
     *  ret 数据源    
     */    
    public int code;    
    public String desc;    
    public T ret;
    }
    

    说完类型转换map之后再来细看code1中的代码compose,这是rxjava专门为开发者提供的防止打破链式结构的操作符。rxjava最大的亮点就是在线程之间来回切换自如,使用如下代码

    observable.subscribeOn(Schedulers.io())
                      .observeOn(AndroidSchedulers.mainThread())
    

    而当我们如果想要避免重复调用就可以使用compose操作符,该方法传入了applySchedulers方法的返回值,applySchedulers方法如下

    <T> Observable.Transformer<T, T> applySchedulers() {    
        return new Observable.Transformer<T, T>() {        
            @Override        
            public Observable<T> call(Observable<T> observable) {            
                return observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());        
            }    
        };
    }
    

    至此我们已经完成了一个网络的请求任务

    关于Retrofit的配置如下

    @Provides
    @Singleton
    OkHttpClient provideOkHttpClient() {    
        OkHttpClient.Builder builder = new OkHttpClient().newBuilder().readTimeout(READ_TIME_OUT_VALUE, TimeUnit.SECONDS).connectTimeout(CONNECT_TIME_OUT_VALUE, TimeUnit.SECONDS).addInterceptor(new Interceptor() {        
            @Override        
            public Response intercept(Chain chain) throws IOException {            
                Request request = chain.request().newBuilder()                    
                    .addHeader("token", "token")            
                    .build();            
                    return chain.proceed(request.newBuilder().method(request.method(), request.body()).build());        
             }    
        });    
        return client;
    }
    

    配置OkHttpClient,在配置过程中可以给builder添加一个Interceptor,可以在请求之前拦截并添加需要的header如token验证。

    @Provides
    @Singleton
    public static Retrofit provideRetrofit(OkHttpClient okHttpClient) {    
        Retrofit retrofit;    
        GsonConverterFactory gsonConverterFactory = GsonConverterFactory.create();    
        retrofit = new Retrofit.Builder().client(okHttpClient)            
                       .baseUrl(APIService.BASE_RELEASE_URL)            //增加返回值为String的支持
                       .addConverterFactory(ScalarsConverterFactory.create())            
                       .addConverterFactory(gsonConverterFactory)
                       .addCallAdapterFactory(RxJavaCallAdapterFactory.create())            
                       .build();    
        return retrofit;
    }
    

    当我们的服务器返回的数据特别复杂不能直接使用Gson解析时可以给Retrofit添加上ScalarsConverterFactory,此时返回的类型为String类型,然后再通过手动解析达到数据->模型的目的。

    相关文章

      网友评论

      • 泅渡者:再接再厉
        We7ex:@泅渡者 加油~
      • Fzy_C:学习 学习
        We7ex:一起学习
      • 娃嘻嘻:和Volley比优势在哪里?
        We7ex:这里展示的只是最简单的网络请求用法,当然也可以看出比原来的网络请求框架更高效,更简洁不是么?通过rxjava首先达成了链式结构,如果数据源需要预处理通过一些操作符也是很方便如排序等
      • e1e7918c36fe:顶!
        We7ex:@eryiLee 谢谢支持:grin:

      本文标题:一起实现一下网络请求吧(Retrofit2+rxjava)

      本文链接:https://www.haomeiwen.com/subject/znawvttx.html