Akka：等待多条消息

Question

Hi akka古鲁们：）你能在这一次指导我吗？

我要做的是-演员A向演员B要消息，然后等一个回来。但是，不知何故，演员B给A的不是一条信息，而是其中的4条信息。Afuture正确完成，但rest消息中有3条被算作死信。为什么？这样对吗？我是说，演员A有一个合适的处理人，那为什么信都死了？：-（

[INFO][11/22/2013 22:00:38.975][ForkJoinPool-2-worker-7][akka://actors/user/a]获得结果pong[INFO][11/22/2013 22:00:38.976][actors-akka.actor.default-dispatcher-4][akka://actors/deadletters]消息[java.lang.String]未从参与者[akka://actors/user/b#-759739990]传递到参与者[akka://actors/deadletters]。[1]遇到的死信。可以使用配置设置'akka.log-dead-letters'和'akka.log-dead-letters-dider-shutdown'关闭或调整此日志记录。...同一条信息再重复2次...

请看一下代码。

package head_thrash

import akka.actor._
import akka.util.Timeout
import scala.concurrent.duration._
import akka.pattern.ask
import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global

object Main extends App {
  val system = ActorSystem("actors")

  val a = system.actorOf(Props[A], "a")
  val b = system.actorOf(Props[B], "b")

  a ! "ping"
  system.awaitTermination()
}

class A extends Actor with ActorLogging {

  implicit val timeout = Timeout(5.seconds)

  def receive = {
    case "ping" => {
      val b = context.actorSelection("../b")
      val future: Future[String] = ask(b, "ping").mapTo[String]
      future.onSuccess {
        case result: String ⇒ {
          log.info("Got result " + result) // <-- got result pong here, that's okay
        }
      }
    }
    case "pong" => {
      log.info("hmmm...")
    }
  }
}

class B extends Actor with ActorLogging {
  def receive = {
    case "ping" => {
      sender ! "pong"
      sender ! "pong" // <-- dead letter!
      sender ! "pong" // <-- dead letter!
      sender ! "pong" // <-- dead letter!
    }
  }
}

那真让我迷惑。现在你可以问--嘿伙计，为什么你需要B发很多信息？好吧，这是更复杂的情况的部分-A向B要消息。B答案。然后A等待来自B的另一个消息，这里的棘手部分是在未来完成后等待--我只是无法下定决心使模型适合于Akka基础。

但是现在，我怎样才能正确处理所有4条消息，而不是死信呢？谢谢：-d

Answer 1

如果不等待消息，您会发现代码更容易编写。当你不按照时间或步骤顺序来考虑你的应用程序时，演员的工作效果最好。让它能够处理回调。但是使用！不是？。如果需要，可以使用benge或an FSM来显示这两种状态。

这不是你问的问题，但这是你想知道的。避免执行器的命令式可以防止大多数此类错误的发生。

Answer 2

您的问题是执行元B没有回答执行元a。如果我们阅读ask模式的文档，我们会发现ask创建一个临时的一次性执行元以接收对消息的答复，并用它完成一个Scala.concurrent.Future。

这个临时actor根本不处理“pong”消息，他只是在等待任何答案，然后您将其转换为字符串的未来。

如果你想解决这个问题，你必须修改你的actor B，这样它首先回答临时的“Ask actor”，然后直接向actor A发送消息。

class B extends Actor with ActorLogging {
  def receive = {
    case "ping" => {
      sender ! "pong"  //the sender is the temp ask actor
      val a = context.actorSelection("../a") // get a ref on actor A
      a ! "pong"
      a ! "pong"
      a ! "pong"
    }
  }
}

这不是真的干净，但现在我希望你明白是怎么回事。