发送多条信息时的Akka死信

Question

我对Akka很陌生，我在尝试与我的演员进行集成测试时遇到了一些问题。

def receive = LoggingReceive {
case msg: JsValue =>
  log.info(msg.toString())

  (msg \ "type").asOpt[String] match {
    case Some("authenticate") =>
      println("authenticate")
    case None                 =>
      log.info("fail")
      out ! Json.obj("error" -> "You should specify a type")
    case t                    =>
      log.info("fail")
      out ! Json.obj("error" -> "You should specify a valid type")
  }

case _ =>
  log.info("fail")
  out ! Json.obj("error" -> "unknown message format")
}

我是这样测试的：

val platoId = StringStub.random(6)
val platoConnection = TestProbe()
val platoSocket = system.actorOf(TalkerSocket.props(platoId)(platoConnection.ref))

def authMessage(talkerId: String) = {
    Json.parse(
      s"""
        {
          "type" : "authenticate",
          "data" : {
            "user_id" : "$talkerId",
            "auth_token" : "not_used_yet"
          }
        }
        """.stripMargin)
}

当我这样做的时候：

platoSocket ! authMessage(platoId)

一切看起来都还好。

platoSocket ! authMessage(platoId)
platoSocket ! authMessage(platoId)

[INFO] [11/25/2015 16:56:49.225] [TypingSpecLol-akka.actor.default-dispatcher-4] [akka://TypingSpecLol/user/$a] Message [play.api.libs.json.JsObject] from Actor[akka://TypingSpecLol/system/testActor1#-94087043] to Actor[akka://TypingSpecLol/user/$a#754865806] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.

platoSocket ! authMessage(platoId)
Thread.sleep(1000)
platoSocket ! authMessage(platoId)

Answer 1

这是一个疯狂的猜测，但我非常肯定您的消息正在杀死您的演员（一个异常被抛出）。如果您没有任何特殊的supervisorStrategy，那么默认情况下将重新创建参与者的新实例。那么，如果您没有等待就发送了两条消息，那么第二条消息将无法到达您的参与者，因为新实例正在创建中。但是，如果稍候，新实例将被创建并准备接收消息。

要测试是否是这种情况，可以将supervisorStrategy更改为在参与者死亡时进行日志记录，或者在receive定义中放置try-catch块。