Service Fabric, определите, существует ли конкретный субъект

Единственный официальный способ проверить, был ли ранее активирован субъект в каком-либо служебном разделе, - это использовать запрос ActorServiceProxy, как описано в здесь:

IActorService actorServiceProxy = ActorServiceProxy.Create(
    new Uri("fabric:/MyApp/MyService"), partitionKey);

ContinuationToken continuationToken = null;
do
{
    PagedResult<ActorInformation> page = await actorServiceProxy.GetActorsAsync(continuationToken, cancellationToken);

    var actor = page.Items.FirstOrDefault(x => x.ActorId == idToFind);

    continuationToken = page.ContinuationToken;
}
while (continuationToken != null);

По природе SF Actors они виртуальные, это означает, что они существуют всегда, даже если вы не активировали их ранее, поэтому выполнить эту проверку будет немного сложнее.

Как вы сказали, запрос всех участников неэффективен, поэтому вы можете попробовать следующие обходные пути:

1. Сохраните идентификаторы в надежном словаре в другом месте, каждый раз, когда актер активируется, вы вызываете событие и вставляете идентификаторы ActorID в словарь, если они еще не там.

   • You can use the OnActivateAsync() actor event to notify it's creation, or
   • Вы можете использовать фабрику пользовательских акторов в ActorService для регистрации активации акторов.
   • Вы можете сохранить словарь в другом актере или другом StatefulService

2. Создайте свойство в актере, которое устанавливается самим актером при его активации.

   • The OnActivateAsync() check if this property has been set before
   • Если еще не установлено, вы устанавливаете новое значение и сохраняете в переменной (непостоянное значение), чтобы сказать, что актер новый.
   • Каждый раз, когда вы взаимодействуете с актером, вы устанавливаете это, чтобы указать, что он больше не новый.
   • При следующей активации свойство уже будет установлено, и ничего не должно произойти.

3. Создайте собственный IActorStateProvider, чтобы он выполнял то же самое, что указано в варианте 2, вместо того, чтобы обрабатывать его в актере, он будет обрабатывать уровень под ним. Честно говоря, я думаю, что это небольшая работа, это будет удобно, только если вам придется проделать то же самое для многих типов актеров, варианты 1 и 2 были бы намного проще.

4. Сделайте так, как предлагал Питер Бонс, сохраните ActorID вне ActorService, как в БД, я бы предложил этот вариант только в том случае, если вам нужно проверить это извне кластера.

.

Следующий фрагмент может помочь вам, если вы хотите управлять этими событиями вне актера.

private static void Main()
{
    try
    {
        ActorRuntime.RegisterActorAsync<NetCoreActorService>(
           (context, actorType) => new ActorService(context, actorType,
                    new Func<ActorService, ActorId, ActorBase>((actorService, actorId) =>
                    {
                        RegisterActor(actorId);//The custom method to register the actor if new
                        return (ActorBase)Activator.CreateInstance(actorType.ImplementationType, actorService, actorId);
                    })
                )).GetAwaiter().GetResult();

        Thread.Sleep(Timeout.Infinite);
    }
    catch (Exception e)
    {
        ActorEventSource.Current.ActorHostInitializationFailed(e.ToString());
        throw;
    }
}

private static void RegisterActor(ActorId actorId) 
{
    //Here you will put the logic to register elsewhere the actor creation
}

В качестве альтернативы вы можете создать DeviceActorStatusActor с отслеживанием состояния, который будет уведомлен (вызван) DeviceActor, как только он будет создан. (Поделитесь ActorId для корреляции.)

В зависимости от ваших потребностей вы также можете зарегистрировать несколько актеров с одним и тем же субъектом отслеживания статуса.

У вас будет отличная производительность и информация почти в реальном времени.