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。

对比
RxJava

compile'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' // RxAndroid

RxJava2

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 差不多就不再多说了。
• 如果有什么问题欢迎大家在评论区评论讨论，谢谢支持。