Akka 2.1异常处理(Scala)

Question

我有一个监督Akka演员，它使用路由器将消息转发给工人演员。

我有一个封装了管理程序的类，当我调用该类的方法时，它“要求”管理程序做一些事情，然后我使用< code > await . result(the future)等待结果(没有结果我无法继续)。

如果worker抛出异常，我想重新启动抛出异常的worker，我想让调用包装类的代码捕获异常。

我向路由器构造函数传递了一个< code>OneForOneStrategy，它在出现< code >异常的情况下返回< code>RESTART。在worker的< code>postRestart方法中，我记录了重启，这样我就可以验证worker是否真的重启了。

当工作线程抛出异常时，它会重新启动，但异常会消失。询问主管的结果< code>Future包含一个异常，但它是一个< code > akka . pattern . asktimeoutexception ，仅在5秒后抛出，而不是20秒，这是我一直徘徊的隐式超时。异常实际上在工作线程启动后不到一秒钟就发生了。

问题1：如何从调用我的包装类的html" target="_blank">代码中的工作器中获取异常？

此外，工作者的接收方法如下：

def receive = {
    case r: Request => 
        val response = ??? //throws an exception sometimes
        sender ! response
}

有些东西正在将异常记录到控制台，但这不是我的代码。堆栈跟踪为：

[ERROR] [02/11/2013 21:34:20.093] [MySystem-akka.actor.default-dispatcher-9]  
[akka://MySystem/user/MySupervisor/MyRouter/$a] Something went wrong!
    at myApp.Worker.$$anonfun$receive$1.applyOrElse(Source.scala:169)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
at akka.actor.ActorCell.invoke(ActorCell.scala:386)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
at akka.dispatch.Mailbox.run(Mailbox.scala:212)
at akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:502)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:262)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1478)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)

Source.scala的第169行是上面的接收方法列表中显示的val响应=？？行。

问题2：谁将该异常记录到控制台，以及如何阻止它？

Answer 1

为了被告知你的一个孩子失败了，你需要

• 首先看着孩子
• 然后当参与者死亡时，您将收到一个Terminated（），其中包含对它的引用。

像这样：

class ParentActor extends Actor {
   // this is sample of how to watch for death of one of your children 
   val childActor = context.actorOf(Props[SomeService], "SomeService")
   val dyingChild = context.watch(context.actorOf(childActor))

   def receive = {
     case Terminated(`dyingChild`) =>
        println("dyingChild died") 
     case Terminated(terminatedActor) => 
        println(s"This child just died $terminatedActor")
   }
 }

希望这有所帮助。

Answer 2

1)

try somethingThatCanFail() catch {
    case e: Exception => sender ! Status.Failure(e); throw e
}

“告诉失败”会导致调用方获得包含异常的失败。抛出“e”会导致调用oneForOneStrategy，从而重新启动工作进程。

2)

是actor系统本身记录了故障，唯一让故障平静下来的方法是通过创建和配置您自己的LoggingAdapter来过滤掉故障，如下所述http://doc.akka.io/docs/akka/2.1.0/scala/logging.html有一张换这个的票https://www.assembla.com/spaces/akka/tickets/2824但它的目标是Akka 2.2

回答https://groups.google.com/forum/#!主题/akka用户/fenCvYu3HYE