StatefulServiceReplica Schnittstelle

Paket:

system.fabric

public interface StatefulServiceReplica

Definiert das Verhalten, das den Lebenszyklus eines Replikats steuert, z. B. Start, Initialisierung, Rollenänderungen und Herunterfahren.

Bemerkungen:Zustandsbehaftete Diensttypen müssen diese Schnittstelle implementieren. Die Logik eines zustandsbehafteten Diensttyps umfasst das Verhalten, das für primäre Replikate aufgerufen wird, und das Verhalten, das auf sekundären Replikaten aufgerufen wird. Wenn der Dienstautor die bereitgestellte FabricReplicatorverwenden möchte, muss der Dienst auch implementieren StateProvider , um die Implementierung von StateReplicator zu verwenden, die von bereitgestellt wird. FabricReplicator

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
void	abort() Ein instance wird unauffällig beendet. Bemerkungen:Leaseverlust und, als Reaktion auf den Dienst, die Verwendung von reportFault(FaultType faultType) , um einen Permanent Fehler zu melden, sind Beispiele für eine nicht ordnungsgemäße Beendigung. Wenn diese Methode aufgerufen wird, sollte der Dienst instance alle Verweise sofort freigeben und sauber und zurückgeben.
CompletableFuture<String>	changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) Ändert die Rolle eines primären oder sekundären Replikats. Bemerkungen:Die neue Rolle wird als Parameter angegeben. Wenn der Dienst in die neue Rolle wechselt, hat der Dienst die Möglichkeit, seine aktuelle Lauschadresse zu aktualisieren. Die Lauschadresse ist die Adresse, an der Clients eine Verbindung herstellen. Dies ermöglicht es dem Dienst, wenn es sich um ein primäres Replikat handelt, nur einige Ressourcen wie Ports in Anspruch zu nehmen, wenn die Kommunikation von Clients erwartet wird.
CompletableFuture<Void>	closeAsync(CancellationToken cancellationToken) Schließt das Dienstreplikat, wenn es heruntergefahren wird. Beachten Sie, dass der Abbruch eine Empfehlung ist und dass der Vorgang möglicherweise trotzdem abgeschlossen wird, auch wenn er abgebrochen wird.
void	initialize(StatefulServiceInitializationParameters initializationParameters) Initialisiert ein neu erstelltes Dienstreplikat.
CompletableFuture<Replicator>	openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) Öffnet ein initialisiertes Dienstreplikat, damit zusätzliche Aktionen ausgeführt werden können.

Details zur Methode

abort

public void abort()

Ein instance wird unauffällig beendet.

Bemerkungen:Leaseverlust und, als Reaktion auf den Dienst, die Verwendung von reportFault(FaultType faultType) , um einen Permanent Fehler zu melden, sind Beispiele für eine nicht ordnungsgemäße Beendigung. Wenn diese Methode aufgerufen wird, sollte der Dienst instance alle Verweise sofort freigeben und sauber und zurückgeben.

changeRoleAsync

public CompletableFuture changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Ändert die Rolle eines primären oder sekundären Replikats.

Bemerkungen:Die neue Rolle wird als Parameter angegeben. Wenn der Dienst in die neue Rolle wechselt, hat der Dienst die Möglichkeit, seine aktuelle Lauschadresse zu aktualisieren. Die Lauschadresse ist die Adresse, an der Clients eine Verbindung herstellen. Dies ermöglicht es dem Dienst, wenn es sich um ein primäres Replikat handelt, nur einige Ressourcen wie Ports in Anspruch zu nehmen, wenn die Kommunikation von Clients erwartet wird.

Parameter:

newRole - Die aktualisierte ReplicaRole , zu der dieses Replikat wechseln soll.

cancellationToken -

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

Gibt zurück:

Gibt CompletableFuture den Typ java.lang.Stringzurück, die neue Verbindungsadresse des Diensts, die dem Replikat über Service Fabric Naming zugeordnet werden soll.

closeAsync

public CompletableFuture closeAsync(CancellationToken cancellationToken)

Schließt das Dienstreplikat, wenn es heruntergefahren wird. Beachten Sie, dass der Abbruch eine Empfehlung ist und dass der Vorgang möglicherweise trotzdem abgeschlossen wird, auch wenn er abgebrochen wird.

Parameter:

cancellationToken -

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

Gibt zurück:

Gibt CompletableFuture zurück.

initialize

public void initialize(StatefulServiceInitializationParameters initializationParameters)

Initialisiert ein neu erstelltes Dienstreplikat.

Parameter:

initializationParameters - Die StatefulServiceInitializationParameters für dieses Replikat.

openAsync

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

Öffnet ein initialisiertes Dienstreplikat, damit zusätzliche Aktionen ausgeführt werden können.

Parameter:

openMode - Dies unterstützt die Service Fabric-Infrastruktur und ist nicht für die direkte Verwendung aus Ihrem Code vorgesehen.

partition - Die StatefulServicePartition Informationen für dieses Replikat.

cancellationToken -

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

Gibt zurück:

Gibt zurückCompletableFuture><Replicator, das Replicator vom zustandsbehafteten Dienst verwendet wird. Um die Service Fabric-Implementierung in openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) zu verwenden, sollte das Replikat einen FabricReplicator zurückgeben, der von createReplicator(StateProvider stateProvider, ReplicatorSettings replicatorSettings)