Akkaアクタークラスター内のシャード移行中の内部状態

アクカーシャーディングを使用して、実行中のアクターをいくつかのノードに分散しています。これらのアクタは永続的で、データベースの内部状態を保持します。Akkaアクタークラスター内のシャード移行中の内部状態

ここで、各ノードで動作する「metrics actor」にActorRefを追加する必要があります。シャードの各アクタは、テレメトリデータをメトリックアクタに送信することになっています。これは、同じノード上でローカルに実行されている正しいメトリックアクタを選択する必要があります。理由は、メトリックアクターはデータピアノードを収集します。アクターの一部としてClusterShardingのinicialisationへの参照を

val mvMetrics : ActorRef = system.actorOf(MetricsActor("mv"), "mvMetrics")

、次に渡すオブジェクトを小道具：

今、私は（各ノード上で最初に実行）メイン方法でメトリック・アクターを作成するために考えていました：

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

私の質問は、このように作成されたアクターがノード間で移動するとどうなりますか？ノードA→Bから？ノードBの移行された小道具オブジェクトがノードAと同じままであるので、ActorRefは同じままであるため、新しく作成された俳優が元のノードAにメトリクスデータを送信することは想像できますか？

ありがとうございます。

出典

2016-07-11 Lukáš Gemela