Rxlifecycle使用详解，解决RxJava内存泄露问题

发表于 | 分类于 |

原文地址
http://www.jcodecraeer.com/a/anzhuokaifa/androidkaifa/2015/1122/3711.html

随着Android第三方库的普及，RxJava和RxAndroid(https://github.com/ReactiveX/RxAndroid)越来越被人熟知，简洁的语法，配合Java8 Lambda表达式，使代码的结构更加清晰，通过线程调度器更容易控制和切换线程，种种优点，使用它的人也越来越多。但是使用不好，很容易导致内存泄露。Rxlifecycle(https://github.com/trello/RxLifecycle) 就是被用来严格控制由于发布了一个订阅后，由于没有及时取消，导致Activity/Fragment无法销毁导致的内存泄露。

RxJava和RxAndroid

1
2
compile 'io.reactivex:rxjava:1.1.1'
compile 'io.reactivex:rxandroid:1.1.0'

Rxlifecycle

1
compile 'com.trello:rxlifecycle:0.5.0'

Rxlifecycle 使用

Activity/Fragment需继承RxAppCompatActivity/RxFragment，目前支持的有RxAppCompatActivity、RxFragment、RxDialogFragment、RxFragmentActivity。

一、bindToLifecycle()方法
在子类使用Observable中的compose操作符，调用，完成Observable发布的事件和当前的组件绑定，实现生命周期同步。从而实现当前组件生命周期结束时，自动取消对Observable订阅。

1
2
3
4
5
6
7
8
Observable.interval(1, TimeUnit.SECONDS)
    .compose(this.bindToLifecycle())
    .subscribe(new Action1<Long>() { 
        @Override
        public void call(Long num) {
            Log.i(TAG, "  " +num);
        }
    });

二、bindUntilEvent() 方法
使用ActivityEvent类，其中的CREATE、START、 RESUME、PAUSE、STOP、 DESTROY分别对应生命周期内的方法。使用bindUntilEvent指定在哪个生命周期方法调用时取消订阅。

1
2
3
Observable.interval(1, TimeUnit.SECONDS)
    .compose(this.bindUntilEvent(ActivityEvent.PAUSE))  
    .subscribe(mSub);