获取现有或创建新的akka演员

Question

我正在尝试使用ActorFor获取现有的ActorRef，或者如果它不存在，则创建一个新的ActorRef。我有以下代码，但它似乎没有按预期工作。isTerminated（）总是正确的。

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

            ActorRef subscriberCandidate = system.actorFor("akka://System/user/"+name);

            if (subscriberCandidate.isTerminated())
            {
                ActorRef subscriber = system.actorOf(new Props(new UntypedActorFactory() {
                      public UntypedActor create() {
                        return new Sub(name,link);
                      }
                    }), name);
                System.out.println(subscriber.path().toString() + " created");
            }
            else
                System.out.println("already exists"); 

我错过了什么？提前谢谢。

Answer 1

基于给定的代码，您将调用actorFor来查找不存在的参与者。在调用actorOf之前，演员不存在。

Answer 2

将查找更改为：

system.actorFor("/user/" + name)

如果这是你正在查找的本地演员，你不需要“akka：//System”部分。这是假设这个演员已经在代码的其他地方启动了。如果没有，那就没用了。

Answer 3

Get或create只能由指定参与者的父级执行，因为只有该父级可以在参与者不存在的情况下创建该参与者，并且只有父级可以始终如一地创建该参与者（即没有竞争条件）。在一个演员身上你可以做到

// assuming a String name like "fred" or "barney", i.e. without "/"
final Option<ActorRef> child = child(name);
if (child.isDefined())
  return child.get();
else
  return getContext().actorOf(..., name);

不要在顶层执行此操作（即使用system.actorOf），因为这样您就无法确定谁在请求创建时“获胜”，同时依赖用户监护人也不是一个好的监督策略。