image.png

前言

• 嗯嗯，在前段時間（好像好久之前了、、、）就有小伙伴有問 Retrofit 和 RxJava2 怎么配合使用，不過那時候挺忙就把這事放在了腦后，雖然最早問這件事的小伙伴大概早就解決了這個問題，但是最近又有小伙伴提到了這個問題，所以，就在這個周末找時間和大家聊聊這個話題吧。

添加依賴

• 當(dāng)然啦，使用之前還是添加相關(guān)依賴到項目中，這個其實和我之前 Retrofit + RxJava 的文章中說的差不多，但是有區(qū)別的是 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 中區(qū)別也不大

    // Kotlin 代碼，Java 中使用沒有區(qū)別
    fun getRxApi(): RxApi {
        // 初始化 OkHttpClient
        val okHttpClient = OkHttpClient.Builder()
                // 設(shè)置超時時間
                .connectTimeout(NET_CONNECT_TIME_OUT, TimeUnit.SECONDS)
                .writeTimeout(NET_WRITE_TIME_OUT, TimeUnit.SECONDS)
                .readTimeout(NET_READ_TIME_OUT, TimeUnit.SECONDS)
                // 設(shè)置參數(shù)攔截器，添加公共參數(shù)
                .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()
                // 服務(wù)器根路徑
                .baseUrl(UrlDefinition.BASE_URL)
                // 添加 RxJava2 支持，就這里與 RxJava 區(qū)別
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                // 添加 Gson 解析
                .addConverterFactory(GsonConverterFactory.create())
                .client(okHttpClient)
                .build()
        return retrofit.create(RxApi::class.java)
    }

• 同樣的，請求接口與使用 RxJava 也沒有太大區(qū)別

// 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 進(jìn)行網(wǎng)絡(luò)請求了，在這里因為 RxJava2 相對于 RxJava 有所改變，所以在使用時也是有區(qū)別的。

        getRxApi()
                .getData(param) // 定義在RxApi中的接口方法
                .subscribeOn(Schedulers.io()) // RxJava2方法，控制請求執(zhí)行的線程
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<DataEntity>() { // 請求成功回調(diào)
                    @Override
                    public void accept(DataEntityweatherBean) throws Exception {
                        onSuccess(weatherBean);
                    }
            }, new Consumer<Throwable>() { // 請求失敗回調(diào)
                @Override
                public void accept(Throwable throwable) throws Exception {
                    onFail(throwble);
                }
            });

• 這里可以看出區(qū)別，RxJava 中使用的 Action1 接口，而在 RxJava2 中變更為 Consumer。

RxJava2 生命周期管理

• 有看過我 Android項目基本架構(gòu)（三） Retrofit + Rx +OkHttp + MVP 一文的小伙伴知道，我們在 BaseMVPPresenter 中使用了 CompositeSubscription 這個類來對 RxJava 進(jìn)行生命周期管理，這樣能夠有效的防止由于 RxJava 生命周期產(chǎn)生的崩潰問題，但是在你升級到 RxJava2 之后，你會發(fā)現(xiàn)找不到 CompositeSubscription 這個類了，這是因為 RxJava2 中將生命周期管理，變更為 CompositeDisposable 了。

// Kotlin
open class BaseMvpPresenter<V : BaseMVPView, M : BaseMVPModule> {

    /** RxJava2 生命周期管理  */
    private val disposables = CompositeDisposable()

    ...
    /**
     * 將網(wǎng)絡(luò)請求添加到 RxJava2 生命周期
     */
    protected fun addDisposable(dis: Disposable) {
        disposables.add(dis)
    }

    /**
     * 消費所有事件
     */
    fun dispose() {
        disposables.clear()
    }
    ...
}

• 就這樣，在每個 Presenter 中調(diào)用 Module 請求網(wǎng)絡(luò)數(shù)據(jù)的時候，返回 Disposable 對象，調(diào)用 addDisposable 方法添加到生命周期管理

        Disposable disposable = getRxApi()
                .getData(param) // 定義在RxApi中的接口方法
                .subscribeOn(Schedulers.io()) // RxJava2方法，控制請求執(zhí)行的線程
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<DataEntity>() { // 請求成功回調(diào)
                    @Override
                    public void accept(DataEntityweatherBean) throws Exception {
                        onSuccess(weatherBean);
                    }
            }, new Consumer<Throwable>() { // 請求失敗回調(diào)
                @Override
                public void accept(Throwable throwable) throws Exception {
                    onFail(throwble);
                }
            });
        addDisposable(disposable);

• 最后，在每個 Activity、Fragment 的 onDestroy 方法中調(diào)用 dispose 方法。

Activity or Fragment {
    @Override
    public void onDestory() {
        super.onDestory()
        mPresenter.dispose()
    }
}

• 嗯嗯，關(guān)于 Retrofit 配合 RxJava2 的使用就這些了，其他的使用和 RxJava 差不多就不再多說了。
• 如果有什么問題歡迎大家在評論區(qū)評論討論，謝謝支持。