Akka Actor 询问和类型安全

Question

如何使用 Akka Actor 询问和维护类型安全？还是避免使用 ask 来支持 tell？

在 Akka Actor 上调用 ? 或 ask 时，会返回 Future[Any]，我必须通过 future.mapTo[MyType] 进行显式转换。

我不喜欢失去这种类型的安全性。如果我直接使用 Futures（没有演员），我可以显式返回 Future[MyType] 并保持类型安全。

我的具体用例涉及一个演员将它的消息委托给两个子演员，然后汇总这些演员的结果并将其返回给父母的发件人。我父母的接收方法看起来类似于 Akka Docs 中的这种方法：

http://doc.akka.io/docs/akka/2.0/scala/futures.html#For_Comprehensions

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

我想发布一个新答案，因为@Roland Kuhn 最近为此提出了一个名为 Typed Channels 的新解决方案：

val f: Future[MyType] = actor <-?- message

• Roland's Presentation
• In the Akka docs

Answer 2

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

类型化的actor可以返回具有不同的强类型返回值的方法（来自上述文档）：

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的不同风格。