我和 Akka 的新手想要实现这一目标,
- 希望在 Amazon EC2 Spot 实例上在固定机器上部署少量有状态参与者(将始终开启)和无状态参与者(处理参与者/工作人员)
现在来处理决定使用 Akka 持久性的有状态参与者的故障转移。
并将工作分配给决定将 RoundRobinPool 与远程部署的路由一起使用的无国籍工人。并希望将消息传递给利用率最低的机器(CPU 和内存)。使用 Pool 以便我可以使用 withSupervisorStrategy() 来处理 Actor 故障。
我正在查看远程部署路由的示例并参考此代码http://www.typesafe.com/activator/template/akka-sample-cluster-java。和https://github.com/akka/akka/blob/cb05725c1ec8a09e9bfd57dd093911dd41c7b288/akka-samples/akka-sample-cluster-java/src/main/java/sample/cluster/stats/StatsSampleOneMasterMain.java。
在 StatsSampleClient 中,它随机获取节点并传递消息。我想通过上面提到的最少使用的机加工。我想知道 Akka 是否支持这一点,否则我将编写代码来找出利用率并相应地向该机器发送消息。
请建议是否可以将任何更好的方法用于我上面提到的内容。
谢谢!
-德文德拉