FabricActorService Klasse

Paket:

microsoft.servicefabric.actors.runtime

• java.lang.Object
• • StatefulServiceBase
  • • microsoft.servicefabric.actors.runtime.FabricActorService

public class FabricActorService extends StatefulServiceBase implements ActorService

Stellt die Basisklasse für den Microsoft Service Fabric-basierten Reliable Actors-Dienst dar.

Bemerkungen:Leiten Sie von dieser Klasse ab, um Ihren eigenen benutzerdefinierten Akteursdienst zu implementieren, wenn Sie das Verhalten der Dienstebene für Ihre Akteure überschreiben möchten.

Zusammenfassung zum Konstruktor

Konstruktor	Beschreibung
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)	Initialisiert eine neue Instanz der ActorService-Klasse.
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory)	Initialisiert eine neue Instanz der ActorService-Klasse.
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory, BiFunction<ActorBase, ActorStateProvider, ActorStateManager> stateManagerFactory, ActorStateProvider stateProvider, ActorServiceSettings settings)	Initialisiert eine neue Instanz der ActorService-Klasse.

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
List<ServiceReplicaListener>	createServiceReplicaListeners() Erstellt Dienstreplikatlistener.
CompletableFuture<?>	deleteActorAsync(ActorId actorId, CancellationToken cancellationToken) Löscht einen Actor aus dem Actor-Dienst. Ein aktiver Akteur wird deaktiviert, und sein Status wird auch aus dem Zustandsanbieter gelöscht. Der Status eines aktiven Akteurs wird aus dem Statusanbieter gelöscht. Wenn diese Methode für eine nicht vorhandene Akteur-ID im System aufgerufen wird, handelt es sich um eine no-op.
CompletableFuture<PagedResult<ActorInformation>>	getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken) Ruft die Liste der Actors ab, indem der Actor-Dienst abfragt wird.
ActorTypeInformation	getActorTypeInformation() Ruft ActorTypeInformation für den Actor-Dienst ab.
ActorServiceSettings	getSettings() Ruft Einstellungen für den Actor-Dienst ab.
ActorStateProvider	getStateProvider() Ruft einen ActorStateProvider ab, der den Zustandsanbieter für den Akteurdienst darstellt.
void	onAbort() Überschreibt onAbort().
CompletableFuture<?>	onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) Überschreibt onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken).
CompletableFuture<?>	onCloseAsync(CancellationToken cancellationToken) Überschreibt onCloseAsync(CancellationToken cancellationToken).
CompletableFuture<?>	onOpenAsync(ReplicaOpenMode openMode, CancellationToken cancellationToken) Diese Methode wird als letzter Schritt zum Öffnen des Diensts aufgerufen. Überschreiben Sie diese Methode, um benachrichtigt zu werden, dass Open für die internen Komponenten dieses Replikats abgeschlossen wurde.
CompletableFuture<?>	runAsync(CancellationToken cancellationToken) Überschreibt runAsync(CancellationToken cancellationToken).

Geerbte Elemente

StatefulServiceBase.backupAsync(BackupDescription backupDescription) StatefulServiceBase.backupAsync(BackupDescription backupDescription, Duration timeout, CancellationToken cancellationToken) StatefulServiceBase.getAddresses() StatefulServiceBase.getPartition() StatefulServiceBase.getServiceContext() StatefulServiceBase.getStateProviderReplica() StatefulServiceBase.onDataLossAsync(RestoreContext context, CancellationToken cancellationToken) StatefulServiceBase.setAddresses(Map<String, String> addresses) StatefulServiceBase.setPartition(StatefulServicePartition partition) StatefulServiceBase.StatefulServiceBase(StatefulServiceContext serviceContext, StateProviderReplica stateProviderReplica)

Details zum Konstruktor

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)

Initialisiert eine neue Instanz der ActorService-Klasse.

Parameter:

context - Dienstkontext, unter dem der Akteurdienst ausgeführt wird.

actorTypeInfo - Geben Sie die Informationen des Akteurs ein.

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction actorFactory)

Initialisiert eine neue Instanz der ActorService-Klasse.

Parameter:

context - Dienstkontext, unter dem der Akteurdienst ausgeführt wird.

actorTypeInfo - Geben Sie die Informationen des Akteurs ein.

actorFactory - Eine Factorymethode zum Erstellen von Akteurobjekten.

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction actorFactory, BiFunction stateManagerFactory, ActorStateProvider stateProvider, ActorServiceSettings settings)

