RxJava onSuccess消费者抛异常时UndeliverableException如何处理

• RxJava 2.x 的内置设计规则：上游发射成功信号触发onSuccess后，整个流的错误通道就已关闭。此时如果onSuccess消费者的代码抛出异常，RxJava判定该异常没有合法的投递目标，会将其包装为UndeliverableException，直接交给全局错误处理器处理，不会再回调到已经接收过成功信号的Observer的onError方法。

• 在每个onSuccess回调中手动添加try-catch、分支判断做异常拦截，属于重复样板代码，是典型的代码坏味道，也不是官方推荐的实现方式。

1. 将易抛异常的业务逻辑迁移到流的中间操作符中执行
   所有可能触发异常的业务代码，从subscribe的onSuccess回调移到map/flatMap等中间操作符内部。操作符执行过程中抛出的异常会被RxJava自动捕获，沿着流通道直接投递到下游onError回调，实现异常的统一处理：

   fun main() {
       Single.just(listOf("efaewf"))
           .map {
               // 原onSuccess中可能抛异常的业务逻辑全部放在这里
               println("result is ${it[1]}")
           }
           .subscribe({
               println("业务流程执行成功")
           }, {
               println("handling exception")
               it.printStackTrace()
           })
   }
   

2. 配置全局错误处理器实现fail-fast兜底
   在应用初始化阶段注册全局RxJavaPlugins错误处理器，处理所有无法投递的异常，避免异常被静默上报为低优先级非致命问题、最终导致用户看到空白界面：

   RxJavaPlugins.setErrorHandler { throwable ->
       // 将异常上报到崩溃监控平台
       // 按照fail-fast策略，对未捕获的非预期异常直接触发崩溃
       throw throwable
   }
   

• subscribe的最终回调仅承载无异常风险的轻量操作（比如UI状态绑定、无分支的展示逻辑），不放置复杂业务判断、数据解析这类易抛错的逻辑。
• 所有易抛错的业务逻辑，尽量放到流的操作符链中执行，借助RxJava自带的异常捕获机制走统一onError通道，不需要开发者手动写重复拦截逻辑。
• 必须配置全局错误处理器，作为所有未被通道捕获的异常的最后防线，避免异常丢失。

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