我是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
}