ActorBase クラス

  • java.lang.Object
    • microsoft.servicefabric.actors.runtime.ActorBase

public class ActorBase

アクターの基底クラスを表します。 Actor

発言:これはアクターの基本型であり、 から派生したアクターによって実装されるアクター間で共通の機能を Actor 提供します。状態はアクターガベージ コレクションとフェールオーバー全体で保持されます。 状態のストレージと取得は、アクター状態プロバイダー ActorStateProviderによって提供されます。

コンストラクターの概要

コンストラクター 説明
ActorBase(FabricActorService actorService, ActorId actorId)

メソッドの概要

修飾子と型 メソッドと説明
FabricActorService getActorService()

アクターをホストしているステートフル サービス レプリカを取得します。

String getApplicationName()

このアクターをホストしているアクター サービスを含むアプリケーションの名前を取得します。

DiagnosticsManagerActorContext getDiagnosticsContext()

アクターの診断 コンテキストを返します。 内部使用専用です。

<T> T getEvent(Class<T> eventClass)

指定したイベント インターフェイスのイベントを取得します。

ActorId getId()

アクター サービスを使用して、このアクターの ID を取得します。

ActorReminder getReminder(String reminderName)

指定したアラーム名を持つアクターアラームを取得します。

URI getServiceUri()

このアクターをホストしているアクター サービスの URI を取得します。

boolean isDirty()

アクターの状態がダーティされているかどうかを確認します。

CompletableFuture<?> onActivateAsync()

メンバーの初期化、状態の初期化、タイマーの登録を行う場合は、このメソッドをオーバーライドします。 このメソッドは、アクターがアクティブ化された直後、およびメソッド呼び出しまたはアラームがディスパッチされる直前に呼び出されます。

CompletableFuture<?> onDeactivateAsync()

タイマーの登録解除などのリソースを解放するには、このメソッドをオーバーライドします。 このメソッドは、アクターが非アクティブ化される直前に呼び出されます。

CompletableFuture<?> onPostActorMethodAsync(ActorMethodContext actorMethodContext)

このメソッドは、アクター メソッドの実行が完了したアクター ランタイムによって呼び出されます。 アクター メソッドの実行が完了した後にアクションを実行するには、このメソッドをオーバーライドします。

発言: このメソッドは、次の前にアクター ランタイムによって呼び出されます。

  • クライアント要求が来たときのアクター インターフェイス メソッドの呼び出し。

  • アラームが発生したときにインターフェイスで Remindable メソッドを呼び出す。

  • タイマーが発生したときにタイマー コールバックを呼び出す。

CompletableFuture<?> onPreActorMethodAsync(ActorMethodContext actorMethodContext)

このメソッドは、アクター メソッドを呼び出す直前にアクター ランタイムによって呼び出されます。 アクター メソッドが呼び出される前にアクションを実行するには、このメソッドをオーバーライドします。

発言:このメソッドは、次の前にアクター ランタイムによって呼び出されます。

  • クライアント要求が来たときのアクター インターフェイス メソッドの呼び出し。

  • アラームが発生したときにインターフェイスで Remindable メソッドを呼び出す。

  • タイマーが発生したときにタイマー コールバックを呼び出す。

CompletableFuture<?> registerReminderAsync(String reminderName, byte[] state, Duration dueTime, Duration period)

指定したアラームをアクターに登録します。

ActorTimer registerTimer(Function<Object, CompletableFuture<?>> asyncCallback, Object state, Duration dueTime, Duration period)

アクターのタイマーを登録します。

ActorTimer registerTimer(Function<Object, CompletableFuture<?>> asyncCallback, String asyncCallbackFunctionName, Object state, Duration dueTime, Duration period)

アクターのタイマーを登録します。

void setDirty(boolean isDirty)

アクターの状態をダーティとして設定します。

void setDummy(boolean isDummy)

ダミーかどうかに関係なく、アクターの状態を設定します。

CompletableFuture<?> unregisterReminderAsync(ActorReminder reminder)

指定したアラームをアクターで登録解除します。

void unregisterTimer(ActorTimer timer)

このアクターで以前に設定されたタイマーの登録を解除します。

コンストラクターの詳細

ActorBase

protected ActorBase(FabricActorService actorService, ActorId actorId)

パラメーター:

actorService
actorId

メソッドの詳細

getActorService

public FabricActorService getActorService()

アクターをホストしているステートフル サービス レプリカを取得します。

戻り値:

FabricActorService アクターをホストするステートフル サービス レプリカを表します。 俳優。

getApplicationName

public String getApplicationName()

このアクターをホストしているアクター サービスを含むアプリケーションの名前を取得します。

戻り値:

このアクターをホストしているアクター サービスを含むアプリケーションの名前。

getDiagnosticsContext

public DiagnosticsManagerActorContext getDiagnosticsContext()

アクターの診断 コンテキストを返します。 内部使用専用です。

戻り値:

コンテキストを診断します。

getEvent

protected T getEvent(Class eventClass)

指定したイベント インターフェイスのイベントを取得します。

パラメーター:

eventClass - イベント クラス。

戻り値:

指定したインターフェイスを表す Event を返します。

getId

public ActorId getId()

アクター サービスを使用して、このアクターの ID を取得します。

戻り値:

ActorId アクターの場合は 。

getReminder

protected ActorReminder getReminder(String reminderName)

指定したアラーム名を持つアクターアラームを取得します。

パラメーター:

reminderName - 取得するアラームの名前。

戻り値:

ActorReminderアクターアラームを表す 。

getServiceUri

public URI getServiceUri()

このアクターをホストしているアクター サービスの URI を取得します。

戻り値:

java.net.URI このアクターをホストしているアクター サービスの 。

isDirty

public boolean isDirty()

アクターの状態がダーティされているかどうかを確認します。

戻り値:

アクターの状態がダーティの場合はブール値 true、それ以外の場合は false。

onActivateAsync

protected CompletableFuture onActivateAsync()

メンバーの初期化、状態の初期化、タイマーの登録を行う場合は、このメソッドをオーバーライドします。 このメソッドは、アクターがアクティブ化された直後、およびメソッド呼び出しまたはアラームがディスパッチされる直前に呼び出されます。

戻り値:

未処理の OnActivateAsync 操作を表す CompletableFuture。

onDeactivateAsync

protected CompletableFuture onDeactivateAsync()

タイマーの登録解除などのリソースを解放するには、このメソッドをオーバーライドします。 このメソッドは、アクターが非アクティブ化される直前に呼び出されます。

戻り値:

未処理の OnDeactivateAsync 操作を表す CompletableFuture。

onPostActorMethodAsync

protected CompletableFuture onPostActorMethodAsync(ActorMethodContext actorMethodContext)

このメソッドは、アクター メソッドの実行が完了したアクター ランタイムによって呼び出されます。 アクター メソッドの実行が完了した後にアクションを実行するには、このメソッドをオーバーライドします。

発言: このメソッドは、次の前にアクター ランタイムによって呼び出されます。

  • クライアント要求が来たときのアクター インターフェイス メソッドの呼び出し。

  • アラームが発生したときにインターフェイスで Remindable メソッドを呼び出す。

  • タイマーが発生したときにタイマー コールバックを呼び出す。

パラメーター:

actorMethodContext - ActorMethodContextこのメソッドの前にアクター ランタイムによって呼び出されたメソッドを記述する 。

戻り値:

CompletableFutureアクターメソッド後の操作を表す 。

onPreActorMethodAsync

protected CompletableFuture onPreActorMethodAsync(ActorMethodContext actorMethodContext)

このメソッドは、アクター メソッドを呼び出す直前にアクター ランタイムによって呼び出されます。 アクター メソッドが呼び出される前にアクションを実行するには、このメソッドをオーバーライドします。

発言:このメソッドは、次の前にアクター ランタイムによって呼び出されます。

  • クライアント要求が来たときのアクター インターフェイス メソッドの呼び出し。

  • アラームが発生したときにインターフェイスで Remindable メソッドを呼び出す。

  • タイマーが発生したときにタイマー コールバックを呼び出す。

パラメーター:

actorMethodContext - ActorMethodContextこのメソッドの完了後にアクター ランタイムによって呼び出されるメソッドを記述する 。

戻り値:

CompletableFutureアクター前メソッド操作を表す 。

registerReminderAsync

protected CompletableFuture registerReminderAsync(String reminderName, byte[] state, Duration dueTime, Duration period)

指定したアラームをアクターに登録します。

パラメーター:

reminderName - 登録するアラームの名前
state - アラームに関連付けられている状態。
dueTime - java.time.Durationアラームを発するまでの遅延時間を表す 。 アラームが発生しないように、負の 1 (-1) ミリ秒を指定します。 アラームを直ちに起動するには、ゼロ (0) を指定します。
period - アラームが発生するまでの時間間隔。 定期的な起動を無効にするには、負の 1 (-1) ミリ秒を指定します。

戻り値:

非同期登録操作を表すタスク。

registerTimer

protected ActorTimer registerTimer(Function> asyncCallback, Object state, Duration dueTime, Duration period)

アクターのタイマーを登録します。

パラメーター:

asyncCallback - タイマーが発生したときに呼び出すコールバック。
state - タイマー コールバックに渡す状態。
dueTime - アクター タイマーが最初に期限である場合の TimeSpan。
period - 後続のアクター タイマー呼び出しの TimeSpan。

戻り値:

ActorTimer オブジェクトを返します。

registerTimer

protected ActorTimer registerTimer(Function> asyncCallback, String asyncCallbackFunctionName, Object state, Duration dueTime, Duration period)

アクターのタイマーを登録します。

パラメーター:

asyncCallback - タイマーが発生したときに呼び出すコールバック。
asyncCallbackFunctionName - AsyncCallBack 関数の名前。 と で使用して、この関数のonPreActorMethodAsync(ActorMethodContext actorMethodContext)onPostActorMethodAsync(ActorMethodContext actorMethodContext)呼び出し前と事後呼び出しで任意のユーザー タスクを開始できます。 プロパティ getMethodName() はメソッド名を指定します。
state - タイマー コールバックに渡す状態。
dueTime - アクター タイマーが最初に期限である場合の TimeSpan。
period - 後続のアクター タイマー呼び出しの TimeSpan。

戻り値:

ActorTimer オブジェクトを返します。

setDirty

public void setDirty(boolean isDirty)

アクターの状態をダーティとして設定します。

パラメーター:

isDirty - は、アクターの状態をブール値として受け取ります: true または false。

setDummy

protected void setDummy(boolean isDummy)

ダミーかどうかに関係なく、アクターの状態を設定します。

パラメーター:

isDummy - は、アクターの状態をブール値として受け取ります: true または false。

unregisterReminderAsync

protected CompletableFuture unregisterReminderAsync(ActorReminder reminder)

指定したアラームをアクターで登録解除します。

パラメーター:

reminder - 登録を解除するアクターアラーム。

戻り値:

非同期登録解除操作を表すタスク。

unregisterTimer

protected void unregisterTimer(ActorTimer timer)

このアクターで以前に設定されたタイマーの登録を解除します。

パラメーター:

timer - 登録解除する必要があるタイマーを表す ActorTimer。

適用対象