Akka：创建多个儿童演员与重用单个儿童演员

Question

我对阿克卡很陌生，我有一个（希望）简单的问题。我有一个参与者需要重复执行某个小的子任务——也就是说，每次这个参与者收到消息时，它都必须执行N个子任务。这个子任务是我指定给儿童演员的。我的问题是，我是否应该为每个子任务创建一个新的子角色实例？或者我应该简单地产生一个孩子演员，并发送N条消息？在这种情况下，最好的做法是什么？

为了更好地说明我的问题，这里有两个简化的示例（在Java中-但希望对Scala成员来说足够简单！）：

第一个actor类在构造时创建一个单子actor，然后向该单子actor发送许多消息。

public class ParentActor extends UntypedActor {

    private final ActorRef childActor;

    public ParentActor() {
        this.childActor = getContext().actorOf(Props.create(childActor.class));
    }

    @Override
    public void onReceive(Object msg) {
        for (int i=0; i<1000; i++) {
            this.childActor.tell("Some message", getSelf());
        }
    }
}

现在，将它与下面的参与者进行比较，后者为需要发送的每个消息生成一个新的子参与者。

public class ParentActor extends UntypedActor {

    @Override
    public void onReceive(Object msg) {
        for (int i=0; i<1000; i++) {
            final ActorRef childActor = getContext().actorOf(Props.create(childActor.class));
            childActor.tell("Some message", getSelf());
        }
    }
}

谢谢

Answer 1

将工作分配给演员可以在akka中使用路由器完成。

其思想是将子rsp工作者参与者的选择移动到消息流中。

参见参考文档中的顶部示例。主节点创建一组称为routees的子角色，并将它们添加到路由器：

router = new Router(new RoundRobinRoutingLogic(), routees);

路由器可以配置为使用一组不同的路由逻辑实现，这里是一个简单的循环逻辑。

当消息发送到其中一个子角色时，您只需将其发送到路由器，路由器将负责选择正确的子角色并将其发送到那里：

router.route(msg, getSender());

getSender可用于传递消息发送者，以防消息最初是在worker中接收到的，或者您只需传递“getSelf（）”的结果（或者可能什么都没有，不确定）即可直接发送消息。