android rxbinding2,Android RxJava+Retrofit2+RxBinding

前言:之前写了一篇名为Android 手把手教你使用Retrofit2的文章,只是单纯并简单的介绍了下Retrofit2的使用,现在我们把它跟RxJava以及RxBinding关联起来,看看效果如何添加依赖RxBinding的依赖比较麻烦,是按控件包区分的,我这边只用到了基础包也就是android.widget.所以只引入了compile 'com.jakewharton.rxbinding:rx

Yl Xu

113人浏览 · 2021-05-28 02:47:32

Yl Xu · 2021-05-28 02:47:32 发布

前言:之前写了一篇名为Android 手把手教你使用Retrofit2的文章,只是单纯并简单的介绍了下Retrofit2的使用,现在我们把它跟RxJava以及RxBinding关联起来,看看效果如何

添加依赖

RxBinding的依赖比较麻烦,是按控件包区分的,我这边只用到了基础包也就是android.widget.所以只引入了compile 'com.jakewharton.rxbinding:rxbinding:1.0.0'//全新网络请求框架Rxjava+RxAndroid+ReTrofit2+okHttp3

compile 'com.tamic.novate:novate:1.2.7'

compile 'com.squareup.retrofit2:retrofit:2.1.0'

compile 'com.squareup.retrofit2:converter-gson:2.1.0'

compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'

//日志拦截器

compile 'com.squareup.okhttp3:logging-interceptor:3.5.0'

compile 'io.reactivex:rxjava:1.2.4'

compile 'io.reactivex:rxandroid:1.2.1'

compile 'org.ligboy.retrofit2:converter-fastjson-android:2.1.0'

//RxBinding

compile 'com.jakewharton.rxbinding:rxbinding:1.0.0'// compile 'com.jakewharton.rxbinding:rxbinding-support-v4:1.0.0'// compile 'com.jakewharton.rxbinding:rxbinding-appcompat-v7:1.0.0'// compile 'com.jakewharton.rxbinding:rxbinding-design:1.0.0'// compile 'com.jakewharton.rxbinding:rxbinding-recyclerview-v7:1.0.0'

开始关联

MyRetrofit2Service差异

在使用RxJava之前是这样的@POST()

Call> post(@Url String url, @QueryMap Map map);

使用了RxJava之后是这样的@POST()

Observable> rxPost(@Url String url, @QueryMap Map map);

MyRetrofit2调用方法上的差异

在使用RxJava之前是这样的/**

* 异步调用

public void getEnqueue() {

Call> call = mApi.post(NEWS_URI, params);

call.enqueue(new Callback>() { @Override

public void onResponse(Call> call, Response> response) { //处理请求成功

Log.e("OkHttp", "处理成功请求 response = " + response.body().toString());

} @Override

public void onFailure(Call> call, Throwable t) { //处理请求失败

Log.e("OkHttp", "处理失败请求");

}

});// cancelCall(call);

}

使用了RxJava之后是这样的public void RxJavaGetEnqueue(Subscriber subscriber) {

Observable observable = mApi.rxPost(NEWS_URI, params)

.map(new HttpResultFunc());

toSubscribe(observable, subscriber);

} private void toSubscribe(Observable o, Subscriber s) {

o.subscribeOn(Schedulers.io())//设置事件触发在非主线程

.unsubscribeOn(Schedulers.io())

.observeOn(AndroidSchedulers.mainThread())//在主线程处理返回数据

.subscribe(s);

} /**

* 用来统一处理Http的resultCode,并将HttpResult的Data部分剥离出来返回给subscriber

* @param Subscriber真正需要的数据类型，也就是Data部分的数据类型

private class HttpResultFunc implements Func1, T> {

@Override public T call(HttpResult httpResult) {

Log.e("OkHttp", "HttpResultFunc httpResult = " + httpResult.toString()); if ("200".equals(httpResult.getStatus_code()) && httpResult.isSuccess()) { return httpResult.getData();

} throw new ApiException(httpResult.getStatus_code());

}

初看代码量变多了,没错,是变多了,但是谁叫他最近比较火呢,而且目前我只是实现比较简单的场景,还没发挥出RxJava的真正功效呢.

这里需要说下HttpResultFunc方法的作用,好用就好用在这里,这里我是根据网络请求的code跟success两个参数判断是否是成功的,如果是成功返回,那就返回data,如果是错误的话,自己写了个ApiException类是用来处理错误信息的/**

* Created by caihan on 2017/1/14.

*/public class ApiException extends RuntimeException { public static final int WRONG_1 = 100; public static final int WRONG_2 = 101; public ApiException(int resultCode) { this(getApiExceptionMessage(resultCode));

} public ApiException(String detailMessage) { super(detailMessage);

} /**

* 由于服务器传递过来的错误信息直接给用户看的话，用户未必能够理解

* 需要根据错误码对错误信息进行一个转换，在显示给用户

* @param code

* @return

private static String getApiExceptionMessage(int code) {

String message = ""; switch (code) { case WRONG_1:

message = "错误1"; break; case WRONG_2:

message = "错误2"; break; default:

message = "未知错误";

} return message;