3

在 Akka 2.2.0 中，我有一个循环路由的 Actor，我想让一个自定义调度程序坐在上面。

在我的application.conf我有；

durable-dispatcher {
  mailbox-type = akka.actor.mailbox.filebased.FileBasedMailboxType
}

akka.actor.deployment {
  /notificationServiceWorkers {
    dispatcher = durable-dispatcher
    router = round-robin
    nr-of-instances = 5
  }
}

现在，当我尝试像这样创建这个演员时；

ActorRef notificationServiceWorkers = akka.actorOf(Props.create(NotificationServiceActor.class)
   .withRouter(new FromConfig()), "notificationServiceWorkers")

调度程序不是从配置中提取的，它使用默认调度程序。

如果我删除.withRouter，Akka 会很好地为调度程序拾取配置，但显然它不再路由。

如果我.withDispatcher这样添加；

ActorRef notificationServiceWorkers = akka.actorOf(Props.create(NotificationServiceActor.class)
       .withDispatcher("durable-dispatcher")
       .withRouter(new FromConfig()), "notificationServiceWorkers")

这一切都有效。问题是（从文档中不清楚）如果我想从application.conf加载调度程序和路由器配置，那么为什么我需要在 Props 创建中同时提供这两者？这是一个错误吗？

4

3 回答 3

5

您的部署没有被选中的原因是路由是作为路由器的子级创建的，因此它们存在于路径notificationServiceWorkers/*中。

于 2013-08-31T12:04:47.960 回答
3

在深入查看 Akka 代码内部LocalActorRefProvider时，您可以在内部看到，actorOf如果调度程序是非路由参与者，它们只会从部署配置中获取调度程序。我想他们这样做是有原因的，但这对您来说意味着如果您要使用路由器并且想要不同的调度程序（默认调度程序除外），您将需要在实例withDispatcher上显式使用Props您将无法从配置中获取它。同样，我不知道这是否是一个错误，但从他们的代码的外观来看，当它是一个路由演员时，他们似乎故意不从配置中提取。

于 2013-08-26T16:21:57.507 回答
1

作为对 Roland Kuhn 的回答的补充，这是有效的：

"/notificationServiceWorkers/*" {
  dispatcher = durable-dispatcher
}
于 2013-12-09T16:21:10.433 回答