優雅的解決Retrofit RxAndroid關聯生命週期問題

Retrofit結合RxAndroid應該是史上最好用的網絡請求框架了，在項目中只須要一段代碼就能夠完成網絡請求以及回調處理，來看看google官方示例：

public class UserActivity extends AppCompatActivity {
    // 數據提供
    private UserViewModel mViewModel;
    // 管理subscriptions訂閱的釋放
    private final CompositeDisposable mDisposable = new CompositeDisposable();

    @Override
    protected void onStart() {
        super.onStart();
        // 發起網絡請求
        mDisposable.add(mViewModel.getUserName()
                .subscribeOn(Schedulers.io()) // 請求在IO線程運行
                .observeOn(AndroidSchedulers.mainThread()) // 回調到Android主線程
                .subscribe(userName -> mUserName.setText(userName), // 回調監聽
                        throwable -> Log.e(TAG, "Unable to update username", throwable)));
    }

    @Override
    protected void onStop() {
        super.onStop();
        // 釋放請求
        mDisposable.clear();
    }
}
複製代碼

在上面的例子中，全部的請求都必需要add在CompositeDisposable中，在Activity中止的時候進行釋放操做。若是不釋放的話會怎麼樣？答案是程序會崩潰。由於你的網絡請求是運行在異步線程IO中去的，當線程完成後回調到主線程來，發現Activity跑路（被釋放）了，回調的subscribe(...)找不到對象了，那確定不幹啊，線程也是有點小脾氣的嘛。

痛點

程序員都是"很懶的"，一來寫代碼很差看，每一個請求要嵌套在add()括號中；二來要在Activity銷燬的時候進行釋放。

Retrofit Rxandroid Adapter

爲解決Retrofit關聯的Activity、Fragment生命週期而設計。

1、用法

經過with(this)來關聯生命週期，簡化Activity.onStop()的釋放操做。

public class UserActivity extends AppCompatActivity {
	@Override
	protected void onCreate(@Nullable Bundle savedInstanceState) {
		MyService service = retrofit.create(MyService.class); // 你的接口
		service.getUser()
		       .with(this) // 關聯生命週期
		       .subscribe(new YourObserver());
	}
}
複製代碼

2、配置

一、在Retrofit初始化的實例的時候，添加RxAndroidCallAdapterFactory 做爲回調適配器。

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("https://example.com/")
    // 添加適配器
    .addCallAdapterFactory(RxAndroidCallAdapterFactory.create())
    .build();
複製代碼

二、改寫你的接口返回值，由以前的Observable<>改成AndroidObservable<>

interface MyService {
  @GET("/user")
  AndroidObservable<User> getUser();
}
複製代碼

3、下載

allprojects {
	repositories {
		// ... 省略其餘
		maven { url 'https://jitpack.io' }
	}
}
複製代碼

dependencies {
	implementation 'com.github.raedev:retrofit-rxandroid-adapter:latest.version'
}
複製代碼

AndroidObservable

源碼請查看 開源地址：https://github.com/raedev/retrofit-rxandroid-adapter。