RxLifecycle詳解

一、RxLifecycle簡介

RxLifecycle是為了解決RxJava下Activity/Fragment生命周期管理而誕生的一個庫。

與RxJava相結合，RxLifecycle提供了生命周期感知的Observable和Flowable，在Activity/Fragment生命周期結束時自動取消訂閱以避免內存泄漏。

使用RxLifecycle可以在Activity/Fragment的onStop()或onDestroy()等生命周期方法中dispose()訂閱事件，減小內存泄漏的風險。

二、RxLifecycle的使用

1、添加依賴

在build.gradle文件中添加以下依賴：

“`
implementation ‘com.trello.rxlifecycle3:rxlifecycle:3.0.0’
implementation ‘com.trello.rxlifecycle3:rxlifecycle-android:3.0.0’
implementation ‘com.trello.rxlifecycle3:rxlifecycle-components:3.0.0’
“`

2、與RxJava結合使用

使用RxLifecycle與RxJava結合使用非常容易，只需要將Observable或Flowable與LifecycleProvider綁定即可。

“`
Observable.just(“hello world”)
.compose(lifecycleProvider.bindToLifecycle()) // 綁定
.subscribe(new Consumer() {
@Override
public void accept(String s) throws Exception {
Log.d(TAG, “accept: ” + s);
}
});
“`

3、在Activity/Fragment中使用

在Activity/Fragment中使用RxLifecycle需要實現LifecycleProvider介面，這個介面有兩個實現類：

1) FragmentLifecycleProvider

2) ActivityLifecycleProvider

“`
public interface LifecycleProvider {

@NonNull
Observable lifecycle();

@NonNull
LifecycleTransformer bindUntilEvent(@NonNull T event);

@NonNull
LifecycleTransformer bindToLifecycle();
}
“`

在Activity或Fragment中，需要實現lifecycle()方法以及綁定生命周期的方法bindUntilEvent()和bindToLifecycle()。

4、RxLifecycle綁定方式

獲取LifecycleProvider實例後，RxLifecycle支持多種綁定方式，包括：

i) bindToLifecycle()

綁定Observable或Flowable到Activity/Fragment生命周期的末尾。

使用bindToLifecycle()，當Activity/Fragment的生命周期結束時，自動取消訂閱，以避免內存泄漏。

“`
Observable.interval(1, TimeUnit.SECONDS)
.observeOn(AndroidSchedulers.mainThread())
.compose(lifecycleProvider.bindToLifecycle())
.subscribe(new Consumer() {
@Override
public void accept(Object o) throws Exception {
Log.d(TAG, “accept: ” + o.toString());
}
});
“`

ii) bindUntilEvent()

綁定Observable或Flowable，直到Activity/Fragment生命周期中的某個事件發生後結束訂閱。

“`
Observable.interval(1, TimeUnit.SECONDS)
.observeOn(AndroidSchedulers.mainThread())
.compose(lifecycleProvider.bindUntilEvent(FragmentEvent.STOP))
.subscribe(new Consumer() {
@Override
public void accept(Object o) throws Exception {
Log.d(TAG, “accept: ” + o.toString());
}
});
“`

iii) bind()

使用bind()方法，可以自定義綁定方式。

“`
Observable.interval(1, TimeUnit.SECONDS)
.observeOn(AndroidSchedulers.mainThread())
.compose(lifecycleProvider.bind(onEvent)) // onEvent可以是任意的Lifecycle.Event
.subscribe(new Consumer() {
@Override
public void accept(Object o) throws Exception {
Log.d(TAG, “accept: ” + o.toString());
}
});
“`

三、RxLifecycle的拓展用法

1、在自定義View中使用RxLifecycle

在自定義View中使用RxLifecycle同樣很容易，只需要通過構造函數傳遞給View即可。

“`
public class CustomView extends View implements LifecycleProvider {

private final LifecycleRegistry lifecycleRegistry;

public CustomView(Context context, AttributeSet attrs) {
super(context, attrs);
lifecycleRegistry = new LifecycleRegistry(this);
}

@NonNull
@Override
public Observable lifecycle() {
return lifecycleRegistry.lifecycle();
}

@NonNull
@Override
public LifecycleTransformer bindUntilEvent(@NonNull FragmentEvent event) {
return RxLifecycle.bindUntilEvent(lifecycleRegistry, event);
}

@NonNull
@Override
public LifecycleTransformer bindToLifecycle() {
return RxLifecycle.bind(lifecycleRegistry);
}
}
“`

2、RxLifecycle在Presenter中的使用

在MVP架構中，通常會使用Presenter來處理業務邏輯。

可以給Presenter實現LifecycleProvider介面，使用RxLifecycle綁定。

“`
public class MyPresenter implements LifecycleProvider {

private LifecycleRegistry lifecycleRegistry;

public void attachView(View view) {
lifecycleRegistry = new LifecycleRegistry(view);
}

public void detachView() {
lifecycleRegistry.markState(Lifecycle.State.DESTROYED);
}

@NonNull
@Override
public Observable lifecycle() {
return lifecycleRegistry.lifecycle();
}

@NonNull
@Override
public LifecycleTransformer bindUntilEvent(@NonNull FragmentEvent event) {
return RxLifecycle.bindUntilEvent(lifecycleRegistry, event);
}

@NonNull
@Override
public LifecycleTransformer bindToLifecycle() {
return RxLifecycle.bind(lifecycleRegistry);
}
}
“`

3、RxLifecycle在Room中的使用

在Android中，有很多使用了Room進行本地資料庫操作的應用。

Room也支持RxJava和RxLifecycle，具體使用思路與RxJava結合使用相同。

“`
@Dao
public interface UserDao {

@Query(“SELECT * FROM users”)
Flowable<List> getUsers();

@Insert
void insertUser(User user);

@Update
void updateUser(User user);

@Delete
void deleteUser(User user);
}

public class UserRepository {

private UserDao userDao;

public UserRepository(Context context) {
AppDatabase db = AppDatabase.getDatabase(context);
userDao = db.userDao();
}

public Flowable<List> getUsers() {
return userDao.getUsers()
.compose(RxLifecycle.<List, FragmentEvent>bindUntilEvent(lifecycleProvider, FragmentEvent.STOP));
}

// …
}
“`

四、RxLifecycle的優化

1、使用AutoDispose替換RxLifecycle

儘管RxLifecycle可以很好地避免界面銷毀時的內存泄漏，但設計上仍然會比較繁瑣，尤其是需要綁定多個事件的時候，會顯得非常麻煩。

AutoDispose是一個更加簡單優雅的生命周期管理庫，支持RxJava 2.x和3.x，可以更莫到地處理生命周期事件以及內存泄漏問題。

相比RxLifecycle，AutoDispose可以讓代碼更加簡潔，使生命周期管理更加優雅。

2、使用lifecycle-livedata-ktx精簡代碼

最近，在Google官方的Android Jetpack組件庫中，新增了一個lifecycle-livedata-ktx庫，使LiveData與Kotlin協程更好的結合。

這個庫提供了一個LiveDataScope，可以幫我們輕鬆實現生命周期的管理，使得代碼更加精簡，避免任何內存泄漏問題。

結語

RxLifecycle是一款非常方便易用的RxJava生命周期管理庫。

它簡單明了，支持多種綁定方式，可以用於Activity、Fragment、自定義View、Presenter、Room等各種場景，是RxJava編程中必備的工具之一。