RxJava解析长JSON时页面退出致应用崩溃问题求助

看起来你遇到的问题是：在使用RxJava 2.1.9解析长JSON数据时，用户离开当前页面后任务本该终止，却因为InterruptedException被包装成RuntimeException导致应用崩溃。我来帮你分析原因并给出解决方案。

问题根源 #

你在Observable.create内部执行了阻塞式的网络连接和JSON解析操作，当用户离开页面时，你应该已经调用了Disposable.dispose()来终止任务。此时RxJava会中断执行该任务的线程，但你的代码没有正确处理InterruptedException，这个异常被RxJava包装成RuntimeException抛出，最终导致应用崩溃。

另外，你的示例代码里Observable.create的泛型是Boolean，但实际要返回的是List<Pair<String, String>?>，这可能也是个小问题，得注意类型匹配。

解决方案 #

我给你两种可行的修复方案，你可以根据自己的情况选择：

方案1：正确处理Observable.create中的中断异常

如果坚持要用Observable.create，一定要在代码中捕获InterruptedException，并且在发送事件前检查emitter.isDisposed()，避免在任务已终止时继续发送事件：

override fun restore(): Observable<List<Pair<String, String>?>> {
    return backupRemoteSource.getBackup()
        .flatMap { urlBackup ->
            Observable.create<List<Pair<String, String>?>> { emitter ->
                try {
                    val url = URL(urlBackup)
                    val connection = url.openConnection()
                    // 这里替换成你的长JSON解析逻辑，最终返回目标List
                    val parsedResult = parseLargeJson(connection.inputStream)
                    
                    // 只有当emitter未被销毁时，才发送结果和完成事件
                    if (!emitter.isDisposed) {
                        emitter.onNext(parsedResult)
                        emitter.onComplete()
                    }
                } catch (e: InterruptedException) {
                    // 中断异常是任务被dispose时的正常情况，无需传递错误，直接终止即可
                    if (!emitter.isDisposed) {
                        emitter.onComplete()
                    }
                } catch (e: Exception) {
                    // 处理其他异常
                    if (!emitter.isDisposed) {
                        emitter.onError(e)
                    }
                }
            }
        }
}

方案2：使用Observable.fromCallable简化代码（推荐）

RxJava提供了fromCallable操作符来处理阻塞式任务，它会自动处理线程中断逻辑，不需要你手动捕获InterruptedException，代码更简洁安全：

override fun restore(): Observable<List<Pair<String, String>?>> {
    return backupRemoteSource.getBackup()
        .flatMap { urlBackup ->
            Observable.fromCallable {
                val url = URL(urlBackup)
                val connection = url.openConnection()
                // 执行你的长JSON解析逻辑
                parseLargeJson(connection.inputStream)
            }
        }
}

额外注意事项 #

1. 生命周期绑定：一定要在页面（Activity/Fragment）的销毁阶段终止RxJava任务，用CompositeDisposable来管理所有Disposable是个好习惯：

private val compositeDisposable = CompositeDisposable()

// 调用restore方法时
compositeDisposable.add(restore()
    .subscribeOn(Schedulers.io()) // 确保耗时操作在IO线程执行
    .observeOn(AndroidSchedulers.mainThread()) // 切换回主线程处理结果
    .subscribe({ result ->
        // 处理解析完成后的结果
    }, { error ->
        // 处理其他异常情况
    })
)

override fun onDestroy() {
    super.onDestroy()
    compositeDisposable.dispose() // 终止所有未完成的任务
}

2. 优化JSON解析：解析长JSON时，建议使用流式解析（比如Gson的JsonReader），这样可以减少内存占用，同时避免长时间阻塞线程，降低中断导致崩溃的概率。

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