Akka Actor询问和类型安全

Question

val f1 = actor1 ? msg
val f2 = actor2 ? msg

val f3 = for {
  a ← f1.mapTo[Int]
  b ← f2.mapTo[Int]
  c ← ask(actor3, (a + b)).mapTo[Int]
} yield c

Answer 1

尝试类型化演员。基本上，它们允许您使用强类型的特征/接口而不是通过交换消息与参与者进行交互。在幕后，Akka用一个动态代理实现了这些接口，并实现了异步魔法。

类型化执行元可以返回具有不同的强类型化返回值的have方法（来自上面提到的文档）：

def squareDontCare(i: Int): Unit //fire-forget

def square(i: Int): Future[Int] //non-blocking send-request-reply

def squareNowPlease(i: Int): Option[Int] //blocking send-request-reply

def squareNow(i: Int): Int //blocking send-request-reply

这些方法代表tell，而其余的方法则是ask的不同风格。