Scalaz IO的catchAll/catchSome算子异常捕获问题咨询

哈哈，我当初学Scalaz IO的时候也被这个问题坑过！你遇到的核心问题是Scalaz IO的错误处理逻辑和RxJava完全不一样——不是catchAll/catchSome算子失效了，而是你没搞清楚它的显式错误通道到底管什么。

先搞懂Scalaz IO的错误模型 #

Scalaz的IO[E, A]是一个显式区分成功值和错误值的类型：

• A是成功通道的结果类型
• E是错误通道的类型（你这里用的是Throwable）

但这里有个关键区别：只有被显式注入到错误通道的错误，才会被catchAll/catchSome捕获。比如用IO.fail(new NullPointerException())生成的错误，或者用Scalaz提供的「安全构造方法」捕获的运行时异常，才会进入这个通道。

而你写的代码里：

IO.point[Throwable, String](null)
  .map(value => value.toUpperCase())

IO.point是用来包装纯值的（即不会抛出异常的确定性值），map里的函数是对这个纯值做转换。当IO被执行时，value.toUpperCase()抛出的NullPointerException是一个非受控的运行时异常——它直接逃逸出了IO的控制范围，根本没进入IO[Throwable, String]的错误通道，所以catchAll自然抓不到它。

反观RxJava，它的操作符会自动把函数执行时的异常捕获并转到onError通道，这是两者设计哲学的差异：Scalaz IO更偏向于「显式控制所有副作用」，不会自动帮你捕获异常，需要你手动处理。

修正你的代码：把异常装进错误通道 #

要让catchAll能捕获到NPE，你需要把可能抛出异常的逻辑用Scalaz的安全构造方法包裹，让异常进入显式错误通道。下面是两种正确的写法：

写法1：用IO.fromTryCatchNonFatal包裹危险逻辑 #

这是最直接的方式，它会自动把非致命异常（比如NPE）捕获并注入到错误通道：

@Test def catchAllOperator(): Unit = {
  val errorSentence: IO[Throwable, String] = IO.fromTryCatchNonFatal {
    // 把可能抛出异常的逻辑放在这里
    val value: String = null
    value.toUpperCase()
  }.catchAll(error => IO.point(s"Caught error: ${error.getClass.getSimpleName}"))

  // 执行IO并验证结果
  val result = errorSentence.unsafePerformIO()
  assert(result == "Caught error: NullPointerException")
}

写法2：用attempt把异常转为Either后处理 #

如果你已经有一个可能抛出异常的IO链，可以用attempt把整个IO的执行结果转为Either[E, A]，再手动处理错误：

@Test def catchAllOperator(): Unit = {
  val errorSentence: IO[Throwable, String] = IO.point[Throwable, String](null)
    .map(value => value.toUpperCase())
    .attempt // 把IO转为IO[Throwable, Either[Throwable, String]]
    .flatMap {
      case Right(result) => IO.point(result)
      case Left(error) => IO.point(s"Caught error: ${error.getMessage}")
    }

  val result = errorSentence.unsafePerformIO()
  assert(result.contains("NullPointerException"))
}

再说说catchSome的用法 #

catchSome和catchAll的区别是，它只捕获特定类型的异常，其他异常会继续在错误通道中传递。比如你只想处理NPE：

val errorSentence: IO[Throwable, String] = IO.fromTryCatchNonFatal {
  null.toUpperCase()
}.catchSome {
  case npe: NullPointerException => IO.point("Caught specific NPE!")
  // 其他类型的异常会继续向上抛出，不会被处理
}

总结一下 #

• Scalaz IO的catchAll/catchSome只处理显式错误通道中的错误，不会自动捕获纯函数里的运行时异常
• 要让异常能被捕获，必须用IO.fromTryCatchNonFatal、attempt等方法把异常注入到错误通道
• 和RxJava的差异：RxJava自动捕获操作符异常，Scalaz IO要求你显式控制所有副作用，更偏向于函数式编程的「显式性」原则

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