Акка Внутреннее состояние Актора во время миграции осколков в кластере

Question

мы используем Akka sharding для распространения наших действующих участников через несколько узлов. Эти участники упорны, и мы сохраняем их внутреннее состояние в базе данных.

Теперь нам нужно добавить ActorRef к «метрическому актору», работающему на каждом узле. Каждый актер в осколке должен отправлять телеметрические данные метрическому актеру - он должен выбрать подходящего актера метрики, который работает локально на том же узле. Причина в том, что метрический актер собирает узел одноранговых данных.

Теперь, я просто думал создать Metric актера в главном методе (который работает сначала на каждом узле):

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

, а затем передать эту ссылку на ClusterSharding inicialisation как часть актеров реквизит объекта :

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

Мой вопрос: что произойдет, если такие созданные актеры мигрируют между узлами, например от узла А -> В? Я могу представить, что перенесенный объект реквизита на узле B остается таким же, как на узле A, поэтому ActorRef остается тем же, и поэтому вновь созданный актер будет отправлять данные метрик в исходный узел A?

Благодаря

Answer 1

Как насчет воспользовавшись ActorRef.path? представьте, что каждый узел имеет свой актер, названный определенным образом, а затем актер будет динамически находить соответствующего метрического актера, используя этот путь.