RxJava内存泄漏——（1）例子、RxLifecycle和引出AutoDispose

水深无声 2023-05-28 05:04 11阅读 0赞

本文例子中所谓内存泄漏，就是：  
**点击back键后onNext仍然被回调，log一直持续输出。**

使用过**Rxjava**的小伙伴都知道，在使用RxJava时如果处理不当，很可能会产生**内存泄漏**的问题。  
我们使用rxjava最大的原因是响应式编程使我们的异步操作代码变得很优雅，在Android中，也使线程切换变得很简单，而产生内存泄漏的大部分原因都是在异步执行耗时操作时，我们关闭了Activity，但是由于rxjava仍然持有Activity的引用，导致Activity无法被内存回收。这样就造成了内存泄漏问题。

我们先举个例子来看看内存泄漏产生的过程及结果

**内存泄漏小例子**

布局很简单，就是一个按钮和一个TextView

<?xml version="1.0" encoding="utf-8"?>
    <android.support.constraint.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
        xmlns:tools="http://schemas.android.com/tools"
        android:layout_width="match_parent"
        android:layout_height="match_parent"
        xmlns:app="http://schemas.android.com/apk/res-auto"
        tools:context=".MainActivity">
        <TextView
            android:id="@+id/numTv"
            android:text="数值"
            android:padding="10dp"
            android:gravity="center"
            android:layout_width="match_parent"
            android:layout_height="wrap_content" />
        <Button
            android:id="@+id/btn"
            app:layout_constraintTop_toBottomOf="@id/numTv"
            android:layout_width="match_parent"
            android:layout_marginTop="10dp"
            android:layout_height="wrap_content"
            android:text="点击" />
    </android.support.constraint.ConstraintLayout>
    
     
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
       18
       19
       20
       21
       22
       23
       24
       25
       26

就长这样

![这里写图片描述][70]

添加rxjava依赖，这里我是用kotlin写的demo，所以依赖的是rxkotlin，使用java的直接依赖rxjava的sdk即可。

/*RxJava相关依赖*/
        implementation "io.reactivex.rxjava2:rxkotlin:2.2.0"
        implementation "io.reactivex.rxjava2:rxandroid:2.0.2"

下面我们来看看Activity的代码，kotlin写的，也很简单。这里扯点题外话，kotlin写起来真的很爽，不需要findviewbyid，空安全，类型推断，扩展函数等特性用起来真的很爽，在实际项目中能减少很多代码，值得一试。

class MainActivity : AppCompatActivity(), View.OnClickListener {
        override fun onCreate(savedInstanceState: Bundle?) {
            super.onCreate(savedInstanceState)
            setContentView(R.layout.activity_main)
            btn.setOnClickListener(this)
        }
        override fun onClick(view: View?) {
            when (view!!.id) {
                R.id.btn ->
                    doSomting()
            }
        }
        private fun doSomting() {
            Observable.interval(1, TimeUnit.SECONDS)
                    .observeOn(AndroidSchedulers.mainThread())//在主线程处理结果
                    .subscribeOn(Schedulers.io())//工作线程处理逻辑
                    .subscribe(Consumer {
                        Log.i("rxjava发射的数据","1")
                        //numTv.text = it.toString()
                    })
        }
        override fun onDestroy() {
            super.onDestroy()
            Log.i("MainActivity","onDestroy")
        }
    }

我们在点击按钮后，RxJava开始每隔一秒就发一个数值给我们，我们将其更新到textview上。但是当我们关闭应用时，rxjava仍然在继续发送数据，并且还持有MainActivity的实例，这就导致了MainActivity 无法被回收，造成了内存泄漏。  
如下图所示，我们在多次点击按钮后，然后关闭应用，再点击内存回收按钮后发现内存中的MainActivity实例并没有被销毁。内存分析具体看下图

![这里写图片描述][70 1]

在实际项目中我们经常有这种需求，比如网络请求一个接口，然后更新ui等。这些操作都可能产生内存泄漏。下面我们来看看解决办法。

--------------------

**如何解决RxJava内存泄漏**

**1.在ondestory中手动切断连接**（**不推荐**）  
这种方法是比较原始的方法，在onSubscribe我们将Disposable保存起来，在onDestory中调用disposable.dispose()取消订阅

如果在实际开发中使用这种方法，我们需要手动的去维护所有RxJava产生的Disposable，费时费力。

class MainActivity : AppCompatActivity(), View.OnClickListener {
        lateinit var disposable: Disposable
        override fun onCreate(savedInstanceState: Bundle?) {
            super.onCreate(savedInstanceState)
            setContentView(R.layout.activity_main)
            btn.setOnClickListener(this)
        }
        override fun onClick(view: View?) {
            when (view!!.id) {
                R.id.btn ->
                    doSomting()
            }
        }
        private fun doSomting() {
            Observable.interval(1, TimeUnit.SECONDS)
                    .observeOn(AndroidSchedulers.mainThread())//在主线程处理结果
                    .subscribeOn(Schedulers.io())//工作线程处理逻辑
                    .subscribe(object : Observer<Long> {
                        override fun onSubscribe(d: Disposable) {
                            disposable = d
                        }
                        override fun onNext(t: Long) {
                            Log.i("rxjava发射的数据", t.toString())
                            numTv.text = t.toString()
                        }
                        override fun onError(e: Throwable) {
                        }
                        override fun onComplete() {
                        }
                    })
        }
        override fun onDestroy() {
            super.onDestroy()
            disposable.dispose()//取消绑定
            Log.i("MainActivity", "onDestroy")
        }
    }

**2.使用RxLifecycle自动解绑（不推荐）**  
首先 [RxLifecycle][] Github地址。  
在使用AutoDispose之前，我一直使用的是RxLifecycle去解决RxJava的内存泄漏问题。  
使用方法很简单。具体使用方法我这里就不介绍了，很简单，可以直接看Github上的文档。  
大体使用方法如下

Observable.interval(1, TimeUnit.SECONDS)
                    .doOnUnsubscribe { Log.i(TAG, "Unsubscribing subscription from onCreate()") }
                    .bindUntilEvent(this, ActivityEvent.PAUSE)
                    .subscribe { num -> Log.i(TAG, "Started in onCreate(), running until onPause(): " + num!!) }
    
     
      
     
      
       1
       2
       3
       4

我们可以直接使用bindUntilEvent(this, ActivityEvent.PAUSE)来实现自动解绑的功能，并且可以指定在哪个生命周期去自动解绑，但是**前提条件**是我们的**Activity必须要继承RxLifecycle提供的RxAppCompatActivity，同样的我们的Fragment必须要继承RxLifecycle提供的RxFragment**  
在Java中，类都是单继承的，我们的Activity如果需要继承别的类，那么我们就必须多写一个Activity基类供下面的Activity去继承。这显然是不优雅的实现方式。  
**如果说你的Activity或Fragment不需要继承其他的Activity或Fragment，那么使用RxLifecycle也没有什么不妥。**

**3.使用AutoDispose优雅的实现RxJava自动解绑**

首先是 [AutoDispose][] Github地址。  
AutoDispose是uber的一个开源库。**注意：0.8.0以后的版本需要先将项目迁移至AndroidX,否则会提示错误**

[70]: /images/20230528/ef93061219ea4e4f95fdce0a5ef3907c.png
[70 1]: /images/20230528/233f15b464684b75a286ba95b7c236b6.png
[RxLifecycle]: https://github.com/trello/RxLifecycle
[AutoDispose]: https://github.com/uber/AutoDispose