Android 第三方库RxLifecycle使用 _三方库

笛里谁知壮士心，沙头空照征人骨。这篇文章主要讲述Android 第三方库RxLifecycle使用相关的知识，希望能为你提供帮助。
1.简单介绍RxLifecycle1.1.使用原因。
在使用rxjava的时候，如果没有及时解除订阅，在退出activity的时候，异步线程还在执行。
对activity还存在引用，此时就会产生内存泄漏。
RxLifecycle就是为了解决rxjava导致的内存泄漏而产生的。

1.2.RxLifecycle可以做到什么呢？
它可以让Observable发布的事件和当前的组件绑定，实现生命周期同步。
从而实现当前组件生命周期结束时，自动取消对Observable订阅。
核心思想：通过监听Activity、Fragment的生命周期，来自动断开订阅防止内存泄漏。

1.3.参考文献。
Rxandroid的github地址：https://github.com/ReactiveX/RxAndroid
Rxlifecycle的github地址：https://github.com/trello/RxLifecycle
参考文章：Rxlifecycle使用详解。
参考文章：在mvp中使用rxlifecycle避免rxjava的内存泄漏。

2.使用方法2.1.添加最新的依赖

//rxjava的依赖 compile ‘io.reactivex.rxjava2:rxandroid:2.0.1‘ compile ‘io.reactivex.rxjava2:rxjava:2.1.7‘ //rxlifecycle的依赖 compile ‘com.trello.rxlifecycle2:rxlifecycle-android-lifecycle-kotlin:2.2.1‘

2.2.Activity以及Fragment的继承
Activity需要继承RxAppCompatActivity。==> 比如这么一个类

public class BaseActivity extends RxAppCompatActivity

Fragment需要继承RxFragment。==> 比如这么一个类

public abstract class BaseFragment< T extends IBasePresenter> extends RxFragment implements IBaseView< T>

2.3.绑定生命周期。
自己写一个接口，里面定义一个bindToLife()函数。

/** * 绑定生命周期 */ < T> LifecycleTransformer< T> bindToLife();

这个bindToLife()是自定义的名字，这里就叫做bindToLife好了。
这个接口是自己定义的一个接口，我让Fragment来继承这个接口。
这个返回的是一个LifecycleTransformer< T> ，这个官方的一个类。而且这里使用了泛型，更加通用了。

2.4.在自己的Fragment中实现这个接口函数。

/** * 绑定生命周期 */ @Override public < T> LifecycleTransformer< T> bindToLife() { return bindUntilEvent(FragmentEvent.DESTROY); }

这里调用了官方的一个bindUntilEvent的方法，以此函数来绑定生命周期。
这里的FragmentEvent.DESTROY，顾名思义，就是当Fragment销毁的时候，自动解除订阅关系。

注意：这里使用了FragmentEvent类，其中的CREATE/START/RESUME/PAUSE/STOP/DESTROY
分布对应生命周期内的方法。使用bindUntilEvent指定在哪个生命周期方法调用示取消订阅。

2.5.在请求API函数的时候，执行自己写的bindToLife()
　调用Observable< T> .compose(执行接口中的bindToLife())
compose里面的东西应该是：LifecycleTransformer< T> 。

3.对于Rxlifecycle的理解3.1.使用原因就不用多说了，解决RxJava导致的内存泄漏。

3.2.因为activity和fragment控制切换线程的时候，引用没有清除干净，所以就把手脚着重于activity和fragment的
生命周期了，就是说，如果你的活动如果碰到意外或者用户主动销毁，那么也断开订阅，就是订阅的生命周期
和活动的生命周期已经融为一体了，那就不用担心再发生内存泄漏了，所以这种绑定生命周期的方法是从根本
上解决了内存泄漏。感觉没有更好的方法解决了。

3.3.其实官方为了两种解决方案。
一种是手动取消订阅，我不知道怎么用，也没有实战过。
这里提供一下大神的文章：RxAndroid之Rxlifecycle使用。
手动设置在activity onPause的时候取消订阅。

private static final String TAG = "RxLifecycle"; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); Log.d(TAG, "onCreate()"); setContentView(R.layout.activity_main); Observable.interval(1, TimeUnit.SECONDS) .doOnUnsubscribe(new Action0() { @Override public void call() { Log.i(TAG, "Unsubscribing subscription from onCreate()"); } }) //Note:手动设置在activity onPause的时候取消订阅 .compose(this.< Long> bindUntilEvent(ActivityEvent.PAUSE)) .subscribe(new Action1< Long> () { @Override public void call(Long num) { Log.i(TAG, "Started in onCreate(), running until onPause(): " + num); } }); }

手动设置在activity的onDestroy的时候取消订阅。

@Override protected void onResume() { super.onResume(); Log.d(TAG, "onResume()"); // `this.< Long> ` is necessary if you‘re compiling on JDK7 or below. // If you‘re using JDK8+, then you can safely remove it. Observable.interval(1, TimeUnit.SECONDS) .doOnUnsubscribe(new Action0() { @Override public void call() { Log.i(TAG, "Unsubscribing subscription from onResume()"); } }) //Note:手动设置在activity onDestroy的时候取消订阅 .compose(this.< Long> bindUntilEvent(ActivityEvent.DESTROY)) .subscribe(new Action1< Long> () { @Override public void call(Long num) { Log.i(TAG, "Started in onResume(), running until in onDestroy(): " + num); } }); }

自动设置取消订阅，默认在onStart的时候调用，在onStop的时候取消订阅。

@Override protected void onStart() { super.onStart(); Log.d(TAG, "onStart()"); // Using automatic unsubscription, this should determine that the correct time to // unsubscribe is onStop (the opposite of onStart). Observable.interval(1, TimeUnit.SECONDS) .doOnUnsubscribe(new Action0() { @Override public void call() { Log.i(TAG, "Unsubscribing subscription from onStart()"); } }) //Note:bindToLifecycle的自动取消订阅示例，因为是在onStart的时候调用，所以在onStop的时候自动取消订阅 .compose(this.< Long> bindToLifecycle()) .subscribe(new Action1< Long> () { @Override public void call(Long num) { Log.i(TAG, "Started in onStart(), running until in onStop(): " + num); } }); }

【Android 第三方库RxLifecycle使用】