RxJava内存泄漏怎么办

在 Android / Java 中使用 RxJava 时，内存泄漏最常见的根源是：订阅（Subscription / Disposable）没有被及时取消，导致 Activity / Fragment 被持有而无法回收。

下面从「原因 → 解决方案 → 最佳实践」系统讲一下。

一、RxJava 内存泄漏的常见原因

1️⃣ 忘了取消订阅

Observable.interval(1, TimeUnit.SECONDS)
    .subscribe(t -> updateUI());

如果 Activity 销毁了但没 dispose()，这个流会一直持有 Activity。

2️⃣ 使用匿名内部类

observable.subscribe(new Observer<T>() {
    void onNext(T t) {
        activityField.xxx();
    }
});

匿名内部类 隐式持有外部类（Activity）。

3️⃣ 生命周期比订阅长

• Activity 销毁了
• RxJava 线程还在跑（IO / computation）
• 回调里操作 UI 或 Context

二、解决方案（重点）

✅ 方案 1：使用 Disposable / CompositeDisposable

Java

CompositeDisposable compositeDisposable = new CompositeDisposable();

Disposable d = observable.subscribe(...);
compositeDisposable.add(d);

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

✅ clear()：可复用
✅ dispose()：不可复用

✅ 方案 2：RxJava + 生命周期自动绑定（推荐）

AndroidX

implementation 'androidx.lifecycle:lifecycle-runtime-ktx:xxx'

observable
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(viewLifecycleOwner, Observer { })

或使用：

RxLifecycle

observable
    .compose(bindUntilEvent(ActivityEvent.DESTROY))
    .subscribe(...)

AutoDispose（已不推荐但经典）

observable
    .as(autoDispose(this))
    .subscribe(...)

✅ 方案 3：使用 DisposableObserver

DisposableObserver<T> observer = new DisposableObserver<T>() {
    @Override public void onNext(T t) {}
    @Override public void onError(Throwable e) {}
    @Override public void onComplete() {}
};

observable.subscribeWith(observer);
// 销毁时
observer.dispose();

✅ 方案 4：避免在流中持有 Activity

❌ 错误

.subscribe(data -> textView.setText(data));

✅ 正确

.subscribe(data -> {
    if (!isFinishing()) {
        textView.setText(data);
    }
});

或使用 viewLifecycleOwner

三、Kotlin 最佳实践（强烈推荐）

使用 lifecycleScope 替代 RxJava（官方趋势）

lifecycleScope.launch {
    flow.collect { updateUI(it) }
}

或使用 repeatOnLifecycle

lifecycleScope.launch {
    repeatOnLifecycle(Lifecycle.State.STARTED) {
        viewModel.data.collect { }
    }
}

四、排查内存泄漏的方法

工具

• LeakCanary
• Android Studio Profiler
• MAT

常见泄漏特征

• Activity 实例数量持续增长
• GC 后 Activity 仍存在
• RxJava 线程未结束

五、总结一句话

RxJava 内存泄漏 = 订阅未取消 + 生命周期未绑定

✅ 核心解决办法：

1. 用 CompositeDisposable
2. 绑定生命周期
3. 不持有 Activity
4. 新项目优先用 Coroutine + Flow

如果你愿意，可以：

• 贴一段你的 RxJava 代码
• 或说明是 Java / Kotlin + Android / 后端 我可以直接帮你改造成不泄漏的写法。