Android-在 ViewModel 中使用 AutoDispose2 解决 RxJava 的内存泄露问题RxJava 的内存泄露问题解决方案AutoDispose2参考

112 阅读 0 评论 74 点赞

我是靠谱客的博主欣喜香菇，最近开发中收集的这篇文章主要介绍Android-在 ViewModel 中使用 AutoDispose2 解决 RxJava 的内存泄露问题RxJava 的内存泄露问题解决方案AutoDispose2参考，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

RxJava 的内存泄露问题

runRxLambda 和 runRxLambdaViewModel 只是个扩展函数，可以不用理会，下面两段代码唯一的区别就是第二段增加了 AndroidLifecycleScopeProvider.from(view)，这也导致了第二段代码不会出现内存泄露，而第一段代码会出现内存泄露。

runRxLambda(Observable.intervalRange(0,100,1,1,TimeUnit.SECONDS),{
            Log.e("222","runRxLambda-time:$it")
        },{},{})

// 只处理成功，失败的可以处理可以不处理
  runRxLambdaViewModel(AndroidLifecycleScopeProvider.from(view),Observable.intervalRange(0,100,1,1,TimeUnit.SECONDS),{
            Log.e("222","runRxLambdaViewModel-time:$it")
            mElapsedRealTime.postValue(it)
        })

下面的日志对应的操作流程是：跳转一个页面后点击一个按钮，执行上面的两段代码，然后立即返回上一个页面。

通过日志也可以看出第一段代码内存泄露了吧，页面都已经关闭但是相关的逻辑代码还在执行。这就是 RxJava使用中常见的内存泄露问题。

在这里插入图片描述

解决方案

在 onSubscribe(d: Disposable) 回调中保存 dispose ，在页面关闭的时候调用.dispose() 方法
使用RxLifeCycle , 地址：https://github.com/trello/RxLifecycle
使用AutoDispose , 地址：https://uber.github.io/AutoDispose/#overview

这里仅介绍AutoDispose2 的使用

AutoDispose2

引入依赖

implementation 'com.uber.autodispose2:autodispose-android:2.0.0'
implementation 'com.uber.autodispose2:autodispose-androidx-lifecycle:2.0.0'

AutoDispose 解决的问题：

AutoDispose是一种RxJava 2+工具，用于通过处置/取消将RxJava流的执行自动绑定到提供的作用域。通常（尤其是在移动应用程序中），Rx订阅需要停止以响应某些事件（例如，在Android应用程序中执行Activity＃onStop（）时）。为了支持RxJava 2中的这种常见情况，我们构建了AutoDispose。

在 Activity 和 Fragment 中使用

解决办法伪代码如下：

myObservable
    .doStuff()
    .as(autoDisposable(this))   // The magic
    .subscribe(s -> ...);

只要这样一行as(autoDisposable(this))，您将按照作用域指示自动取消订阅myObservable , 这有助于防止在Observable发出项目时出现许多错误类别。

在 ViewModel 或者 Presenter 中使用

// 构造函数注入 LifecycleOwner，然后在 activity 或者fragment 中传入 this 参数即可。
class MineViewModel(val view:LifecycleOwner) : BaseViewModel() {

    private val mElapsedRealTime = MutableLiveData<Long>()

    val countDownTime: MutableLiveData<Long> by lazy {
        mElapsedRealTime
    }

    /**
     * 开启倒计时
     * 加入这一行：AndroidLifecycleScopeProvider.from(view)
     */
    fun getTime(){
        // 只处理成功，失败的可以处理可以不处理
        runRxLambdaViewModel(AndroidLifecycleScopeProvider.from(view),
        Observable.intervalRange(0,100,1,1,TimeUnit.SECONDS),{
            mElapsedRealTime.postValue(it)
        })
    }
}