利用 Kotlin 扩展函数优雅处理网络异常详解

三、传统异常处理的痛点

通常情况下，我们会在 Observer 的 onError 中按照如下的方式处理异常：

viewModel.getHelps(this)
    .subscribe(
        { response ->
            if (response.isOkStatus) {
                multi_status_view.showContent()
                adapter.addData(response.data?.list)
            } else {
                multi_status_view.showError()
            }
        }, 
        { throwable -> 
            multi_status_view.showError() 
        }
    )

这种方式存在以下问题：

1. 逻辑耦合：UI 更新逻辑与异常捕获逻辑混在一起。
2. 重复代码：每次请求都需要编写类似的 if-else 判断。
3. 维护困难：如果错误处理策略变更，需要修改所有订阅点。

四、Kotlin 扩展函数的解决方案

利用 Kotlin 扩展函数的特性，我们可以针对 RxJava 的 Maybe 类型编写通用的错误处理扩展函数。这样无须在 onError 中处理异常，而且高阶函数的 action 参数可以传递不同的异常处理逻辑。

4.1 重试机制扩展

import com.safframework.utils.RetryWithDelay
import io.reactivex.Maybe

/**
 * 尝试重试
 * 默认有 3 次重试机会，每次的延迟时间是 1000ms
 */
fun <T> Maybe<T>.retryWithDelayMillis(maxRetries: Int = 3, retryDelayMillis: Int = 1000): Maybe<T> =
    this.retryWhen(RetryWithDelay(maxRetries, retryDelayMillis))

4.2 错误返回值扩展

/**
 * 遇到错误时，能够提前捕获异常，并发射一个默认的值。
 * 后面无须再做异常处理
 */
fun <T> Maybe<T>.errorReturn(defValue: T): Maybe<T> = this.onErrorReturn {
    it.printStackTrace()
    defValue
}

/**
 * 遇到错误时，能够提前捕获异常，并执行自定义操作后返回默认值。
 */
fun <T> Maybe<T>.errorReturn(defValue: T, action: (Throwable) -> Unit): Maybe<T> = this.onErrorReturn {
    action.invoke(it)
    defValue
}

4.3 错误恢复流扩展

/**
 * 遇到错误时，能够提前捕获异常，并返回一个新的 Maybe
 * 后面无须再做异常处理
 */
fun <T> Maybe<T>.errorResumeNext(defValue: T): Maybe<T> = this.onErrorResumeNext(Maybe.just(defValue))

/**
 * 遇到错误时，返回空值
 */
fun <T> Maybe<T>.errorResumeNext(): Maybe<T> = this.onErrorResumeNext(Maybe.empty())

五、实际应用场景

使用上述扩展函数后，代码结构将变得非常清晰。我们可以在数据流的上游就处理好异常，下游只需关注业务逻辑。

viewModel.getHelps(this)
    .retryWithDelayMillis()
    .errorReturn(HttpResponse()) { throwable ->
        // 在这里统一记录日志或弹出 Toast
        Log.e("NetworkError", throwable.message)
    }
    .subscribe {
        if (it.isOkStatus) {
            multi_status_view.showContent()
            adapter.addData(it.data?.list)
        } else {
            multi_status_view.showError()
        }
    }

在这个例子中，errorReturn 是一个高阶函数。它的 action 参数传递的是一个函数，专门用于处理异常。每一个网络请求的异常处理并不会都一样，可以用该函数来传递不同的异常处理策略，实现了高度的灵活性。

六、最佳实践建议

1. 统一错误码映射：建议在 HttpResponse 中增加一个方法，将业务错误码转换为友好的用户提示文本。
2. 线程调度：确保网络请求在主线程处理结果，异常处理逻辑也应在主线程或合适的调度器上执行，避免 UI 更新崩溃。
3. 日志记录：在生产环境中，建议将 throwable 上报到监控服务，以便追踪线上问题。
4. 类型安全：尽量使用泛型约束，确保 data 类型的正确性，避免运行时类型转换错误。

七、总结

合理利用 Kotlin 的扩展函数，可以编写优雅的代码。而使用高阶函数，则可以达到的进一步的抽象。通过将 RxJava 的错误处理逻辑封装为通用扩展，开发者可以将注意力更多地集中在业务逻辑的实现上，而不是分散在繁琐的异常捕获代码中。这种方式不仅简化了 Observer 代码，还提高了代码的可读性和可维护性，是现代 Android 架构设计中值得推荐的做法。