scala - Akka Actor /scala - 多个请求的单个 onSuccess

Question

我有一系列的 akka Actor ，比如

A --> B --> C

Actor A“询问” Actor B， Actor B 又“询问” Actor C。Actor A 需要等到 Actor C 完成处理。B 是一个薄层，除了将消息传递(询问)给 C 并将 Future 返回给 A 之外什么都不做。基本上 B 只是做

        { case msgFromA => sender ! C ? msgFromA }

因此 A 得到的是 Future[Any]。

A 处理请求的方式是使用嵌套映射

actorRefFactory.actorOf(Props[A]) ? msgA map {
        resp =>
          // Type cast Any to Future and use another map to complete processing. 
          resp.asInstanceOf[Future[_]] map {
            case Success =>
              // Complete processing
            case Failure(exc) =>
             // Log error

这是有效的(即最终处理仅在 Actor C 完成处理时发生)但不用说它看起来很糟糕。我尝试使用平面图但无法使其工作。任何让它看起来不错的想法:)谢谢

Answer 1

更恰当的做法:

在 A 中:

val f: Future[MyType] = (B ? msg).mapTo[MyType]
f onComplete {
  case Success(res) => // do something
  case Failure(t) => // do something
}

在B中，使用forward:

{ case msgFromA => C forward msgFromA }

在 C 中:

// call database
// update cache
sender() ! res   // actually sends to A