Akka Java-动态创建递归子角色？

Question

我的理解是，在任何给定的时间点上，一个线程只能执行onRecture。

假设我有一个非类型的演员，定义如下：

import akka.actor.ActorRef;
import akka.actor.Props;
import akka.actor.UntypedActor;


public class ExampleActor extends UntypedActor {

     private ActorRef databaseActor;


    @Override
    public void preStart() {
       ActorRef databaseActor = getContext().system().actorOf(Props.create(DatabaseActor.class));
    }


    @Override
    public void onReceive(Object message) throws Exception {

        if (message.equals("start")) {
            // spawn a child actor of myself!
            ActorRef child = getContext().actorOf(Props.create(ExampleActor.class));
            databaseActor.tell("fetch", child);
        }

        if (message.equals("dbresponse")) {
           // just log the repsonse here!
        }

        if (message.equals("something else")) {
           // possibly mutate state
        }


   }
}

我基本上想使用Akka而不使用期货。同时，我希望我的演员们不要尽可能多地阻拦。在我的onReceive中生成递归子角色，单独处理来自其他角色的特定消息，可以吗？

本质上，在我的“if（message.equals（“dbresponse”）”中，我只想记录一个DB响应，而不是在ExampleActor中改变状态。

这种方法有效吗？这样即兴创作演员的后果是什么？

Answer 1

您做得完全正确，这就是Actor模型预测Actor交互处理的方式。使用ask模式所做的事情实际上是相同的（但会产生一种优化形式的单回复参与者），因此如果您不想使用Futures，这是一种选择退出的方式。