我是Akka的新手,我建立了一个Akka模型,该模型连接到HDFS,提取数据,对其进行处理,然后将处理后的数据写回到HDFS。现在,如果我的主 Actor 崩溃了,那么相应的子 Actor ( worker )将会崩溃,并且整个系统必须重新启动。

因此,如果有一个创建辅助主服务器的过程,则一旦主服务器出现故障,它就会以最小的恢复时间自动生效。我无法对此做出清晰的描绘。

任何帮助将不胜感激。

谢谢

最佳答案

docs:



您的主人是应用程序中的顶级角色,因此他是用户监护人的 child ,因此将自动重新启动,因为对监护人的监督默认为:

  final val defaultDecider: Decider = {
    case _: ActorInitializationException ⇒ Stop
    case _: ActorKilledException         ⇒ Stop
    case _: DeathPactException           ⇒ Stop
    case _: Exception                    ⇒ Restart
  }

10-06 05:09
查看更多