Wie Akka Schauspieler mit actorSelection auswählen?

Question

Ich versuche einen Akteur auszuwählen, der bereits erstellt wurde. Hier ist ein Code:

val myActor = system.actorOf(Props(classOf[MyActor]), "myActorName") 
println("myActor path - " + akka.serialization.Serialization.serializedActorPath(myActor)) 
println("Selection from spec akka://unit-test/user/myActorName " + system.actorSelection("akka://unit-test/user/myActorName").resolveOne().value) 
println("Selection from spec /user/myActorName/ " + system.actorSelection("/user/myActorName/").resolveOne().value) 

Das Ergebnis ist:

myActor path - akka.tcp://unit-test@127.0.0.1:46635/user/myActorName#1444872428 
Selection from spec akka://unit-test/user/myActorName None 
Selection from spec /user/myActorName/ None 

Auch ich eine Nachricht an Schauspieler passieren kann und es vervollständigt gut. Was habe ich bei actorSelection verpasst? Wie wählt man den Schauspieler richtig aus?

AKTUALISIERT

Es ist sehr seltsam, aber wenn ich system.actorSelection("/user/myActorName/").resolveOne().value mit system.actorFor("/user/myActorName/") alles funktioniert ersetzen. Ich meine actorFor gibt einen Schauspieler zurück. (Was ist keine richtige Lösung wegen actorFor ist veraltet)

Answer 1

Bitte seien Sie vorsichtig mit Futures. In Ihrem Fall sind Sie empfangen Zukunft, die in dem anrufenden Moment wird nicht abgeschlossen ist, kann - so kann sein Wert leer sein:

scala> println("Selection from spec /user/myActorName/ " + system.actorSelection("/user/myActorName/").resolveOne().value) 
Selection from spec /user/myActorName/ None 

vs

scala> val fut = system.actorSelection("/user/myActorName/").resolveOne() 
fut: scala.concurrent.Future[akka.actor.ActorRef] = scala.concurrent.impl.Promise$DefaultPromise@7eb8d7bd 

<just wait some time here> 

scala> fut.value 
res21: Option[scala.util.Try[akka.actor.ActorRef]] = Some(Success(Actor[akka://default/user/myActorName#1625966960])) 

Wert zu erhalten, richtig verwenden onComplete oder einfach nur for- comprehesion:

import scala.concurrent.ExecutionContext.Implicits.global 

for (res <- system.actorSelection("/user/myActorName").resolveOne()) { 
    println(res) 
} 

beachten sie, dass onComplete/für so Zuhörer umgesetzt werden, so dass sie vielleicht in anderen Thread ausgeführt werden. Wenn Sie das Ergebnis im aktuellen Thread benötigen - verwenden Sie den klassischen Await.result.