Làm thế nào để chọn diễn viên akka với diễn viênSelection?

Question

Tôi đang cố gắng chọn một diễn viên đã tạo. Dưới đây là một mã số:

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) 

Kết quả là:

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 

Ngoài ra tôi có thể vượt qua một thông điệp tới diễn viên và nó hoàn thành tốt. Điều gì tôi đã bỏ lỡ trong diễn viênSelection? Làm thế nào để chọn diễn viên đúng cách?

CẬP NHẬT

Nó là rất lạ, nhưng khi tôi thay system.actorSelection("/user/myActorName/").resolveOne().value với system.actorFor("/user/myActorName/") mọi thứ hoạt động. Ý tôi là actorFor trả về một diễn viên. (Đó không phải là giải pháp phù hợp do actorFor không còn được dùng nữa)

Answer 1

Hãy cẩn thận với tương lai. Trong trường hợp của bạn, bạn đang nhận được tương lai mà có thể không hoàn thành tại thời điểm gọi điện thoại - vì vậy giá trị của nó có thể rỗng:

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])) 

Để có được giá trị chính xác sử dụng onComplete hoặc chỉ cho- comprehesion:

import scala.concurrent.ExecutionContext.Implicits.global 

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

Hãy nhớ rằng onComplete/for được thực hiện làm người nghe, vì vậy chúng có thể được thực thi theo chuỗi khác nhau. Nếu bạn cần kết quả trong chuỗi hiện tại - hãy sử dụng cổ điển Await.result.