java - 如何统计akka系统中特定时间活跃的特定类型的actor？

Question

Akka 2 是否提供了一种方法来确定系统中特定时间活跃的特定类型的 Actor 数量？

我一直在寻找类似的东西

int actorCount = getContext().count(MyActor.class)

或者

Props props = Props.create(MyActor.class, "actorName")
...
int actorCount = getContext().count(props)

或者

getContext().actorSelection("/path/to/actor").count()

我刚刚开始使用 Java 中的 akka 框架，所以请耐心等待。

Answer 1

在我的一个 Akka 应用程序中(我的第一个应用程序，我不会将其视为如何编写此类系统的光辉示例)，我实现了由心跳驱动的低水位/高水位工作生成策略。低水位线和高水位线是根据活跃工作参与者的数量来定义的，每个参与者只做一件事情并由经理创建。该管理器跟踪已启动和尚未完成的工作人员，并可以响应工作生成器发出的当前 Activity 计数的请求。对这些询问的答复提供了有关正在进行的工作是否已低于低水位线以及是否应该生成新工作的信息。

这有点粗糙，在我现在正在开发的新系统中，工作生成和工作执行之间的连接以及检查点日志记录是以更连续、更少“面向批处理”的方式完成的。该系统即将部署，因此目前我无法确定它将如何执行，但我很确定它将表现出比早期系统更好的行为。它本质上也比早期的系统更复杂，因为它如何生成、执行和记录它所做的工作。