Akka 演员无法发回消息答案

【问题标题】：Akka actor cannot send back the messageAkka 演员无法发回消息
【发布时间】：2015-03-28 11:23:28
【问题描述】：

比如说，我有一个 Actor，它的接收函数喜欢

def receive = {
  case Message =>
    val doFuture: Future[String] = doSomething()

    doFuture onSuccess {
      case doResult =>
        //////////// Here is the problem !! /////////////
        // --> here fail. Seems sender cannot send back the result to the caller
        sender ! doResult
    }

    doFuture onFailure {
      // handle exception
    }
}

为什么发件人不能再发回消息了？

【问题讨论】：

您正在关闭发件人（它是可变的）。到未来完成时，发件人不一定有效/不再相同。见stackoverflow.com/questions/16898131/sender-inside-a-future
通过添加import context.dispatcher确保未来在Actors执行上下文中执行
谢谢！抱歉重复的问题..

标签： scala akka actor

【解决方案1】：

def receive = {
  case Message =>
    val doFuture: Future[String] = doSomething()
    val requester = sender

    doFuture onSuccess {
      case doResult =>
        requester ! doResult
    }

    doFuture onFailure {
      // handle exception
    }
}

您可以保存您的原始发件人然后使用它（以防您出于某种原因不想使用管道）。不管怎样，管道看起来好多了，而且是专门为这种情况设计的：

import akka.pattern.pipe

 def receive = {
      case Message =>
          val doFuture: Future[String] = doSomething()  
          doFuture pipeTo sender
 }

【讨论】：

【解决方案2】：

这就是pipeTo 的用途：

import akka.pattern.pipe

...

doFuture.pipeTo(sender())

【讨论】：