rxjava如何避免内存泄漏

在 RxJava 中，内存泄漏的根本原因通常是：订阅（Subscription / Disposable）没有及时取消，导致 Observer 持有 Activity / Fragment / View 等外部对象，页面销毁后仍被 RxJava 链条引用。

下面从 原理 → 常见场景 → 解决方案 系统说明。

一、内存泄漏的根本原因

典型泄漏示例：

Observable.timer(10, TimeUnit.SECONDS)
    .subscribe(aLong -> {
        // 这里持有了 Activity
        textView.setText("done");
    });

问题：

• subscribe 返回的 Disposable 没有管理
• Activity 销毁后，RxJava 仍持有内部类（匿名内部类 → 隐式持有 Activity）
• GC 无法回收 Activity

二、核心解决方案总览

✅ 核心原则：页面销毁时，取消所有订阅

三、最推荐方案：CompositeDisposable

1️⃣ 基本用法（官方推荐）

public class MyActivity extends AppCompatActivity {

    private CompositeDisposable compositeDisposable = new CompositeDisposable();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        Disposable disposable = Observable.interval(1, TimeUnit.SECONDS)
                .subscribe(t -> Log.d("Rx", "tick"));

        compositeDisposable.add(disposable);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        compositeDisposable.clear(); // 或 dispose()
    }
}

✅ clear() vs dispose()

• clear()：可继续 add
• dispose()：不可再使用

四、更优雅方案：AutoDispose（强烈推荐）

1️⃣ AutoDispose 原理

自动在生命周期结束时取消订阅

2️⃣ 使用方式

Observable.interval(1, TimeUnit.SECONDS)
    .as(autoDispose(this))
    .subscribe(t -> Log.d("Rx", "tick"));

或配合 AndroidLifecycleScopeProvider：

.as(AutoDispose.autoDisposable(AndroidLifecycleScopeProvider.from(this)))

✅ 优点

• 不用手动管理 Disposable
• 不会忘记 cancel
• 与 Lifecycle 深度集成

五、RxLifecycle（老方案）

Observable.timer(3, TimeUnit.SECONDS)
    .compose(bindToLifecycle())
    .subscribe();

⚠️ 现已逐渐被 AutoDispose 替代

六、常见泄漏场景 & 正确写法

❌ 错误：内部类隐式持有 Activity

observable.subscribe(new Observer<String>() {
    @Override
    public void onNext(String s) {
        textView.setText(s); // 持有 Activity
    }
});

✅ 解决

• 用 CompositeDisposable
• 或 AutoDispose

❌ 错误：Retrofit + RxJava 忘记取消

api.getUser()
    .subscribe(user -> updateUI(user));

✅ 正确

api.getUser()
    .as(autoDispose(this))
    .subscribe(user -> updateUI(user));

七、线程切换注意点

即使切到 Schedulers.io()，也必须取消订阅：

Observable.fromCallable(() -> doWork())
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .as(autoDispose(this))
    .subscribe();

八、检测内存泄漏工具

✅ 强烈建议配合：

• LeakCanary
• Android Studio Profiler
• MAT

九、一句话总结

RxJava 避免内存泄漏的本质：页面销毁前，取消所有 Disposable

✅ 推荐组合：

• AutoDispose（首选）
• CompositeDisposable（必备基础）
• 避免匿名内部类持有 UI

如果你愿意，我可以：

• 给你一个 完整 Activity + RxJava 防泄漏模板
• 或对比 AutoDispose vs RxLifecycle
• 或结合 Kotlin + Coroutine 对比