Scala中Akka Classic Actors的BackoffSupervisor延迟重启不生效

问题场景 #

使用Akka的BackoffSupervisor实现Actor延迟重启，已配置10秒最小退避时间，但TestActor抛出异常时，Actor立即重启，未遵循设定的退避时长。

相关代码 #

主程序代码 #

object Task2Implementation extends App {
  val system = ActorSystem("system")
  val actor = system.actorOf(BackoffSupervisor.props(BackoffOpts.onStop(
    Props[TestActor],
    "testActor",
    10.seconds,
    30.seconds,
    0.2
  ).withSupervisorStrategy(OneForOneStrategy(){
    case ex:Exception =>
      log.error("Going To Stop!")
      Stop
  })))

  actor ! BadStuff
}

TestActor 实现 #

class TestActor extends Actor {
  override def postStop(): Unit = log.info("Actor {} is stopped!", self.path)

  override def preRestart(reason: Throwable, message: Option[Any]): Unit = {
    log.info("In preRestart: reason -> {}, message -> {}", reason.getMessage, message.getOrElse(""))
  }

  def receive = {
    case BadStuff => throw new Exception("Bad Stuff!")

    case _ => log.info("Child Received Message!")
  }
}

问题原因 #

核心错误在于使用了BackoffOpts.onStop策略：该策略仅在**子Actor停止（正常停止或被Supervisor指令停止）**时触发退避重启逻辑，并不匹配“异常触发延迟重启”的需求场景。

即使代码中自定义SupervisorStrategy返回Stop，onStop的退避逻辑需要等待子Actor完全终止（触发Terminated事件）后才会启动定时器，但实际观察到的立即重启，是因为onStop策略本身不适用于异常故障场景。

解决方法 #

1. 切换为BackoffOpts.onFailure策略 #

onFailure是专门针对子Actor抛出异常的场景设计的退避重启策略，无需手动设置Stop指令，会自动处理故障后的延迟重启：

object Task2Implementation extends App {
  val system = ActorSystem("system")
  val actor = system.actorOf(BackoffSupervisor.props(BackoffOpts.onFailure(
    Props[TestActor],
    "testActor",
    10.seconds,
    30.seconds,
    0.2
  )))

  actor ! BadStuff
}

2. 保留自定义SupervisorStrategy（可选） #

如果需要添加错误日志等自定义逻辑，可在onFailure策略上附加SupervisorStrategy，注意需返回Restart而非Stop（onFailure基于故障重启事件触发退避）：

object Task2Implementation extends App {
  val system = ActorSystem("system")
  val actor = system.actorOf(BackoffSupervisor.props(BackoffOpts.onFailure(
    Props[TestActor],
    "testActor",
    10.seconds,
    30.seconds,
    0.2
  ).withSupervisorStrategy(OneForOneStrategy(){
    case ex:Exception =>
      log.error("Actor failed with exception: {}", ex.getMessage)
      Restart
  })))

  actor ! BadStuff
}

说明 #

• BackoffOpts.onFailure会监听子Actor的故障事件，当异常抛出时启动退避定时器，到达最小退避时间后重启子Actor。
• 退避时间会按指数退避算法增长（上限30秒），并加入抖动因子（0.2），避免批量重启带来的系统负载压力。

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