2

有没有人知道创建一个在延迟后执行 Actor 重启的 SupervisorStrategy 的方法？为了提供一些上下文，我有一个在启动时查询数据库的演员。如果 DB 连接断开，Actor 将旋转直到达到最大重试次数。延迟重启会很好。

蛮力但不可接受的解决方案是执行以下操作：

override val supervisorStrategy = OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange = 1 minute)    
  {
    case initEx: ActorInitializationException => {
      Thread.sleep(1000)
      Restart
    }
    case t =>
      super.supervisorStrategy.decider.applyOrElse(t, (_: Any) => Escalate)
  }

但是，这对我来说似乎站不住脚，因为我想避免任何阻塞代码。

这难道不是一个应该得到演员支持的概念吗？是否应该将延迟或重试移至 Actor 实现本身？这似乎与“让它崩溃”的想法背道而驰。

4

1 回答 1

2

重启延迟尚未实现。Thread.sleep 在性能方面是不可能的。

我看到两个选择：

  • 让您的主要参与者在消息上创建查询参与者。当它由于数据库中断而崩溃时，您可以停止执行者并重新安排消息以重新创建它。如果数据库操作必须在其他任何事情之前发生，则可能是一个问题。
  • 在查询参与者内部移动容错逻辑。将您的数据库逻辑放在部分函数中，并使用断路器来处理重试。然后，您可以使用监督在需要的异常上重新启动参与者，并通过 preRestart 挂钩重新安排指示执行数据库操作的消息。如果您不想重新启动，只需在您的断路器周围加上一个 try-catch 以在此处重新安排消息。
于 2014-12-01T10:05:18.593 回答