寻找阿卡所有儿童演员的状态

Question

在主管内部-

以下是我主管课程的一部分：

    Router router;
{
    counter = 0;
    List<Routee> routees = new ArrayList<Routee>();
    for (int i = 0; i < 10; i++) {
        ActorRef r = getContext().actorOf(Props.create(Children.class));
        getContext().watch(r);
        routees.add(new ActorRefRoutee(r));
    }
    router = new Router(new RoundRobinRoutingLogic(), routees);
}

以下是导致子参与者停止的条件：

if (/*some condition*/) {
   getContext().parent().tell(new Response(startTime, messages, Status.SUCCESS), getContext().parent());
   getContext().stop(getSelf());
}

在akka工具包中，我可以使用哪个API打印我的Supervisor类中所有子角色的状态？

Answer 1

有几种方法。

首先，我看到您从主管处查看您的路由，这是因为您必须在路由终止时将其从路由器中删除。监视一个参与者意味着当一个孩子终止时，监视者（在您的情况下是主管）将收到一条终止（actorRef）消息。您可以使用它来维护自己的活动路由列表（在收到此类消息时，您应该已经在更新路由器）。而且，因为您应该已经在更新路由器，所以您可以始终使用路由器查询其路由对象。getRoutees（）

其次，ActorContext提供了getChildren（）方法，您可以使用该方法枚举当前活动的路由对象。您还可以使用getChild（name）按名称检查特定路由对象的状态，但当然，您必须在创建它们时为它们设置名称。。。

第三，您可以制定自己的协议，其中主管可以向所有路由对象广播自定义消息，并让他们用您的另一条消息进行回复。这种方法的缺点是，您必须引入某种超时机制，因为您永远不知道有多少路由正在接收您的消息，因此也不知道如何响应预期。

我在这里停下来是因为我认为除非你有更精确的要求，否则除了上面的第一个解决方案，我不会去做任何事情...为什么要重新发明轮子？