Akka集群分片：基于通信模式的移动actor分片

Question

我正在使用Akka（特别是远程和集群包）构建一个开源的分布式经济模拟平台。这类仿真中的一个关键瓶颈是参与者之间的通信模式在仿真过程中不断演变，并且参与者最终通常会通过集群中节点之间的线路发送消息负载。

我正在寻找一种机制来检测某些节点上的参与者，这些参与者正在与其他节点上的参与者进行大量通信，并将它们移动到其他节点。是否可以使用现有的Akka集群分片功能？也许这就是罗兰·库恩所说的“自动演员树划分”是他对这个SO问题的回答。

Answer 1

通过实现自定义的ShardalLocationStrategy可以根据自己的逻辑移动碎片。

您只需扩展ShardAllocationStrategy并实现以下两种方法：

def allocateShard(requester: ActorRef, shardId: ShardId, 
  currentShardAllocations: Map[ActorRef, immutable.IndexedSeq[ShardId]])
  : Future[ActorRef]

def rebalance(currentShardAllocations: Map[ActorRef,
  immutable.IndexedSeq[ShardId]], rebalanceInProgress: Set[ShardId])
  : Future[Set[ShardId]]

第一个确定分配新碎片时将选择哪个区域，并为您提供已经分配的碎片。第二个是定期调用的，允许您控制将哪些碎片重新平衡到另一个区域（例如，如果它们变得太不平衡）。

这两个函数都返回一个Future,这意味着您甚至可以查询另一个actor以获得您需要的信息（例如,一个具有您的actor之间的亲和力信息的actor）。

对于亲和力本身，我觉得你得自己去实现一些东西。例如，参与者可以收集关于其发送方节点的统计信息，并定期将这些信息发布到集群单例中，该集群单例将确定哪些参与者应该移动到同一节点。