群集中碎片迁移过程中的Akka参与者内部状态

Question

我们正在使用Akka sharding将我们的运行参与者分布在多个节点上。这些行为体是持久的，我们将它们的内部状态保留在数据库中。

现在我们需要将ActorRef添加到“Metrics Actor”中，在每个节点上运行。shard中的每个actor都应该将遥测数据发送给metrics actor-它必须选择正确的metrics actor,该actor在本地运行于同一节点上。原因是，度量执行元收集数据对等节点。

    ClusterSharding(system).start(
        typeName = shardName,
        entityProps = MyShardActor.props(mvMetrics),
        settings = ClusterShardingSettings(system),
        extractEntityId = idExtractor,
        extractShardId = shardResolver)

我的问题是，如果这样创建的参与者在节点之间迁移，例如从节点A->B，会发生什么？我可以想象，节点B上迁移的props对象与节点A上的对象保持相同，因此ActorRef保持相同，因此新创建的actor将向原始节点A发送度量数据？

谢谢

Answer 1

如何利用ActorRef.Path？假设每个节点都有以某种方式命名的actor，然后一个actor将使用路径动态地找到相关的metrics actor。