image.png
前言
- 嗯嗯，在前段时间（好像好久之前了、、、）就有小伙伴有问 Retrofit 和 RxJava2 怎么配合使用，不过那时候挺忙就把这事放在了脑后，虽然最早问这件事的小伙伴大概早就解决了这个问题，但是最近又有小伙伴提到了这个问题，所以，就在这个周末找时间和大家聊聊这个话题吧。
添加依赖
- 当然啦，使用之前还是添加相关依赖到项目中，这个其实和我之前 Retrofit + RxJava 的文章中说的差不多，但是有区别的是 RxJava 的依赖。
dependencies{
/* OkHttp + Retrofit */
implementation 'com.squareup.okhttp3:okhttp:3.10.0'
implementation 'com.squareup.retrofit2:retrofit:2.4.0'
// RxJava2
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.4.0'
implementation 'com.squareup.retrofit2:converter-gson:2.4.0'
/* RxJava2 + RxAndroid */
implementation 'io.reactivex.rxjava2:rxjava:2.1.12'
implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
}
- 在使用RxJava 的时候添加的是 adapter-rxjava 以及 rxjava ，但是使用 RxJava2 添加的依赖是 adapter-rxjava2 以及 rxjava2。
对比
RxJavacompile'com.squareup.retrofit2:adapter-rxjava:2.0.2' // 用于Retrofit支持RxJava compile'io.reactivex:rxjava:1.1.0' // RxJava compile'io.reactivex:rxandroid:1.1.0' // RxAndroidRxJava2
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.4.0' // 用于 Retrofit 支持 RxJava2 implementation 'io.reactivex.rxjava2:rxjava:2.1.12' // RxJava2 implementation 'io.reactivex.rxjava2:rxandroid:2.0.2' // RxAndroid2
Retrofit初始化
- 接下来这一步和使用 RxJava 中区别也不大
// Kotlin 代码，Java 中使用没有区别
fun getRxApi(): RxApi {
// 初始化 OkHttpClient
val okHttpClient = OkHttpClient.Builder()
// 设置超时时间
.connectTimeout(NET_CONNECT_TIME_OUT, TimeUnit.SECONDS)
.writeTimeout(NET_WRITE_TIME_OUT, TimeUnit.SECONDS)
.readTimeout(NET_READ_TIME_OUT, TimeUnit.SECONDS)
// 设置参数拦截器，添加公共参数
.addInterceptor(ParamsInterceptor(
mapOf("version" to BuildConfig.VERSION_NAME,
"app" to "android"),
BuildConfig.DEBUG))
// 日志拦截器，打印日志
.addInterceptor(LogInterceptor(
if (BuildConfig.DEBUG) Level.BODY else Level.NONE,
object : InterceptorLogger {
override fun log(msg: String) {
Logger.d(msg)
}
}))
.build()
// 初始化 Retrofit
val retrofit = Retrofit.Builder()
// 服务器根路径
.baseUrl(UrlDefinition.BASE_URL)
// 添加 RxJava2 支持，就这里与 RxJava 区别
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
// 添加 Gson 解析
.addConverterFactory(GsonConverterFactory.create())
.client(okHttpClient)
.build()
return retrofit.create(RxApi::class.java)
}
- 同样的，请求接口与使用 RxJava 也没有太大区别
// Kotlin
interface RxApi {
/**
* 请求接口
**/
@GET("url")
fun getData(@Query("param") param: String): Observable<DataEntity>
}
// Java
public interface RxApi {
/**
* 请求接口
**/
@GET("url")
Observable<DataEntity> getData(@Query("param") String param);
}
- 这里要注意到的 Observable 类是 RxJava2 包中的。
使用
- 接下来就是使用 Retrofit 进行网络请求了，在这里因为 RxJava2 相对于 RxJava 有所改变，所以在使用时也是有区别的。
getRxApi()
.getData(param) // 定义在RxApi中的接口方法
.subscribeOn(Schedulers.io()) // RxJava2方法，控制请求执行的线程
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<DataEntity>() { // 请求成功回调
@Override
public void accept(DataEntityweatherBean) throws Exception {
onSuccess(weatherBean);
}
}, new Consumer<Throwable>() { // 请求失败回调
@Override
public void accept(Throwable throwable) throws Exception {
onFail(throwble);
}
});
- 这里可以看出区别，RxJava 中使用的 Action1 接口，而在 RxJava2 中变更为 Consumer。
RxJava2 生命周期管理
- 有看过我 Android项目基本架构（三） Retrofit + Rx +OkHttp + MVP 一文的小伙伴知道，我们在 BaseMVPPresenter 中使用了 CompositeSubscription 这个类来对 RxJava 进行生命周期管理，这样能够有效的防止由于 RxJava 生命周期产生的崩溃问题，但是在你升级到 RxJava2 之后，你会发现找不到 CompositeSubscription 这个类了，这是因为 RxJava2 中将生命周期管理，变更为 CompositeDisposable 了。
// Kotlin
open class BaseMvpPresenter<V : BaseMVPView, M : BaseMVPModule> {
/** RxJava2 生命周期管理 */
private val disposables = CompositeDisposable()
...
/**
* 将网络请求添加到 RxJava2 生命周期
*/
protected fun addDisposable(dis: Disposable) {
disposables.add(dis)
}
/**
* 消费所有事件
*/
fun dispose() {
disposables.clear()
}
...
}
- 就这样，在每个 Presenter 中调用 Module 请求网络数据的时候，返回 Disposable 对象，调用 addDisposable 方法添加到生命周期管理
Disposable disposable = getRxApi()
.getData(param) // 定义在RxApi中的接口方法
.subscribeOn(Schedulers.io()) // RxJava2方法，控制请求执行的线程
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<DataEntity>() { // 请求成功回调
@Override
public void accept(DataEntityweatherBean) throws Exception {
onSuccess(weatherBean);
}
}, new Consumer<Throwable>() { // 请求失败回调
@Override
public void accept(Throwable throwable) throws Exception {
onFail(throwble);
}
});
addDisposable(disposable);
- 最后，在每个 Activity、Fragment 的 onDestroy 方法中调用 dispose 方法。
Activity or Fragment {
@Override
public void onDestory() {
super.onDestory()
mPresenter.dispose()
}
}
- 嗯嗯，关于 Retrofit 配合 RxJava2 的使用就这些了，其他的使用和 RxJava 差不多就不再多说了。
- 如果有什么问题欢迎大家在评论区评论讨论，谢谢支持。
