前言
隨著RxJava及RxAndroid的逐漸推廣意乓，使用者越來(lái)越多，但是有一個(gè)問(wèn)題惜傲，RxJava的使用不當(dāng)極有可能會(huì)導(dǎo)致內(nèi)存泄漏洽故。
比如，使用RxJava發(fā)布一個(gè)訂閱后盗誊，當(dāng)Activity被finish收津，此時(shí)訂閱邏輯還未完成，如果沒(méi)有及時(shí)取消訂閱浊伙，就會(huì)導(dǎo)致Activity無(wú)法被回收撞秋，從而引發(fā)內(nèi)存泄漏。
目前網(wǎng)上對(duì)RxJava的內(nèi)存泄漏有幾種方案：
1嚣鄙、通過(guò)封裝吻贿，手動(dòng)為RxJava的每一次訂閱進(jìn)行控制，在指定的時(shí)機(jī)進(jìn)行取消訂閱哑子；
2舅列、使用 Daniel Lew 的 RxLifecycle ，通過(guò)監(jiān)聽(tīng)Activity卧蜓、Fragment的生命周期帐要，來(lái)自動(dòng)斷開(kāi)subscription以防止內(nèi)存泄漏。
筆者上述兩種方式都使用過(guò)弥奸，RxLifecycle顯然對(duì)于第一種方式榨惠，更簡(jiǎn)單直接，并且能夠在Activity/Fragment容器的指定生命周期取消訂閱，實(shí)在是好用赠橙。
依賴(lài)并使用RxLifecycle
1耽装、添加依賴(lài)
首先在build.gradle文件中添加依賴(lài)：
compile 'com.trello.rxlifecycle2:rxlifecycle:2.2.1'
compile 'com.trello.rxlifecycle2:rxlifecycle-android:2.2.1'
compile 'com.trello.rxlifecycle2:rxlifecycle-components:2.2.1'
2、配置Activity/Fragment容器
Activity/Fragment需繼承RxAppCompatActivity/RxFragment期揪，目前支持的有如下：
代碼如下：
//只需要繼承即可
public class MainActivity extends RxAppCompatActivity {
...
...
}
3掉奄、使用compose操作符綁定容器生命周期
有兩種方式：
3.1 使用bindToLifecycle()
以Activity為例，在Activity中使用bindToLifecycle()方法凤薛，完成Observable發(fā)布的事件和當(dāng)前的組件綁定姓建，實(shí)現(xiàn)生命周期同步。從而實(shí)現(xiàn)當(dāng)前組件生命周期結(jié)束時(shí)缤苫，自動(dòng)取消對(duì)Observable訂閱速兔，代碼如下：
public class MainActivity extends RxAppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
// 當(dāng)執(zhí)行onDestory()時(shí)， 自動(dòng)解除訂閱
Observable.interval(1, TimeUnit.SECONDS)
.doOnDispose(new Action() {
@Override
public void run() throws Exception {
Log.i(TAG, "Unsubscribing subscription from onCreate()");
}
})
.compose(this.<Long>bindToLifecycle())
.subscribe(new Consumer<Long>() {
@Override
public void accept(Long num) throws Exception {
Log.i(TAG, "Started in onCreate(), running until onDestory(): " + num);
}
});
}
}
3.2 使用bindUntilEvent()
使用ActivityEvent類(lèi)榨馁，其中的CREATE憨栽、START、 RESUME翼虫、PAUSE屑柔、STOP、 DESTROY分別對(duì)應(yīng)生命周期內(nèi)的方法珍剑。使用bindUntilEvent指定在哪個(gè)生命周期方法調(diào)用時(shí)取消訂閱：
public class MainActivity extends RxAppCompatActivity {
@Override
protected void onResume() {
super.onResume();
Observable.interval(1, TimeUnit.SECONDS)
.doOnDispose(new Action() {
@Override
public void run() throws Exception {
Log.i(TAG, "Unsubscribing subscription from onResume()");
}
})
//bindUntilEvent()掸宛，內(nèi)部傳入指定生命周期參數(shù)
.compose(this.<Long>bindUntilEvent(ActivityEvent.DESTROY))
.subscribe(new Consumer<Long>() {
@Override
public void accept(Long num) throws Exception {
Log.i(TAG, "Started in onResume(), running until in onDestroy(): " + num);
}
});
}
}
以上，僅僅需要三步：依賴(lài)招拙、繼承唧瘾、compose操作符，即可完成在容器的指定生命周期內(nèi)别凤，RxJava的自動(dòng)取消訂閱饰序。
原理分析
RxLifecycle的原理可以說(shuō)非常簡(jiǎn)單。
我們直接看一下這行代碼的內(nèi)部原理：
Observable.compose(this.<Long>bindToLifecycle())
1规哪、RxAppCompatActivity
public abstract class RxAppCompatActivity extends AppCompatActivity implements LifecycleProvider<ActivityEvent> {
//1.實(shí)際上RxAppCompatActivity內(nèi)部存儲(chǔ)了一個(gè)BehaviorSubject
private final BehaviorSubject<ActivityEvent> lifecycleSubject = BehaviorSubject.create();
public final Observable<ActivityEvent> lifecycle() {
return lifecycleSubject.hide();
}
public final <T> LifecycleTransformer<T> bindUntilEvent(@NonNull ActivityEvent event) {
return RxLifecycle.bindUntilEvent(lifecycleSubject, event);
}
//2.實(shí)際上返回了一個(gè)LifecycleTransformer
public final <T> LifecycleTransformer<T> bindToLifecycle() {
return RxLifecycleAndroid.bindActivity(lifecycleSubject);
}
//3.Activity不同的生命周期求豫，BehaviorSubject對(duì)象會(huì)發(fā)射對(duì)應(yīng)的ActivityEvent
@Override
@CallSuper
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
lifecycleSubject.onNext(ActivityEvent.CREATE);
}
@Override
@CallSuper
protected void onStart() {
super.onStart();
lifecycleSubject.onNext(ActivityEvent.START);
}
@Override
@CallSuper
protected void onResume() {
super.onResume();
lifecycleSubject.onNext(ActivityEvent.RESUME);
}
@Override
@CallSuper
protected void onPause() {
lifecycleSubject.onNext(ActivityEvent.PAUSE);
super.onPause();
}
@Override
@CallSuper
protected void onStop() {
lifecycleSubject.onNext(ActivityEvent.STOP);
super.onStop();
}
@Override
@CallSuper
protected void onDestroy() {
lifecycleSubject.onNext(ActivityEvent.DESTROY);
super.onDestroy();
}
}
我們繼承的RxAppCompatActivity，其內(nèi)部實(shí)際上存儲(chǔ)了一個(gè)BehaviorSubject诉稍，關(guān)于BehaviorSubject蝠嘉，實(shí)際上也還是一個(gè)Observable，不了解的朋友可以閱讀筆者的前一篇文章,本文不再贅述：
這個(gè)BehaviorSubject會(huì)在不同的生命周期發(fā)射不同的ActivityEvent杯巨，比如在onCreate()生命周期發(fā)射ActivityEvent.CREATE蚤告，在onStop()發(fā)射ActivityEvent.STOP。
在2中服爷，我們可以看到杜恰，bindToLifecycle()方法實(shí)際返回了一個(gè)LifecycleTransformer获诈，那么這個(gè)LifecycleTransformer是什么呢？
2箫章、LifecycleTransformer
public final class LifecycleTransformer<T> implements ObservableTransformer<T, T>,
FlowableTransformer<T, T>,
SingleTransformer<T, T>,
MaybeTransformer<T, T>,
CompletableTransformer
{
final Observable<?> observable;
LifecycleTransformer(Observable<?> observable) {
checkNotNull(observable, "observable == null");
this.observable = observable;
}
@Override
public ObservableSource<T> apply(Observable<T> upstream) {
return upstream.takeUntil(observable);
}
//隱藏其余代碼烙荷，這里只以O(shè)bservable為例
}
熟悉Transformer的同學(xué)都應(yīng)該能看懂镜会，LifecycleTransformer實(shí)際是實(shí)現(xiàn)了不同響應(yīng)式數(shù)據(jù)類(lèi)（Observable檬寂、Flowable等）的Transformer接口。
以O(shè)bservable為例戳表，實(shí)際上就是通過(guò)傳入一個(gè)Observable序列并存儲(chǔ)為成員桶至，然后作為參數(shù)給上游的數(shù)據(jù)源執(zhí)行takeUntil方法。
takeUntil操作符
takeUntil操作符:當(dāng)?shù)诙€(gè)Observable發(fā)射了一項(xiàng)數(shù)據(jù)或者終止時(shí)匾旭，丟棄原Observable發(fā)射的任何數(shù)據(jù)镣屹。
回顧
Observable.interval(1, TimeUnit.SECONDS)
.doOnDispose(new Action() {
@Override
public void run() throws Exception {
Log.i(TAG, "Unsubscribing subscription from onCreate()");
}
})
.compose(this.<Long>bindToLifecycle())
.subscribe(new Consumer<Long>() {
@Override
public void accept(Long num) throws Exception {
Log.i(TAG, "Started in onCreate(), running until onDestory(): " + num);
}
});
現(xiàn)在回頭來(lái)看這段代碼，就很好理解了价涝，Activity.<Long>bindToLifecycle()實(shí)際上就是指定上游的數(shù)據(jù)源女蜈，當(dāng)接收到某個(gè)Observable（就是LifecycleTransformer中那個(gè)神秘的成員變量）的某個(gè)事件時(shí)，該數(shù)據(jù)源自動(dòng)解除訂閱色瘩。
老師伪窖，原理已經(jīng)搞清楚了，我還有最后一個(gè)問(wèn)題：
神秘人是誰(shuí)居兆？
回到RxAppCompatActivity中來(lái)覆山，我們來(lái)看bindToLifecycle()方法：
public abstract class RxAppCompatActivity extends AppCompatActivity implements LifecycleProvider<ActivityEvent> {
private final BehaviorSubject<ActivityEvent> lifecycleSubject = BehaviorSubject.create();
public final <T> LifecycleTransformer<T> bindToLifecycle() {
//執(zhí)行了這行代碼，返回了LifecycleTransformer
return RxLifecycleAndroid.bindActivity(lifecycleSubject);
}
}
不難猜測(cè)泥栖，實(shí)際上簇宽，那個(gè)神秘人，就是我們RxAppCompatActivity 中的BehaviorSubject成員變量（它本身就是一個(gè)Observable）吧享！
我們點(diǎn)進(jìn)去看看：
//1.執(zhí)行了 bind(lifecycle, ACTIVITY_LIFECYCLE);
public static <T> LifecycleTransformer<T> bindActivity(@NonNull final Observable<ActivityEvent> lifecycle) {
return bind(lifecycle, ACTIVITY_LIFECYCLE);
}
//2.執(zhí)行了bind(takeUntilCorrespondingEvent(lifecycle.share(), correspondingEvents))
public static <T, R> LifecycleTransformer<T> bind(@Nonnull Observable<R> lifecycle,
@Nonnull final Function<R, R> correspondingEvents) {
return bind(takeUntilCorrespondingEvent(lifecycle.share(), correspondingEvents));
}
//3.最終抵達(dá)這里魏割，這個(gè)方法執(zhí)行了什么呢？
private static <R> Observable<Boolean> takeUntilCorrespondingEvent(final Observable<R> lifecycle,
final Function<R, R> correspondingEvents) {
return Observable.combineLatest(
lifecycle.take(1).map(correspondingEvents),
lifecycle.skip(1),
new BiFunction<R, R, Boolean>() {
@Override
public Boolean apply(R bindUntilEvent, R lifecycleEvent) throws Exception {
return lifecycleEvent.equals(bindUntilEvent);
}
})
.onErrorReturn(Functions.RESUME_FUNCTION)
.filter(Functions.SHOULD_COMPLETE);
}
最后我們走到了3钢颂，我們一行一行分析：
Observable.combineLatest
這行代碼實(shí)際上是將lifecycle（就是我們傳進(jìn)來(lái)的BehaviorSubject）的事件進(jìn)行了一次分割：
lifecycle.take(1)指的是最近發(fā)射的事件钞它，比如說(shuō)我們?cè)趏nCreate()中執(zhí)行了bindToLifecycle，那么lifecycle.take(1)指的就是ActivityEvent.CREATE甸陌，經(jīng)過(guò)map(correspondingEvents)须揣，這個(gè)map中傳的函數(shù)就是 1中的ACTIVITY_LIFECYCLE：
private static final Function<ActivityEvent, ActivityEvent> ACTIVITY_LIFECYCLE =
new Function<ActivityEvent, ActivityEvent>() {
@Override
public ActivityEvent apply(ActivityEvent lastEvent) throws Exception {
switch (lastEvent) {
case CREATE:
return ActivityEvent.DESTROY;
case START:
return ActivityEvent.STOP;
case RESUME:
return ActivityEvent.PAUSE;
case PAUSE:
return ActivityEvent.STOP;
case STOP:
return ActivityEvent.DESTROY;
case DESTROY:
throw new OutsideLifecycleException("Cannot bind to Activity lifecycle when outside of it.");
default:
throw new UnsupportedOperationException("Binding to " + lastEvent + " not yet implemented");
}
}
};
也就是說(shuō)，lifecycle.take(1).map(correspondingEvents)實(shí)際上是返回了 CREATE 對(duì)應(yīng)的事件 DESTROY ,它意味著本次訂閱將在Activity的onDestory進(jìn)行取消钱豁。
lifecycle.skip(1)就簡(jiǎn)單了耻卡，除去第一個(gè)保留剩下的，以ActivityEvent.Create為例牲尺，這里就剩下：
ActivityEvent.START
ActivityEvent.RESUME
ActivityEvent.PAUSE
ActivityEvent.STOP
ActivityEvent.DESTROY
第三個(gè)參數(shù) 意味著卵酪，lifecycle.take(1).map(correspondingEvents)的序列和 lifecycle.skip(1)進(jìn)行combine幌蚊，形成一個(gè)新的序列：
false,false,fasle,false,true
這意味著，當(dāng)Activity走到onStart生命周期時(shí)溃卡，為false,這次訂閱不會(huì)取消溢豆，直到onDestroy，為true瘸羡，訂閱取消漩仙。
而后的onErrorReturn和filter是對(duì)異常的處理和判斷是否應(yīng)該結(jié)束訂閱：
//異常處理
static final Function<Throwable, Boolean> RESUME_FUNCTION = new Function<Throwable, Boolean>() {
@Override
public Boolean apply(Throwable throwable) throws Exception {
if (throwable instanceof OutsideLifecycleException) {
return true;
}
Exceptions.propagate(throwable);
return false;
}
};
//是否應(yīng)該取消訂閱，可以看到犹赖，這依賴(lài)于上游的boolean
static final Predicate<Boolean> SHOULD_COMPLETE = new Predicate<Boolean>() {
@Override
public boolean test(Boolean shouldComplete) throws Exception {
return shouldComplete;
}
};
bind生成LifecycleTransformer
看懂了3队他，我們回到2，我們生成了一個(gè)Observable峻村，然后通過(guò)bind(Observable)方法麸折，生成LifecycleTransformer并返回：
public static <T, R> LifecycleTransformer<T> bind(@Nonnull final Observable<R> lifecycle) {
return new LifecycleTransformer<>(lifecycle);
}
神秘人的神秘面紗就此揭開(kāi)。
總結(jié)
RxLifecycle并不難以理解粘昨，相反垢啼，它的設(shè)計(jì)思路很簡(jiǎn)單：
1.在Activity中，定義一個(gè)Observable（Subject）张肾，在不同的生命周期發(fā)射不同的事件芭析；
2.通過(guò)compose操作符（內(nèi)部實(shí)際上還是依賴(lài)takeUntil操作符），定義了上游數(shù)據(jù)捌浩，當(dāng)其接收到Subject的特定事件時(shí)放刨，取消訂閱；
3.Subject的特定事件并非是ActivityEvent尸饺，而是簡(jiǎn)單的boolean进统，它已經(jīng)內(nèi)部通過(guò)combineLast操作符進(jìn)行了對(duì)應(yīng)的轉(zhuǎn)化。
實(shí)際上浪听，Subject和ActivityEvent對(duì)RxLifecycle的使用者來(lái)講螟碎，是對(duì)應(yīng)隱藏的。我們只需要調(diào)用它提供給我們的API,而內(nèi)部的實(shí)現(xiàn)者我們無(wú)需考慮迹栓，但是也只有去閱讀和理解了它的思想掉分，我們才能更好的選擇使用這個(gè)庫(kù)。
轉(zhuǎn)折：AutoDispose
在我沉迷于RxLifecycle對(duì)項(xiàng)目的便利時(shí)克伊，一個(gè)機(jī)會(huì)酥郭，我有幸閱讀到了 Daniel Lew 的文章《Why Not RxLifecycle?》（為什么放棄使用RxLifecycle）。
作為RxLifecycle的作者愿吹，Daniel Lew客觀陳述了使用RxLifecycle在開(kāi)發(fā)時(shí)所遇到的窘境不从。并且為我們提供了一個(gè)他認(rèn)為更優(yōu)秀的設(shè)計(jì)：
AutoDispose: Automatic binding+disposal of RxJava 2 streams.
我花了一些時(shí)間研究了一下AutoDispose，不得不承認(rèn)犁跪，AutoDispose相比較RxLifecycle椿息，前者更加健壯歹袁，并且擁有更優(yōu)秀的拓展性，如果我的項(xiàng)目需要一個(gè)處理RxJava自動(dòng)取消訂閱的庫(kù)寝优，也許AutoDispose更為適合条舔。
更讓我感到驚喜的是，AutoDispose的設(shè)計(jì)思想乏矾，有很大一部分和RxLifecycle相似孟抗，而且我在其文檔上，看到了Uber的工程師對(duì)于Daniel Lew 所維護(hù)的 RxLifecycle 感謝妻熊，也感謝Daniel Lew 對(duì)于 AutoDispose的很大貢獻(xiàn)：
以下摘錄于AutoDispose的官方文檔：
Special thanks go to Dan Lew (creator of RxLifecycle), who helped pioneer this area for RxJava in android and humored many of the discussions around lifecycle handling over the past couple years that we've learned from. Much of the internal scope resolution mechanics of
AutoDispose are inspired by RxLifecycle.
在我嘗試將AutoDispose應(yīng)用在項(xiàng)目中時(shí)夸浅，我發(fā)現(xiàn)國(guó)內(nèi)對(duì)于這個(gè)庫(kù)所應(yīng)用的不多，我更希望有更多朋友能夠和我一起使用這個(gè)庫(kù)，于是我準(zhǔn)備寫(xiě)一篇關(guān)于AutoDispose使用方式的文章芦劣。
但在這之前忘朝，我還是希望能夠先將RxLifecycle的個(gè)人心得分享給大家，原因有二：
一是RxLifecycle更簡(jiǎn)單伴澄，原理也更好理解，學(xué)習(xí)一個(gè)庫(kù)不僅僅是為了會(huì)使用它，我們更希望能夠從源碼中學(xué)習(xí)到作者優(yōu)秀的設(shè)計(jì)和思想侈玄。因此，如果是從未接觸過(guò)這兩個(gè)庫(kù)的開(kāi)發(fā)者吟温，直接入手AutoDispose序仙，在我看來(lái)不如先入手RxLifecycle。
二是AutoDispose的很大一部分設(shè)計(jì)核心源于RxLifecycle鲁豪，理解了RxLifecycle潘悼，更有利于AutoDispose的學(xué)習(xí)。
接下來(lái)我將會(huì)嘗試向大家闡述AutoDispose的使用及其內(nèi)部原理爬橡，和RxLifecycle不同治唤，我們不再需要去繼承RxActivity/RxFragment，而是內(nèi)部依賴(lài)使用了google不久前推出的架構(gòu)組件 Lifecycle（事實(shí)上這也是我青睞AutoDispose的原因之一糙申，盡量避免繼承可以給代碼更多選擇的余地）宾添。
2018-3-1追加更新
填坑后歸來(lái)：
