Implementación de características de nivel de servicio en el servicio de actor

Article
06/01/2023

Como se describe en las capas de servicio, el propio servicio de actor es un servicio confiable. Puede escribir su propio servicio que se deriva de ActorService. También puede implementar características de nivel de servicio de la misma manera que cuando hereda un servicio con estado, como:

Copia de seguridad y restauración del servicio.
Funcionalidad compartida para todos los actores, por ejemplo, un interruptor.
Llamadas de procedimiento remoto en el propio servicio de actor y en cada actor individual.

Uso del servicio de actor

Las instancias de actor tienen acceso al servicio de actor en que se ejecutan. A través del servicio de actor, las instancias de actor pueden obtener el contexto de servicio mediante programación. El contexto de servicio tiene el identificador de partición, el nombre del servicio, el nombre de la aplicación y otra información específica de la plataforma de Azure Service Fabric:

Task MyActorMethod()
{
    Guid partitionId = this.ActorService.Context.PartitionId;
    string serviceTypeName = this.ActorService.Context.ServiceTypeName;
    Uri serviceInstanceName = this.ActorService.Context.ServiceName;
    string applicationInstanceName = this.ActorService.Context.CodePackageActivationContext.ApplicationName;
}

CompletableFuture<?> MyActorMethod()
{
    UUID partitionId = this.getActorService().getServiceContext().getPartitionId();
    String serviceTypeName = this.getActorService().getServiceContext().getServiceTypeName();
    URI serviceInstanceName = this.getActorService().getServiceContext().getServiceName();
    String applicationInstanceName = this.getActorService().getServiceContext().getCodePackageActivationContext().getApplicationName();
}

Del mismo modo que ocurre con todos los Reliable Services, el servicio de actor se debe registrar con un tipo de servicio en el tiempo de ejecución de Service Fabric. Con el fin de que el servicio de actor ejecute las instancias de actor, el tipo de actor también se debe registrar con el servicio de actor. El método de registro ActorRuntime realiza este trabajo para los actores. En el caso más sencillo, puede registrar el tipo de actor y entonces el servicio de actor usará la configuración predeterminada.

static class Program
{
    private static void Main()
    {
        ActorRuntime.RegisterActorAsync<MyActor>().GetAwaiter().GetResult();

        Thread.Sleep(Timeout.Infinite);
    }
}

Como alternativa, puede usar una expresión lambda para construir el servicio de actor. A continuación, puede configurar el servicio de actor y construir de manera explícita las instancias de actor. Puede insertar dependencias en el actor mediante su constructor.

static class Program
{
    private static void Main()
    {
        ActorRuntime.RegisterActorAsync<MyActor>(
            (context, actorType) => new ActorService(context, actorType, () => new MyActor()))
            .GetAwaiter().GetResult();

        Thread.Sleep(Timeout.Infinite);
    }
}

static class Program
{
    private static void Main()
    {
      ActorRuntime.registerActorAsync(
              MyActor.class,
              (context, actorTypeInfo) -> new FabricActorService(context, actorTypeInfo),
              timeout);

        Thread.sleep(Long.MAX_VALUE);
    }
}

Métodos de servicio de actor

