Akka儿童演员返回一个void类型并拒绝发送消息

Question

我正在学习Akka类型的Actor库，并尝试使用向特定Actor的所有子Actor发送消息。getContext（）。getChildren（）。但是它返回一个Void类型，而不是我最初创建的子参与者的类型-

我所做的解决方法是在创建时将子对象简单地存储在hashmap中。但这不是一个可伸缩的。

我该如何实现这一点？尤其是在分布式场景下？

        .onMessage(GetPosition.class, message -> {

            // whenever I send a GetPosition() message to myself,
            // I get that reminder and send an AskPosition to all workers

            while (results.keySet().size() < 10) {
                // while not finished, ask for positions from child actors

                // This is not working
                this.getContext().getChildren().forEach(child -> {
                    child.tell("this is a void class, so I cannot send any message to children");
                });

                // WORKAROUND:
                // get child  actors from hashmap (hashmap lambda has 2 things in it -> bi-consumer)
                racers.forEach((id, actor) -> actor.tell(new RacerBehavior.AskPosition(this.getContext().getSelf())));
            }

            return this;
        })

Answer 1

由于无法静态地知道任意参与者将生成的子级所接受的消息类型，getChildren（）只能返回ActorRef

如果您的所有孩子碰巧都是相同的类型（这将是能够在中遍历他们以发送消息的先决条件），类似这样的方式应该可以工作：

child.unsafeUpcast<Object>.narrow<RacerBehavior.AskPosition>

如果您不能绝对确定所有子对象都是相同的类型，那么可以使用父参与者状态下的类型显式跟踪它们（例如，每个类型有一个集合）。