0

我和 Akka 的新手想要实现这一目标,

  1. 希望在 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 是否支持这一点,否则我将编写代码来找出利用率并相应地向该机器发送消息。

请建议是否可以将任何更好的方法用于我上面提到的内容。

谢谢!

-德文德拉

4

1 回答 1

0

您看过自适应负载平衡路由器吗?

它通过配置根据集群指标数据对集群节点执行消息负载平衡。

希望能帮助到你。

于 2014-09-26T10:30:58.133 回答