El servicio de actor implementa IActorService (C#) o ActorService (Java), que, a su vez, implementa IService (C#) o Service (Java). Esta es la interfaz que se usa en la comunicación remota de Reliable Services, que permite llamadas a procedimiento remoto en los métodos de servicio. Contiene métodos de nivel de servicio a los que se puede llamar de manera remota a través del servicio remoto. Se puede usar para enumerar y eliminar actores.

Servicio de actor personalizado

Mediante el uso de la expresión lambda del registro de actor, puede registrar su propio servicio de actor personalizado que deriva de ActorService (C#) y FabricActorService (Java). Luego puede implementar su propia funcionalidad de nivel de servicio mediante la escritura de una clase de servicio que hereda ActorService (C#) o FabricActorService (Java). Un servicio de actor personalizado hereda toda la funcionalidad en tiempo de ejecución de actor de ActorService (C#) o FabricActorService (Java). Se puede usar para implementar sus propios métodos de servicio.

class MyActorService : ActorService
{
    public MyActorService(StatefulServiceContext context, ActorTypeInformation typeInfo, Func<ActorBase> newActor)
        : base(context, typeInfo, newActor)
    { }
}

class MyActorService extends FabricActorService
{
    public MyActorService(StatefulServiceContext context, ActorTypeInformation typeInfo, BiFunction<FabricActorService, ActorId, ActorBase> newActor)
    {
         super(context, typeInfo, newActor);
    }
}

static class Program
{
    private static void Main()
    {
        ActorRuntime.RegisterActorAsync<MyActor>(
            (context, actorType) => new MyActorService(context, actorType, () => new MyActor()))
            .GetAwaiter().GetResult();

        Thread.Sleep(Timeout.Infinite);
    }
}

public class Program
{
    public static void main(String[] args)
    {
        ActorRuntime.registerActorAsync(
                MyActor.class,
                (context, actorTypeInfo) -> new FabricActorService(context, actorTypeInfo),
                timeout);
        Thread.sleep(Long.MAX_VALUE);
    }
}

Implementación de la copia de seguridad y la restauración de actores

Un servicio de actor personalizado puede exponer un método para crear una copia de seguridad de los datos de actor mediante el uso del agente de escucha remoto que ya se encuentra presente en ActorService: Para obtener un ejemplo, vea Actores de copia de seguridad y restauración.

Actor que usa una pila de comunicación remota V2 (compatible con interfaz)

La pila de comunicación remota V2 (compatible con interfaz, conocida como V2_1) tiene todas las características de la pila de comunicación remota V2. Su interfaz es compatible con la pila de comunicación remota V1, pero no es compatible con V2 ni V1. Para actualizar de V1 a V2_1 sin que la disponibilidad del servicio se vea afectada, siga los pasos descritos en la sección siguiente.

Los cambios siguientes son necesarios para usar la pila de comunicación remota V2_1:

Agregue el siguiente atributo de ensamblado en las interfaces de actor.

[assembly:FabricTransportActorRemotingProvider(RemotingListenerVersion = RemotingListenerVersion.V2_1,RemotingClientVersion = RemotingClientVersion.V2_1)]

Compile y actualice los proyectos de servicio de actor y cliente de actor para empezar a usar la pila V2.

Actualización del servicio de actor a la pila de comunicación remota V2 (compatible con interface) sin que la disponibilidad del servicio se vea afectada

Este cambio es una actualización en dos pasos. Siga los pasos de esta secuencia.

Agregue el siguiente atributo de ensamblado en las interfaces de actor. Este atributo inicia dos agentes de escucha para el servicio de actor, V1 (existente) y el agente de escucha V2_1. Actualice el servicio de actor con este cambio.
```
[assembly:FabricTransportActorRemotingProvider(RemotingListenerVersion = RemotingListenerVersion.V1|RemotingListenerVersion.V2_1,RemotingClientVersion = RemotingClientVersion.V2_1)]
```
Actualice los clientes de actor después de completar la actualización anterior. Este paso garantiza que el proxy de actor usa la pila de comunicación remota V2_1.

Este paso es opcional. Cambie el atributo anterior para quitar el agente de escucha V1.

[assembly:FabricTransportActorRemotingProvider(RemotingListenerVersion = RemotingListenerVersion.V2_1,RemotingClientVersion = RemotingClientVersion.V2_1)]

Actor que usa la pila de comunicación remota V2

Con el paquete NuGet 2.8, los usuarios ahora pueden utilizar la pila de comunicación remota V2, que funciona mejor y proporciona características como serialización personalizada. La comunicación remota V2 no es compatible con versiones anteriores de la pila de comunicación remota existente (llamada ahora la pila de comunicación remota V1).

Para usar la pila de comunicación remota V2, son necesarios los cambios siguientes: