创建一个ActorSelection以获取在父actor中创建的ActorRef

Question

我有一个Akka系统,ParentOrderActor它接收Create和分别创建Read和读取子的消息OrderActor.

如果我在主 "/user/..."路径中创建所有Actors,一切顺利:

// Inside the ParentOrderActor ("/user/orders")

// Create in "/user"
getContext().system().actorOf(new Props(OrderActor.class), "ABC");

// Read via an ActorSelection
ActorSelection actorSelection = getContext().system().actorSelection("/user/ABC");

当一切顺利时,日志会显示:

ParentOrderActor -> created: Actor[akka://system/user/ABC#1132819541]
ParentOrderActor -> received: Message[name=Read, id=ABC]
ParentOrderActor -> actorSelection: ActorSelection[Actor[akka://system/]/user/ABC]
ParentOrderActor -> for id=Message[name=Read, id=ABC], we retrieved ActorRef: Actor[akka://system/user/ABC#1132819541]

但是在尝试创建并读取ParentOrderActor中的子actor时:

// Inside the ParentOrderActor ("/user/orders")

// Create in "/user/orders"
getContext().actorOf(new Props(OrderActor.class), "ABC");

// Read via an ActorSelection
ActorSelection actorSelection = getContext().actorSelection("ABC");

这是印刷品:

ParentOrderActor -> created: Actor[akka://system/user/orders/$a/ABC#-436492577]
ParentOrderActor -> received: Message[name=Read, id=ABC]
ParentOrderActor -> actorSelection: ActorSelection[Actor[akka://system/user/orders/$a#478613574]/ABC]
Oops: java.util.concurrent.TimeoutException: Futures timed out after [2 seconds]
ParentOrderActor -> for id=Message[name=Read, id=ABC], we retrieved ActorRef: null

我已经尝试了所有类型的路径actorSelection(...),但ActorRef总是如此null.

为了完整起见,这里有一个简短的SSCCE,演示了上述内容:

public class Main {

    private static boolean createChildrenInUser = false;
    private static LoggingAdapter log;

    static abstract class Message {

        final String id;

        Message(String id) {
            this.id = id;
        }

        @Override
        public String toString() {
            return "Message[name=" + getClass().getSimpleName() + ", id=" + id + "]";
        }
    }

    static class Create extends Message {
        Create(String id) {
            super(id);
        }
    }

    static class Read extends Message {
        Read(String id) {
            super(id);
        }
    }

    static class ParentOrderActor extends UntypedActor {

        @Override
        public void preStart() {
            log.debug("ParentOrderActor -> starting...");
        }

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

            log.debug("ParentOrderActor -> received: {}", message);

            if(message instanceof Create) {
                if(createChildrenInUser) {
                    // Create an Actor in the root context ("/user/id").
                    ActorRef created = getContext().system().actorOf(new Props(OrderActor.class), ((Create)message).id);
                    log.debug("ParentOrderActor -> created: {}", created);
                }
                else {
                    // Create an Actor in this ParentOrderActor's context ("/user/orders/id")
                    ActorRef created = getContext().actorOf(new Props(OrderActor.class), ((Create)message).id);
                    log.debug("ParentOrderActor -> created: {}", created);
                }
            }
            else if(message instanceof Read) {
                ActorRef ref = select((Message)message);
                log.debug("ParentOrderActor -> for id={}, we retrieved ActorRef: {}", message, ref);
                getContext().system().shutdown();
            }
            else {
                unhandled(message);
            }
        }

        private ActorRef select(Message message) {
            try {
                ActorSelection actorSelection;
                if(createChildrenInUser) {
                    // Select the Actor with a certain id in the root context ("/user/id").
                    actorSelection = getContext().system().actorSelection("/user/" + message.id);
                }
                else {
                    // Create an Actor in this ParentOrderActor's context ("/user/orders/id")
                    actorSelection = getContext().actorSelection(message.id);
                }
                log.debug("ParentOrderActor -> actorSelection: {}", actorSelection);
                Timeout timeout = new Timeout(2, TimeUnit.SECONDS);
                AskableActorSelection askableActorSelection = new AskableActorSelection(actorSelection);
                Future<Object> future = askableActorSelection.ask(new Identify(1), timeout);
                ActorIdentity actorIdentity = (ActorIdentity) Await.result(future, timeout.duration());
                return actorIdentity.getRef();
            }
            catch(Exception e) {
                log.debug("Oops: {}", e);
                return null;
            }
        }
    }

    static class OrderActor extends UntypedActor {

        @Override
        public void preStart() {
            log.debug("OrderActor -> starting...");
        }

        @Override
        public void onReceive(Object message) throws Exception {
            log.debug("OrderActor -> received: {}", message);
            unhandled(message);
        }
    }

    public static void main(String[] args) {

        ActorSystem system = ActorSystem.create("system");

        log = Logging.getLogger(system, Main.class);

        ActorRef orders = system.actorOf(new Props(ParentOrderActor.class).withRouter(new RoundRobinRouter(1)), "orders");

        orders.tell(new Create("ABC"), orders);

        orders.tell(new Read("ABC"), orders);
    }
}

运行上面的代码将导致Read返回的ActorRef是null.更改布尔标志createChildrenInUser,以true将内部创建的儿童演员"/user"和一切顺利.

问题是:如何在()中创建ActorSelection并获取ActorRef一个actor ？/user/ordersParentOrderActor

Answer 1

如果我正确理解您的问题,并且您想要从父actor中加载子actor的最佳方法,那么您可以使用:

getContext().child("ABC")

这将返回一个scala.Option<ActorRef>而不是一个ActorSelection,所以如果你想用通配符查找多个子节点并向它们发送所有消息,这种方法将不起作用.