如何在akka中强制参与者在超时后失败
我在使用java的akka中使用了主从架构。主机接收表示他路由到从机的作业命令的消息。这些作业涉及调用非开源的第三方库，有时仅仅通过挂起和阻塞执行而不抛出任何异常就会崩溃。Akka没有意识到这是一个失败，并继续向此参与者正在使用的邮箱发送消息，但由于第一个调用无限期地阻塞，邮箱中的其余命令将永远不会执行。
我的目标是用超时到期和异常来模拟这种类型的故障，以便将整个事件转发到akka中的failure Strategy build。所以我的问题是，我能以某种方式配置一个参与者，在收到消息后抛出异常，并且超时后它的执行没有完成吗？
如果不是，有什么其他的替代方案来处理这种情况而不执行任何阻塞操作？我正在考虑将执行封装在Future中，并从一个actor内部调用它，该actor将在超时时阻塞该将来。它是有效的，但正如许多人所建议的那样，阻塞在akka中不是一个好的解决方案。
回答 1
Stack Overflow用户
发布于 2014-01-09 16:32:53
没有必要在一个线程足够的情况下阻止两个线程:只需要一个参与者来协调对该(非常不可靠的) API的调用次数，并在未来启动它们(正如cmbaxter建议的那样，你不应该使用与该参与者运行时相同的ExecutionContext，我会使用一个专用的)。然后，应该使用firstCompletedOf将这些期货与超时未来进行组合：
import akka.pattern.after
import context.system.scheduler
import scala.concurrent.duration._
implicit val ec = myDedicatedDangerousActivityThreadPool
val myDangerousFuture = ???
val timeout = after(1.second, scheduler(throw new TimeoutException)
val combined = Future.firstCompletedOf(myDangerousFuture, timeout)然后，以某种适当的方式将其传回给您的参与者，例如将其结果值映射到消息类型或您需要的任何内容，并跟踪有多少未完成的消息。我建议将myDangerousFuture包装在Circuit Breaker中，以提高在失败情况下的响应能力。
https://stackoverflow.com/questions/20993450
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号