Поделиться через

Перечисление надежных субъектов Service Fabric

Служба Reliable Actors позволяет клиенту перечислять метаданные субъектов, на которые размещена служба. Так как служба субъекта является секционированной службой с отслеживанием состояния, перечисление выполняется для каждой секции. Так как каждая секция может содержать множество субъектов, перечисление возвращается в виде набора страничных результатов. Страницы перебираются, пока не будут прочитаны все страницы. В следующем примере показано, как создать список всех активных акторов в одном разделе службы акторов.

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);

Хотя приведенный выше код извлекает все субъекты в данной секции, иногда возникает необходимость запрашивать идентификаторы всех субъектов (активных или неактивных) в каждой секции. Это должно быть сделано в порядке исключения, так как это довольно трудоемкая задача.

В следующем примере показано, как запрашивать секции службы и выполнять итерацию по каждому из них в сочетании с приведенным выше примером, чтобы создать список всех активных и неактивных субъектов в службе в приложении 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;

Дальнейшие действия

  • Last updated on