Android Retrofit+RxJava接入（三）

水深无声 2022-05-29 09:56 204阅读 0赞

前面两篇文字介绍了，Retrofit的简单使用，该文章则使用Retrofit+Rxjava 来实现请求。  
首先导入

compile 'com.google.code.gson:gson:2.8.0'
        //=========Retrofit=========
        compile 'com.squareup.retrofit2:retrofit:2.2.0'
        //转换为Response Gson
        compile 'com.squareup.retrofit2:converter-gson:2.0.2'
        //转换为Response String
        compile 'com.squareup.retrofit2:converter-scalars:2.0.0'
    
    
        //======RxJava引用========
        compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
        compile 'io.reactivex.rxjava2:rxjava:2.0.9'
        //添加.addCallAdapterFactory(RxJava2CallAdapterFactory)
        compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'

## Retrofit ##

//现在未添加InterCeptor
            OkHttpClient client = new OkHttpClient.Builder()
                    .cache(cache)
                    .connectTimeout(60l, TimeUnit.SECONDS)
                    .readTimeout(60l, TimeUnit.SECONDS)
                    .writeTimeout(60l, TimeUnit.SECONDS)
                    .build();
            retrofit = new Retrofit.Builder()
                    .baseUrl(QpAddress.baseUrl)
                    .client(client)
                    .addConverterFactory(ScalarsConverterFactory.create())
                    .addConverterFactory(GsonConverterFactory.create())
                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                    .build();
            mApiService = retrofit.create(QpApiService.class);

## QpApiService.class ##

public interface QpApiService { 
    
    
        /** * 获取广告，使用CallBack * @param map a=api * method=customized.thread.design * moduleid=10 * appid=9FprO7RiGjFknxPo, * random=ica3gjycxqy2 * tick=1521600960 * sign=NWNjMzY3MDY0ODQ2NmI4OTMyYWNhYzkyNDMyMjJkODg2ZmY3YWQwMw== * @return */
        @FormUrlEncoded
        @POST("aCloud/index.php")
        Call<BaseData<List<BannerBean>>> getBanners(@FieldMap Map<String, String> map);
    
    
        /** * 获取广告,使用RxJava * @param map * @return */
        @FormUrlEncoded
        @POST("aCloud/index.php")
        Observable<BaseData<List<BannerBean>>> getBannersRx(@FieldMap Map<String, String> map);
    
    }

## 封装请求方法 ##

/** * 获取Banner,使用CallBack * * @param mapBanner * @param callback */
        public void getBanners(Map<String, String> mapBanner, Callback<BaseData<List<BannerBean>>> callback) {
    
    
            mApiService.getBanners(mapBanner).enqueue(callback);
        }
    
    
        /** * 使用RxJava * import io.reactivex.Observable; * @param mapBanner * @return */
        public Observable getBannersRx(Map<String, String> mapBanner) {
            return mApiService.getBannersRx(mapBanner).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
        }

## BaseObServer ##

注意继承的是`import io.reactivex.Observer;`

public abstract class BaseObServer<T> implements Observer<BaseData<T>> {
    
        private Disposable mdisposable;
    
        private final  String SUCCESS_CODE="0";
    
        @Override
        public void onSubscribe(@NonNull Disposable d) {
            mdisposable=d;
        }
    
        @Override
        public void onNext(@NonNull BaseData<T> value) {
            if (value.getCode().equals(SUCCESS_CODE)){
    
                LogUtils.e("返回数据成功");
                T t=value.getInfo();
    
                onHandleSuccess(t);
            }else {
    
                onHandleError(value.getCode(),value.getInfo().toString());
            }
    
        }
    
    
        @Override
        public void onError(@NonNull Throwable e) {
            LogUtils.e("请求出错=="+e.toString());
        }
    
        @Override
        public void onComplete() {
    
        }
    
    
        public abstract void onHandleSuccess(T t);
    
        //错误信息统一处理
        void onHandleError(String code, String message) {
            Toast.makeText(QProjApplication.getContext(), message, Toast.LENGTH_LONG).show();
        }
    
    }

## 执行请求 ##

//相当于使用Map.put(key,value)
            QpPostMap qpPostMap = new QpPostMap.Builder().
                    addMethod("customized.thread.design")
                    .addModuleid("10")
                    .addAppid("9FprO7RiGjFknxPo")
                    .addRandom("ica3gjycxqy2")
                    .addTick("1521600960")
                    .addSign("NWNjMzY3MDY0ODQ2NmI4OTMyYWNhYzkyNDMyMjJkODg2ZmY3YWQwMw==")
                    .build();
    
    //回调的使用
            QpRetrofitManager.getInstance().getBanners(qpPostMap.getMap(), new Callback<BaseData<List<BannerBean>>>() {
                @Override
                public void onResponse(Call<BaseData<List<BannerBean>>> call, Response<BaseData<List<BannerBean>>> response) {
                    LogUtils.e("onResponse==" + response.body().toString());
    
                }
    
                @Override
                public void onFailure(Call<BaseData<List<BannerBean>>> call, Throwable t) {
    
                }
            });
    ／／Rxjava请求使用
            QpRetrofitManager.getInstance().getBannersRx(qpPostMap.getMap()).subscribe(new BaseObServer<List<BannerBean>>() {
                @Override
                public void onHandleSuccess(List<BannerBean> o) {
    
                    LogUtils.e("onHandleSuccess==" + o.toString());
    
                }
            });

## 执行后，打印的Log ##

callback

onHandleSuccess==[BannerBean{data_id='91127', title='【规则】奥飞俱乐部发帖规则1.0', url='http://mobile.club.auldey.com/index/thread/tid/6752/fid/6.html', thumb='http://club.auldey.com/attachment/module/10/4f491059de7e0d5.jpg'}, BannerBean{data_id='91140', title='感谢陪伴丨我们永远在你身边', url='http://club.auldey.com/read.php?tid=6255&fid=6&page=1', thumb='http://club.auldey.com/attachment/module/10/d0f66945ae37988.jpg'}, BannerBean{data_id='93474', title='超级飞侠——出行安全小贴士', url='http://mobile.club.auldey.com/index/thread/tid/6758/fid/2.html', thumb='http://club.auldey.com/attachment/module/10/37c3d85bff5c866.jpg'}]
    03

rxJava

onResponse==BaseData{code='0', info=[BannerBean{data_id='91127', title='【规则】奥飞俱乐部发帖规则1.0', url='http://mobile.club.auldey.com/index/thread/tid/6752/fid/6.html', thumb='http://club.auldey.com/attachment/module/10/4f491059de7e0d5.jpg'}, BannerBean{data_id='91140', title='感谢陪伴丨我们永远在你身边', url='http://club.auldey.com/read.php?tid=6255&fid=6&page=1', thumb='http://club.auldey.com/attachment/module/10/d0f66945ae37988.jpg'}, BannerBean{data_id='93474', title='超级飞侠——出行安全小贴士', url='http://mobile.club.auldey.com/index/thread/tid/6758/fid/2.html', thumb='http://club.auldey.com/attachment/module/10/37c3d85bff5c866.jpg'}]}

可以看到，打印的内容没有区别，为什么要使RxJava？主要是，对一些返回异常统一处理，而且使得代码维护性便利，

事实上，你也可以自定义一个Callback实现`import retrofit2.Callback;`

如下：

public abstract class NetCallBack<T> implements Callback<T> { 
        @Override
        public void onFailure(Call<T> call, Throwable t) {
            //统一处理回调错误的情况
        }
    }

将实现方法可以简化为

QpRetrofitManager.getInstance().getBanners(qpPostMap.getMap(), new NetCallBack<BaseData<List<BannerBean>>>() {
                @Override
                public void onResponse(Call<BaseData<List<BannerBean>>> call, Response<BaseData<List<BannerBean>>> response) {
                    LogUtils.e("onResponse==" + response.body().toString());
                }
            });

其实这样也很简单的。事实上，为什么，大家都在使用Retrofit＋Rxjava ，我还没有搞明白，不过先会使用了，然后在慢慢的看，这么多人用，我想，肯定是有它的好处的。