如何在cats.effect.Resource中实现细粒度的异常错误处理？

1. 推荐方案：资源单独绑定错误处理 + for推导式组合 #

针对你原写法嵌套层级深、扩展性差的问题，最优的改造方式是将每个资源的初始化错误处理逻辑和资源本身绑定，再通过for推导式扁平化组合，逻辑和你原有的嵌套写法完全等价，且新增资源时只需要加一行绑定逻辑即可：

// 为每个资源单独绑定初始化阶段的错误处理
val r1WithErrorHandle: Resource[F, Service1[F]] = resource1.onError(e => 
  Resource.eval(logger.error(e)("error during service 1 setup"))
)
val r2WithErrorHandle: Resource[F, Service2[F]] = resource2.onError(e => 
  Resource.eval(logger.error(e)("error during service 2 setup"))
)
val r3WithErrorHandle: Resource[F, Service3[F]] = resource3.onError(e => 
  Resource.eval(logger.error(e)("error during service 3 setup"))
)

// 扁平化组合资源，无嵌套
val fullProgram: Resource[F, ExitCode] = for {
  r1 <- r1WithErrorHandle
  r2 <- r2WithErrorHandle
  r3 <- r3WithErrorHandle
  runRes <- Resource.eval(runProgram(r1, r2, r3))
} yield runRes

// 统一执行，初始化阶段的错误已被各资源的onError捕获打印，外层统一返回错误码即可
fullProgram.use(_.pure[F]).handleErrorWith(_ => ExitCode.Error.pure[F])

onError 方法仅会在资源初始化失败时触发指定逻辑，不会吞掉异常，也不会干扰资源的正常释放流程，完全符合你的需求。

2. 异常捕获失效的根因说明 #

你之前调用attempt、handleErrorWith失效的问题，你排查的结论是准确的：Resource的错误处理机制仅能捕获被F类型效果托管的异常，如果你在资源初始化过程中启动了不受F管控的独立线程池、执行了大量不纯异步操作，这些操作抛出的异常不会进入Resource的错误处理链路。嵌套写法能正常运行确实属于时序巧合，要彻底解决稳定性问题，需要将所有异步操作通过Async[F]的API封装，纳入效果的生命周期管理，才能保证错误捕获的可靠性。

3. 替代方案：基于attempt的显式错误处理 #

如果你需要在资源初始化失败时直接返回退出码、不继续后续流程，也可以通过attempt将资源的结果转为Either类型，在use阶段做显式分支处理：

val program: F[ExitCode] = (for {
  r1 <- resource1.attempt
  r2 <- resource2.attempt
  r3 <- resource3.attempt
} yield (r1, r2, r3)).use {
  case (Left(e), _, _) => logger.error(e)("error during service 1 setup").as(ExitCode.Error)
  case (_, Left(e), _) => logger.error(e)("error during service 2 setup").as(ExitCode.Error)
  case (_, _, Left(e)) => logger.error(e)("error during service 3 setup").as(ExitCode.Error)
  case (Right(r1), Right(r2), Right(r3)) => runProgram(r1, r2, r3)
}

这种写法也可以完全消除嵌套，扩展性同样良好。

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