アクター サービスでのサービス レベルの機能の実装

  • [アーティクル]

サービスのレイヤーで説明したように、アクター サービス自体は信頼できるサービスです。 ActorServiceから派生した独自のサービスを記述することができます。 次のように、StatefulService を継承したときと同様に、サービス レベルの機能を実装することもできます。

  • サービスのバックアップと復元。
  • すべてのアクターで共有される機能 (サーキット ブレーカーなど)。
  • アクター サービス自体と個別アクターでのリモート プロシージャ コール。

アクター サービスの使用

アクター インスタンスは、それが実行されるアクター サービスにアクセスできます。 アクター インスタンスは、アクター サービスを使用して、サービス コンテキストをプログラムによって取得できます。 サービス コンテキストには、パーティション ID、サービス名、アプリケーション名、他の 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();
}

アクター サービスは、すべての Reliable Services と同様に、Service Fabric ランタイムのサービスの種類に登録する必要があります。 アクター サービスでアクター インスタンスを実行するためには、アクター型もアクター サービスに登録する必要があります。 ActorRuntime 登録メソッドは、アクターに対してこの処理を実行します。 最も単純なケースでは、アクターの種類を登録するだけでかまいません。そうすれば、アクター サービスが既定の設定を使用します。

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

        Thread.Sleep(Timeout.Infinite);
    }
}

また、登録メソッドによって提供されるラムダを使ってアクター サービスを自分で構築することもできます。 そうすれば、アクター サービスを構成してアクター インスタンスを明示的に構築することができます。 コンストラクターを通じてアクターに依存関係を挿入することができます。

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

アクター サービスのメソッド

アクター サービスは IActorService (C#) または ActorService (Java) を実装し、それが IService (C#) または Service (Java) を実装します。 このインターフェイスは、Reliable Services リモート処理によって使用され、サービス メソッドでのリモート プロシージャ呼び出しを可能にします。 これには、サービスのリモート処理によってリモートで呼び出すことのできるサービスレベルのメソッドが含まれます。 列挙と削除アクターに対して使用することができます。

カスタム アクター サービス

アクター登録ラムダを使用することで、ActorService (C#) および FabricActorService (Java) から派生する独自のカスタム アクター サービスを登録できます。 そうすれば、ActorService (C#) または FabricActorService (Java) を継承するサービス クラスを記述することで、独自のサービス レベル機能を実装できます。 カスタム アクター サービスは、ActorService (C#) または FabricActorService (Java) からすべてのアクター ランタイム機能を継承します。 独自のサービス メソッドを実装するために使用できます。

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

アクターのバックアップと復元の実装

カスタム アクター サービスは、既に ActorService に存在するリモート処理リスナーを活用して、アクター データをバックアップするメソッドを公開することができます。 例については、アクターのバックアップおよび復元を参照してください。

リモート処理 V2 スタック (インターフェイスとの互換性あり) を使用するアクター

リモート処理 V2 (インターフェイス互換、V2_1 と呼ばれます) スタックは、V2 リモート処理スタックのすべての機能を備えています。 そのインターフェイスには、リモート処理 V1 スタックとの互換性がありますが、V2 および V1 との下位互換性はありません。 サービスの可用性に影響を与えずに V2_1 V1 からアップグレードするには、次のセクションの手順に従います。

リモート処理 V2_1 スタックを使用するには、次の変更が必要です。

  1. アクター インターフェイスで次の Assembly 属性を追加します。

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

  2. ActorService とアクター クライアント プロジェクトをビルドしてアップグレードし、V2 スタックの使用を開始します。

サービスの可用性に影響を与えずにアクター サービスをリモート処理 V2 (インターフェイスとの互換性あり) スタックにアップグレードする

この変更は、2 段階アップグレードです。 この順序で以下の手順に従います。

  1. アクター インターフェイスで次の Assembly 属性を追加します。 この属性は、ActorService 用の 2 つのリスナーである、V1 (既存) および V2_1 リスナーを開始します。 この変更で ActorService をアップグレードします。

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

  2. 前のアップグレードを完了してから、アクター クライアントをアップグレードします。 この手順により、アクター プロキシがリモート処理 V2_1 スタックを使用していることを確認します。

  3. この手順は省略可能です。 前の属性を変更して V1 リスナーを削除します。

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

リモート処理 V2 スタックを使用するアクター

バージョン 2.8 NuGet パッケージによって、ユーザーは、カスタムのシリアル化などの機能を提供するリモート処理 V2 スタックを使用できるようになりました。 リモート処理 V2 には、既存のリモート処理スタック (V1 リモート処理スタックと呼びます) との下位互換性がありません。

リモート処理 V2 スタックを使用するには、次の変更が必要です。

  1. アクター インターフェイスで次の Assembly 属性を追加します。

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

  2. ActorService とアクター クライアント プロジェクトをビルドしてアップグレードし、V2 スタックの使用を開始します。

サービスの可用性に影響を与えずにアクター サービスをリモート処理 V2 スタックにアップグレードする

この変更は、2 段階アップグレードです。 この順序で以下の手順に従います。

  1. アクター インターフェイスで次の Assembly 属性を追加します。 この属性は、ActorService 用の 2 つのリスナーである、V1 (既存) および V2 リスナーを開始します。 この変更で ActorService をアップグレードします。

    [assembly:FabricTransportActorRemotingProvider(RemotingListenerVersion = RemotingListenerVersion.V1|RemotingListenerVersion.V2,RemotingClientVersion = RemotingClientVersion.V2)]

  2. 前のアップグレードを完了してから、アクター クライアントをアップグレードします。 この手順により、アクター プロキシがリモート処理 V2 スタックを使用していることを確認します。

  3. この手順は省略可能です。 前の属性を変更して V1 リスナーを削除します。

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

次のステップ