Azure Service Fabric: Wie finde ich heraus, ob ein Actor bereits existiert?

Question

Wie kann ich herausfinden, ob ein Actor mit einer bestimmten ActorId existiert?

Der ActorProxy dient nur zum Erstellen eines Actors. Wenn eine nicht vorhandene ID bereitgestellt wird und der Actor nicht vorhanden ist, wird ein neuer Actor erstellt.

Der Standard ActorService kann alle Actors abrufen, aber das ist soweit, wie ich sehen kann.

Answer 1

Derzeit gibt es keine einfache Möglichkeit, dies zu tun. Akteure sollen die Lebensdauer der Instanz eines Gegenstandes weg abstrahieren. Ruf einfach eines an, wenn du es brauchst, und es wird da sein. Ich bin mir also nicht sicher, ob das wirklich nötig ist.

Das heißt, Sie könnten eine andere Service-Methode erstellen, um alle Akteure auf der Serverseite zu durchlaufen, statt die gesamte Liste auf den Client zu ziehen, aber wenn Sie Millionen von Actor-Instanzen haben, wird es nicht sehr effizient sein .

Alternativ können Sie einen Markierungsstatus während der Initialisierung Ihres Actors speichern und den State-Provider danach abfragen - auf Kosten des Hinzufügens von mehr Status- und Replikations-Overhead zu Ihrem Actor.

Erstellen Sie zunächst eine Service-Schnittstelle:

public interface IActorServiceEx : IService 
{ 
    Task<bool> ActorExists(ActorId actorId, CancellationToken cancellationToken = default(CancellationToken)); 
} 

Dann einen benutzerdefinierten Schauspieler Dienst erstellen, die diese Schnittstelle implementiert:

internal class CustomActorService : ActorService, IActorServiceEx 
{ 
    public CustomActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, Func<ActorBase> actorFactory = null, IActorStateProvider stateProvider = null, ActorServiceSettings settings = null) 
     : base(context, actorTypeInfo, actorFactory, stateProvider, settings) 
    { 
    } 

    public async Task<bool> ActorExists(ActorId actorId, CancellationToken cancellationToken) 
    { 
     const int batchSize = 1000; 
     ContinuationToken token = null; 
     do 
     { 
      var actors = await StateProvider.GetActorsAsync(batchSize, token, cancellationToken); 
      if (actors.Items.Contains(actorId)) 
      { 
       return true; 
      } 
      token = actors.ContinuationToken; 
     } while (token != null); 
     return false; 
    } 
} 

Oder die alternative Version mit dem Marker:

internal class Actor1 : Actor, IActor1 
{ 
    protected override async Task OnActivateAsync() 
    { 
     await StateManager.TryAddStateAsync("Activated", true); 
    } 
} 

internal class CustomActorService : ActorService, IActorServiceEx 
{ 
    ... 

    public Task<bool> ActorExists(ActorId actorId, CancellationToken cancellationToken) 
    { 
     return StateProvider.ContainsStateAsync(actorId, "Activated", cancellationToken); 
    } 
} 

Schließlich, verwenden Sie es bei der Registrierung Ihres Schauspielers, zB:

ActorRuntime.RegisterActorAsync<Actor1>((context, actorType) => 
    new CustomActorService(context, actorType, 
    () => new Actor1())).GetAwaiter().GetResult(); 

Und diesen neuen Service-Methode aufzurufen:

var actorService = ActorServiceProxy.Create<IActorServiceEx>(serviceUri, actorId); 

var exists = await actorService.ActorExists(actorId);