StatefulServiceReplica インターフェイス

パッケージ:

system.fabric

public interface StatefulServiceReplica

起動、初期化、ロールの変更、シャットダウンなど、レプリカのライフサイクルを制御する動作を定義します。

発言：ステートフル サービスの種類では、このインターフェイスを実装する必要があります。 ステートフル サービスの種類のロジックには、プライマリ レプリカで呼び出される動作と、セカンダリ レプリカで呼び出される動作が含まれます。 サービス作成者が指定された FabricReplicatorを使用する場合は、 によって提供される の実装StateReplicatorを使用するために、サービスも を実装StateProviderする必要があります。FabricReplicator

メソッドの概要

修飾子と型	メソッドと説明
void	abort() インスタンスを不当に終了します。 発言：リース損失と、サービスに応じて、 を使用して reportFault(FaultType faultType) 障害を Permanent 報告することが、不名誉な終了の例です。 このメソッドが呼び出されると、サービス インスタンスは直ちに解放し、すべての参照をクリーンし、 を返す必要があります。
CompletableFuture<String>	changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) プライマリ レプリカまたはセカンダリ レプリカのロールを変更します。 発言：新しいロールはパラメーターとして示されます。 サービスが新しいロールに移行すると、サービスは現在のリッスン アドレスを更新する機会があります。 リッスン アドレスは、クライアントが接続するアドレスです。 これにより、プライマリ レプリカであるサービスは、クライアントからの通信が予想される場合にポートなどの一部のリソースのみを要求できます。
CompletableFuture<Void>	closeAsync(CancellationToken cancellationToken) シャットダウン中にサービス レプリカを閉じます。 取り消しはアドバイザリであり、取り消された場合でも操作が完了する可能性があることに注意してください。
void	initialize(StatefulServiceInitializationParameters initializationParameters) 新しく作成されたサービス レプリカを初期化します。
CompletableFuture<Replicator>	openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) 追加のアクションを実行できるように、初期化されたサービス レプリカを開きます。

メソッドの詳細

abort

public void abort()

インスタンスを不当に終了します。

発言：リース損失と、サービスに応じて、 を使用して reportFault(FaultType faultType) 障害を Permanent 報告することが、不名誉な終了の例です。 このメソッドが呼び出されると、サービス インスタンスは直ちに解放し、すべての参照をクリーンし、 を返す必要があります。

changeRoleAsync

public CompletableFuture changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

プライマリ レプリカまたはセカンダリ レプリカのロールを変更します。

発言：新しいロールはパラメーターとして示されます。 サービスが新しいロールに移行すると、サービスは現在のリッスン アドレスを更新する機会があります。 リッスン アドレスは、クライアントが接続するアドレスです。 これにより、プライマリ レプリカであるサービスは、クライアントからの通信が予想される場合にポートなどの一部のリソースのみを要求できます。

パラメーター:

newRole - このレプリカが移行する必要がある更新。ReplicaRole

cancellationToken -

CancellationToken 操作の取り消し状態を示す オブジェクト。

戻り値:

CompletableFuture Service Fabric の名前付けによってレプリカに関連付けられるサービスの新しい接続アドレス である 型java.lang.Stringを返します。

closeAsync

public CompletableFuture closeAsync(CancellationToken cancellationToken)

シャットダウン中にサービス レプリカを閉じます。 取り消しはアドバイザリであり、取り消された場合でも操作が完了する可能性があることに注意してください。

パラメーター:

cancellationToken -

CancellationToken 操作の取り消し状態を示す オブジェクト。

戻り値:

CompletableFuture が返されます。

initialize

public void initialize(StatefulServiceInitializationParameters initializationParameters)

新しく作成されたサービス レプリカを初期化します。

パラメーター:

initializationParameters - StatefulServiceInitializationParametersこのレプリカの 。

openAsync

public CompletableFuture openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken)

追加のアクションを実行できるように、初期化されたサービス レプリカを開きます。

パラメーター:

openMode - これは Service Fabric インフラストラクチャをサポートしており、コードから直接使用するためのものではありません。

partition - StatefulServicePartitionこのレプリカの情報。

cancellationToken -

CancellationToken 操作の取り消し状態を示す オブジェクト。

戻り値:

CompletableFuture > < Replicator Replicatorステートフル サービスによって使用される を返します。 で Service Fabric 実装を使用するには、 openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) から取得した を FabricReplicator レプリカから返す必要があります。 createReplicator(StateProvider stateProvider, ReplicatorSettings replicatorSettings)