image.png
前言
- 嗯嗯橘洞，在前段時間（好像好久之前了捌袜、、炸枣、）就有小伙伴有問 Retrofit 和 RxJava2 怎么配合使用虏等，不過那時候挺忙就把這事放在了腦后弄唧，雖然最早問這件事的小伙伴大概早就解決了這個問題，但是最近又有小伙伴提到了這個問題霍衫，所以候引，就在這個周末找時間和大家聊聊這個話題吧。
添加依賴
- 當然啦敦跌，使用之前還是添加相關依賴到項目中澄干，這個其實和我之前 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息尺。
對比
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 中區(qū)別也不大
// Kotlin 代碼携兵，Java 中使用沒有區(qū)別
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)
// 設置參數(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()
// 服務器根路徑
.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 進行網(wǎng)絡請求了并级，在這里因為 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項目基本架構（三） Retrofit + Rx +OkHttp + MVP 一文的小伙伴知道，我們在 BaseMVPPresenter 中使用了 CompositeSubscription 這個類來對 RxJava 進行生命周期管理加矛，這樣能夠有效的防止由于 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)絡請求添加到 RxJava2 生命周期
*/
protected fun addDisposable(dis: Disposable) {
disposables.add(dis)
}
/**
* 消費所有事件
*/
fun dispose() {
disposables.clear()
}
...
}
- 就這樣苛茂，在每個 Presenter 中調(diào)用 Module 請求網(wǎng)絡數(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()
}
}
- 嗯嗯唐片，關于 Retrofit 配合 RxJava2 的使用就這些了丙猬，其他的使用和 RxJava 差不多就不再多說了。
- 如果有什么問題歡迎大家在評論區(qū)評論討論费韭，謝謝支持茧球。
