Scala Akka Classic Actor系统OneForOne监管策略不生效问题咨询

问题根因 #

你自定义的监管策略未执行、仅输出Akka默认日志，核心是以下2个高频问题：

1. 监管策略的偏函数执行上下文内直接调用sender会抛出异常，导致你写的日志代码根本没有执行成功，Akka捕获到策略本身的故障后，会降级使用内置默认策略输出日志。
2. 模拟故障的逻辑触发了循环报错：如果异常是在子Actor初始化方法（构造函数、preStart）抛出，或者失败的消息被重复消费，会导致子Actor持续重启，超出重试次数后策略被熔断，走默认日志输出。

解决方案 #

1. 修复监管策略代码 #

不要在策略的异常匹配逻辑中调用sender获取发件人，Classic Actor的SupervisorStrategy决策上下文内没有对应子Actor的sender上下文，直接调用会触发未定义行为。修正后的代码如下：

override val supervisorStrategy =
    OneForOneStrategy(maxNrOfRetries = 5, withinTimeRange = 1.minute) {
      case e: ArithmeticException =>
        logger.error(s"Supervisor: 捕获算术异常 ${e.getMessage}, 执行重启")
        Restart
      case e: NullPointerException =>
        logger.error(s"Supervisor: 捕获空指针异常 ${e.getMessage}, 执行重启")
        Restart
      case e: IllegalArgumentException =>
        logger.error(s"Supervisor: 捕获非法参数异常 ${e.getMessage}, 执行重启")
        Restart
      case e: Exception =>
        logger.error(s"Supervisor: 捕获未知异常 ${e.getMessage}, 执行重启")
        Restart 
    }

如果需要获取出错子Actor的标识，可以在子Actor的preRestart钩子中上报自身信息给监管者，或者开启Akka生命周期Debug日志查看对应Actor路径。

2. 验证子Actor从属关系 #

确保故障子Actor是当前监管者通过context.actorOf创建的直属子节点，通过system.actorOf创建的顶级Actor、其他Actor创建的子节点，都不会触发当前监管者的自定义策略。

3. 修复模拟故障的循环问题 #

你当前通过给子Actor发送异常对象触发报错的逻辑，会因为默认配置下失败消息不会被丢弃、重启后重复消费导致循环报错，可在子Actor类中添加preRestart钩子清空邮箱，避免重复消费同一条失败消息：

override def preRestart(reason: Throwable, message: Option[Any]): Unit = {
  context.self ! PoisonPill // 清空所有未处理消息
  super.preRestart(reason, message)
}

如果异常是在子Actor初始化逻辑中抛出，需要把模拟异常的逻辑迁移到普通消息处理逻辑中，避免每次重启都自动触发异常。

4. 验证配置 #

在application.conf中添加以下配置，打开生命周期日志确认监管流程被正确触发：

akka.loglevel = DEBUG
akka.actor.debug.lifecycle = on

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