Initialisiert eine neue Instanz der ActorService-Klasse.

Parameter:

context - Dienstkontext, unter dem der Akteurdienst ausgeführt wird.

actorTypeInfo - Geben Sie die Informationen des Akteurs ein.

actorFactory - Eine Factorymethode zum Erstellen von Akteurobjekten.

stateManagerFactory - Eine Factorymethode zum Erstellen ActorStateManagervon .

stateProvider - Zustandsanbieter zum Speichern des Zustands für Actor-Objekte.

settings - Einstellungen zum Konfigurieren des Verhaltens des Actor-Diensts.

Details zur Methode

createServiceReplicaListeners

protected List createServiceReplicaListeners()

Erstellt Dienstreplikatlistener.

Gibt zurück:

Endpunktzeichenfolgenpaare wie {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

deleteActorAsync

public CompletableFuture deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

Löscht einen Actor aus dem Actor-Dienst.

Ein aktiver Akteur wird deaktiviert, und sein Status wird auch aus dem Zustandsanbieter gelöscht. Der Status eines aktiven Akteurs wird aus dem Statusanbieter gelöscht. Wenn diese Methode für eine nicht vorhandene Akteur-ID im System aufgerufen wird, handelt es sich um eine no-op.

Überschreibt:

FabricActorService.deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

Parameter:

actorId -

ActorId des zu löschenden Akteurs.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Vorgang des Aufrufs an den Server darstellt.

getActorsAsync

public CompletableFuture> getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

Ruft die Liste der Actors ab, indem der Actor-Dienst abfragt wird.

Überschreibt:

FabricActorService.getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

Parameter:

continuationToken - Ein Fortsetzungstoken, aus dem mit der Abfrage der Ergebnisse begonnen werden soll. Ein NULL-Wert des Fortsetzungstokens bedeutet, dass werte vom Anfang zurückgegeben werden.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Ein CompletableFuture , das den asynchronen Vorgang des Aufrufs des Servers darstellt.

getActorTypeInformation

public ActorTypeInformation getActorTypeInformation()

Ruft ActorTypeInformation für den Actor-Dienst ab.

Gibt zurück:

ActorTypeInformation für den Akteur, der vom Dienstreplikat gehostet wird.

getSettings

public ActorServiceSettings getSettings()

Ruft Einstellungen für den Actor-Dienst ab.

Gibt zurück:

Einstellungen für den Actor-Dienst.

getStateProvider

public ActorStateProvider getStateProvider()

Ruft einen ActorStateProvider ab, der den Zustandsanbieter für den Akteurdienst darstellt.

Gibt zurück:

ActorStateProvider stellt den Zustandsanbieter für den Actor-Dienst dar.

onAbort

protected void onAbort()

Überschreibt onAbort().

onChangeRoleAsync

protected CompletableFuture onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Überschreibt onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken).

Parameter:

newRole - Neue Rolle für das Replikat.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Vorgang darstellt, der ausgeführt wird, wenn das Replikat primär wird.

onCloseAsync

protected CompletableFuture onCloseAsync(CancellationToken cancellationToken)

Überschreibt onCloseAsync(CancellationToken cancellationToken).

Parameter:

cancellationToken - Das Token zum Überwachen von Abbruchanforderungen.

Gibt zurück:

Eine Aufgabe, die den asynchronen Vorgang darstellt, der beim Schließen des Replikats ausgeführt wird.

onOpenAsync

protected CompletableFuture onOpenAsync(ReplicaOpenMode openMode, CancellationToken cancellationToken)

Diese Methode wird als letzter Schritt zum Öffnen des Diensts aufgerufen. Überschreiben Sie diese Methode, um benachrichtigt zu werden, dass Open für die internen Komponenten dieses Replikats abgeschlossen wurde.

Parameter:

openMode - für dieses Dienstreplikat.

cancellationToken -

CancellationToken-Objekt, um die Abbruch-status des Vorgangs anzugeben.

Gibt zurück:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt.

runAsync

protected CompletableFuture runAsync(CancellationToken cancellationToken)

Überschreibt runAsync(CancellationToken cancellationToken).

Parameter:

cancellationToken -

CancellationToken-Objekt, um die Abbruch-status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Vorgang des Ladens von Erinnerungen darstellt, wenn das Replikat primär wird.