Akka-重新发送“中断”消息

Question

在官方的akka 2.0.4文档中，它说：

actor重新启动只替换实际的actor对象；邮箱的内容不受重新启动的影响，因此在postRestart钩子返回后，将继续处理邮件。不会再收到触发异常的消息。在重新启动时发送给参与者的任何消息都将像往常一样排队到其邮箱。

class ResendingActor extends Actor {
  var curMessage: Option[MyMessage] = None
  def receive = {
    case MyMessage(x) => {
      curMessage = Some(MyMessage(x))
      /* processing */
      curMessage = None
    }
  }
  override def preRestart(reason: Throwable, message: Option[Any]) {
    curMessage match {
      case Some(x) => self ! x
      case None => ;
    }
  }
}

我唯一能想到的是，如果消息由于某种原因出现畸形，它将永远不会离开系统，并导致演员定期重新启动...

Answer 1

您已经在preRestart中获得了失败消息（请参见:message:option[Any])，因此不需要自己隐藏它。是的，重新发送给自己是完全可以的，但要小心与此相结合的无限重启，因为你很可能最终得到一条永远不会被丢弃的信息。