首先，我对 Akka 和演员模型还很陌生，所以也许我做错了一切。
我有一个输入actor，它从流源获取数据并将它们传递给具有一些内部状态的子处理器actor。如果连接断开，输入actor可能会崩溃，这会触发其重新启动。问题在于，这会触发其子代的重新启动，这会使它们失去状态。我不希望这样，因为输入流可能会恢复并且它们的状态将再次变得相关。此外，处理器是根据输入中的某些数据生成的，因此我看不到在输入参与者之外创建它们的方法。
换句话说，问题是“我如何只重新启动actor管道的输入而不重新启动进一步的阶段”？
【问题讨论】：
基本上有 3 种类型的 Actor 重启原因 (1) 系统错误，例如发生异常时 (2) 暂时性错误，这完全是您正在处理的问题（连接丢失）和 (3) 内部损坏状态。因为你有一个父子关系，它的孩子会重新启动。在这一点上，我不确定您是否可以通过 SupervisionStrategy 处理它。因此，请看这里http://doc.akka.io/docs/akka/snapshot/general/supervision.html#What_Restarting_Means - 这也是我“引用”的来源
处理此问题的另一种方法可能是对您的连接进行容错处理。在这里你必须接近： (1) 将连接处理和错误处理放入一个单独的子角色中。底层监督策略将是 OneForOne（默认），这意味着如果孩子死了，只有孩子会重新启动。
(2) 你有两个根 Actor，它们将成为 Actor 系统的 Actor。一个 connectionActor 和您的 inputActor。您将把 connectionActor 的实例传递给 inputActor，或者反过来从 connectionActor 请求数据，或者将数据发送给 inputActor。
如果您是 akka-actors 的新手，这有点难。但我建议阅读文档的介绍（根据您使用的版本）： http://doc.akka.io/docs/akka/snapshot/scala.html
【讨论】：
这种情况的完美解决方案是使用 Akka Persistence。 将 akka-persistence 与您正在使用的数据库一起使用并保存参与者的内部状态
您可以在这里找到更多信息：http://doc.akka.io/docs/akka/current/scala/persistence.html
希望我解决了你的问题！谢谢:)
【讨论】：