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

Question

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

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

“获取或创建”只能由指定的actor 的 父级
执行，因为只有该父级可以创建actor（如果不存在），并且只有父级才能一致地创建（即没有竞争条件）。在演员中，您可以做

// 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）执行此操作，因为那样一来您就不能确定谁在请求创建时“胜出”，并且依赖用户的监护人也不是一个好的监管策略。