RxJava2：页面切换/离开时如何让网络请求完成且无内存泄漏

针对你的问题，核心矛盾是既要让依赖的网络请求完整执行，又要避免因持有已销毁视图的引用导致内存泄漏。下面分几个步骤给出具体方案：

1. 先重构你的Parse请求Observable（符合Rx最佳实践） #

你当前的Observable.create里是同步执行save()，这会阻塞线程，也没利用Rx的异步优势。Parse的save()有异步方法saveInBackground，我们可以把每个保存操作包装成Observable，用flatMap按顺序串联，这样更安全且符合Rx规范：

// 包装Parse对象的save操作成Observable
private fun saveParseObject(obj: ParseObject): Observable<ParseObject> {
    return Observable.create { emitter ->
        obj.saveInBackground { e ->
            if (e == null) {
                emitter.onNext(obj)
                emitter.onComplete()
            } else {
                emitter.onError(e)
            }
        }
    }
}

// 重构后的链式请求
fun doParseNetworkCall(): Observable<Boolean> {
    return saveParseObject(createParseObject1())
        .flatMap { obj1 ->
            val obj2 = createParseObject2()
            obj2.add(key, obj1)
            saveParseObject(obj2)
        }
        .flatMap { obj2 ->
            val obj3 = createParseObject3()
            obj3.add(key, obj2)
            saveParseObject(obj3)
        }
        .map { true } // 最终返回成功标记
}

这样每个保存操作都是异步的，且严格按顺序执行，不会阻塞线程。

2. 避免持有视图/Presenter的强引用 #

你提到不调用dispose()时，onComplete会触发错误，本质是因为回调里引用了已销毁的视图（比如更新UI、调用Presenter的视图方法）。解决这个问题的关键是让订阅回调不持有视图的强引用：

方案A：使用弱引用持有Presenter/视图 #

如果你的回调里确实需要做一些非UI操作（比如本地存储），可以用弱引用避免泄漏：

fun doNetworkCall() {
    val weakPresenter = WeakReference(this) // 假设当前是Presenter类
    repo.doParseNetworkCall()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribeBy(
            onError = { error ->
                weakPresenter.get()?.run {
                    // 这里只做不依赖视图的操作，比如记录日志
                    logError(error)
                }
            },
            onComplete = {
                weakPresenter.get()?.run {
                    // 同样只做无视图依赖的操作
                    logSuccess()
                }
            }
        )
        // 注意：这里不要addTo视图相关的CompositeDisposable！
}

方案B：完全忽略回调（因为你不在意结果回调） #

既然你说不在意onComplete/onError是否被调用，那可以简化订阅，只处理必要的错误（避免崩溃），且不引用任何视图对象：

fun doNetworkCall() {
    repo.doParseNetworkCall()
        .subscribeOn(Schedulers.io())
        .subscribe(
            {}, // onNext空实现
            { error ->
                // 只记录错误，不涉及任何视图操作
                Log.e("ParseRequest", "请求失败", error)
            }
        )
    // 不将Disposable加入视图的CompositeDisposable，让请求在后台自行完成
}

这样即使视图销毁了，请求会在后台继续执行，且回调里没有持有任何视图引用，不会造成内存泄漏。

3. 关键：要不要调用dispose()？ #

• 如果你的订阅回调没有持有视图的强引用，不需要调用dispose()：因为Observable执行完成后会自动释放所有资源，且回调里没有引用视图，视图可以被正常GC回收，不会泄漏。
• 如果必须管理Disposable（比如全局统一管理后台任务），可以用一个全局的CompositeDisposable来持有这些后台请求的Disposable，而不是绑定到单个Fragment/Presenter的生命周期。比如在Application类中维护一个全局CompositeDisposable，在应用退出时统一dispose，但这对你的场景来说可能没必要，因为请求完成后会自动终止。

4. 额外：处理未捕获的Rx错误 #

为了避免请求完成后因视图销毁导致的回调错误，可以全局设置RxJava的错误处理器，防止崩溃：

// 在Application的onCreate中设置
RxJavaPlugins.setErrorHandler { error ->
    if (error is IOException || error is ParseException) {
        // 网络或Parse相关错误，只记录日志
        Log.e("RxError", "后台请求错误", error)
    } else {
        // 其他错误按原有逻辑处理
        Thread.currentThread().uncaughtExceptionHandler?.uncaughtException(Thread.currentThread(), error)
    }
}

这样即使回调中有意外错误，也不会导致崩溃，只会记录日志。

内容的提问来源于stack exchange，提问作者Ben987654