如何使用 Akka Actor 永远 运行 一个守护进程？

Question

• 我的项目 没有 使用 Akka 截至目前，它 运行 作为一个进程并且做了太多事情.

• 作为第一步，我们正在尝试搭建一个脚手架，以便我们获得容错。例如，

ProjectSupervisor
     |
ExistingProcessActor

其中 ExistingProcessActor 将 运行 作为一个永远漫长的 运行ning 工作，如果它因为某些 Exception 而被杀死，ProjectSupervisor 将 restart它

我对此不太确定，所以我在 user-group 上询问，并收到了一个有趣的建议

[Me] def run: Unit = LogReaderDisruptor.main(Array())
is a method that is supposed to run forever, plus it required some setup (that is available on client's machine or test environment)

[Advice here] By that do you mean that the main() is never returning? If so, then you're blocking the Actor and wasting an entire thread. Spawn this off on a dedicated dispatcher instead (see dispatchers and futures docs).

我浏览了文档，但不明白我需要做什么。

是跟风的意思吗？

• ExistingProcessActor 将通过提供 PinnedDispatcher 类型的自定义调度程序来启动一个新的 future？
• 如果是这样，那么如果发生任何故障，将如何通知 ProjectSupervisor？他正在监视 ExistingProcessActor 而不是 future（future 不是 Actor）

一头雾水，请指教

Answer 1

您无需使用 Future 即可在专用调度程序中完成工作。这可以通过生成一个 actor 并将该 actor 分配给专用的调度程序来完成。来自 akka 文档的一个简单示例：

val myActor =
  context.actorOf(Props[MyActor].withDispatcher("my-dispatcher"), "myactor1")

http://doc.akka.io/docs/akka/snapshot/scala/dispatchers.html

您可以在创建 ExistingProcessActor 时在您的项目主管中执行此操作，将该 actor 放在固定的调度程序上，然后您的监督策略将继续按照您的意愿工作。