Partilhar via

Enumerar atores confiáveis do Service Fabric

  • Artigo

O serviço Reliable Actors permite que um cliente enumere metadados sobre os atores que o serviço está hospedando. Como o serviço de ator é um serviço com estado particionado, a enumeração é executada por partição. Como cada partição pode conter muitos atores, a enumeração é retornada como um conjunto de resultados paginados. As páginas são repetidas até que todas as páginas sejam lidas. O exemplo a seguir mostra como criar uma lista de todos os atores ativos em uma partição de um serviço de ator:

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

ContinuationToken continuationToken = null;
List<ActorInformation> activeActors = new List<ActorInformation>();

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

    activeActors.AddRange(page.Items.Where(x => x.IsActive));

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

ActorService actorServiceProxy = ActorServiceProxy.create(
    new URI("fabric:/MyApp/MyService"), partitionKey);

ContinuationToken continuationToken = null;
List<ActorInformation> activeActors = new ArrayList<ActorInformation>();

do
{
    PagedResult<ActorInformation> page = actorServiceProxy.getActorsAsync(continuationToken);

    while(ActorInformation x: page.getItems())
    {
         if(x.isActive()){
              activeActors.add(x);
         }
    }

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

Embora o código acima recupere todos os atores em uma determinada partição, ocasionalmente surgirá a necessidade de consultar os IDs de todos os atores (ativos ou inativos) em cada partição. Isso deve ser feito por exceção, pois é uma tarefa bastante pesada.

O exemplo a seguir demonstra como consultar as partições do serviço e iterar através de cada uma em combinação com o exemplo acima para produzir uma lista de todos os atores ativos e inativos no serviço no aplicativo Service Fabric:


var serviceName = new Uri("fabric:/MyApp/MyService");

//As the FabricClient is expensive to create, it should be shared as much as possible
FabricClient fabricClient = new();

//List each of the service's partitions
ServicePartitionList partitions = await fabricClient.QueryManager.GetPartitionListAsync(serviceName);

List<Guid> actorIds = new();

foreach(var partition in partitions)
{
    //Retrieve the partition information
    Int64RangePartitionInformation partitionInformation = (Int64RangePartitionInformation)partition.PartitionInformation; //Actors are restricted to the uniform Int64 scheme per https://learn.microsoft.com/azure/service-fabric/service-fabric-reliable-actors-introduction#distribution-and-failover
    IActorService actorServiceProxy = ActorServiceProxy.Create(serviceName, partitionInformation.LowKey);
    
    ContinuationToken? continuationToken = null;
    
    do 
    {
        var page = await actorServiceProxy.GetActorsAsync(continuationToken, cancellationToken);
        actorIds.AddRange(page.Items.Select(actor => actor.ActorId.GetGuidId());
        continuationToken = page.ContinuationToken;
    } while (continuationToken != null);
}

return actorIds;

Próximos passos