Akka Decider能否获取完整失败场景？如何抽离Decider逻辑？

嘿，作为Akka新手能留意到ActorException里藏着这么多关键信息，真的很赞！我来帮你一步步实现把Decider逻辑抽离到单独的MyDecider.scala，同时轻松拿到你需要的三类信息：子Actor抛出的原始异常、子Actor的ActorRef，以及触发异常的消息。

第一步：编写独立的MyDecider类 #

首先创建MyDecider.scala，我们要实现Akka的SupervisorStrategy.Decider trait，并且通过匹配ActorException来提取所有需要的上下文信息：

import akka.actor.{ActorException, ActorRef, SupervisorStrategy}

class MyDecider extends SupervisorStrategy.Decider {
  override def apply(throwable: Throwable): SupervisorStrategy.Directive = throwable match {
    case actorException: ActorException =>
      // 提取你需要的三类核心信息
      val originalThrowable = actorException.getCause
      val childActorRef = actorException.getActor
      val failedMessage = actorException.getFailedMessage

      // 这里写你的自定义处理逻辑，比如日志记录或者决策指令
      println(s"子Actor [${childActorRef.path}] 处理消息 [$failedMessage] 时抛出异常: ${originalThrowable.getMessage}")
      
      // 根据业务需求返回对应的指令：Restart/Stop/Resume/Escalate
      SupervisorStrategy.Restart

    case otherThrowable =>
      // 处理非ActorException的场景（比如子Actor初始化失败）
      println(s"未被包装的异常: ${otherThrowable.getMessage}")
      SupervisorStrategy.Escalate
  }
}

这里要注意：Akka会将子Actor处理消息时抛出的异常自动包装成ActorException，它内置了三个关键方法：

• getCause()：获取子Actor抛出的原始Throwable/Exception
• getActor()：获取抛出异常的子Actor的ActorRef
• getFailedMessage()：获取触发异常的原始消息

第二步：重构Supervisor类使用自定义Decider #

接下来修改你的Supervisor类，替换默认的Decider为我们的MyDecider实例：

import akka.actor.{Actor, ActorLogging, SupervisorStrategy}

class MySupervisor extends Actor with ActorLogging {
  // 初始化自定义Decider实例
  private val customDecider = new MyDecider()

  // 替换默认的SupervisorStrategy，使用我们的自定义Decider
  override val supervisorStrategy: SupervisorStrategy =
    SupervisorStrategy.defaultStrategy.withDecider(customDecider)

  // Supervisor的消息处理逻辑
  override def receive: Receive = {
    case "createChild" =>
      // 示例：创建子Actor
      val child = context.actorOf(MyChildActor.props(), "my-child")
      log.info(s"Created child actor: ${child.path}")
    // 其他消息处理...
  }
}

这样你的Supervisor就会完全使用MyDecider里的逻辑来处理子Actor的异常了，所有上下文信息都能在Decider里轻松获取。

小提示 #

如果你的Decider需要依赖其他组件（比如日志工具、配置），可以通过构造函数注入的方式传递给MyDecider，让它更灵活：

class MyDecider(log: ActorLogging) extends SupervisorStrategy.Decider {
  // 使用注入的日志工具
  override def apply(throwable: Throwable): SupervisorStrategy.Directive = {
    log.warning("子Actor发生异常", throwable)
    // ... 其他处理逻辑
    SupervisorStrategy.Restart
  }
}

然后在Supervisor里初始化时传入：

private val customDecider = new MyDecider(this)

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