scala - Akka : the proper use of `ask` pattern?

Question

我正在努力理解 Futures并在 akka 中询问模式。

所以，我做了两个 Actor ，一个要求另一个给他发回信息。好吧，根据 akka 的 Futures文档， Actor 应该向( ? )询问消息，它会给他一个 Future瞬间。然后actor应该阻塞(使用 Await )来获取 Future结果。

好吧，我永远不会完成我的 future 。为什么？

代码是:

package head_thrash

import akka.actor._
import akka.util.Timeout
import scala.concurrent.Await
import scala.concurrent.duration._

object Main extends App {

  val system = ActorSystem("actors")

  val actor1 = system.actorOf(Props[MyActor], "node_1")
  val actor2 = system.actorOf(Props[MyActor], "node_2")

  actor2 ! "ping_other"

  system.awaitTermination()

  Console.println("Bye!")
}

class MyActor extends Actor with ActorLogging {
  import akka.pattern.ask

  implicit val timeout = Timeout(100.days)

  def receive = {
    case "ping_other" => {
      val selection = context.actorSelection("../node_1")
      log.info("Sending ping to node_1")
      val result = Await.result(selection ? "ping", Duration.Inf) // <-- Blocks here forever!
      log.info("Got result " + result)
    }
    case "ping" => {
      log.info("Sending back pong!")
      sender ! "pong"
    }
  }
}

如果我改变 Duration.Inf至 5.seconds ，然后 actor 等待 5 秒，告诉我的 future 已超时(通过抛出 TimeoutException )，然后其他 actor 最终回复所需的消息。所以，没有异步发生。为什么？ :-(

我应该如何正确实现该模式？谢谢。

Answer 1

Akka 官方documentation说 Await.result 将导致当前线程阻塞并等待 Actor 用它的回复“完成” future 。

奇怪的是，您的代码永远阻塞在那里，您的所有应用程序是否只有一个线程？

无论如何，我想一种更“惯用”的编码方式是对 future 的成功使用回调。

def receive = {
    case "ping_other" => {
      val selection = context.actorSelection("../node_1")
      log.info("Sending ping to node_1")
      val future: Future[String] = ask(selection, "ping").mapTo[String]
      future.onSuccess { 
         case result : String ⇒ log.info("Got result " + result)
      }
    }
...