StatefulServiceBase Klasse

Paket:

microsoft.servicefabric.services.runtime

• java.lang.Object
• • microsoft.servicefabric.services.runtime.StatefulServiceBase

public class StatefulServiceBase

Stellt die Basisklasse für den zustandsbehafteten zuverlässigen Dienst von Microsoft Service Fabric dar.

Zusammenfassung zum Konstruktor

Konstruktor	Beschreibung
StatefulServiceBase(StatefulServiceContext serviceContext, StateProviderReplica stateProviderReplica)	Erstellt einen neuen StatefulService.

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
CompletableFuture<?>	backupAsync(BackupDescription backupDescription) Führt eine Sicherung des gesamten zuverlässigen Zustands aus, der von diesem StatefulServiceBaseverwaltet wird.
CompletableFuture<?>	backupAsync(BackupDescription backupDescription, Duration timeout, CancellationToken cancellationToken) Führt eine Sicherung des gesamten zuverlässigen Zustands aus, der von diesem StatefulServiceBaseverwaltet wird.
List<ServiceReplicaListener>	createServiceReplicaListeners() Überschreiben Sie diese Methode, um die Kommunikationslistener für das Dienstreplikat anzugeben. Die vom Kommunikationslistener zurückgegebenen Endpunkte werden als JSON-Zeichenfolge von ListenerName gespeichert, Endpunktzeichenfolgenpaare wie {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}
Map<String, String>	getAddresses() Ruft eine Liste aller Adressen für dieses Dienstreplikat als Schlüssel-Wert-Paar (ListenerName, Endpunkt) ab.
StatefulServicePartition	getPartition() Dienstpartition, zu der das aktuelle Dienstreplikat gehört.
StatefulServiceContext	getServiceContext() Ruft den Dienstkontext ab, unter dem dieser zustandsbehaftete Dienst ausgeführt wird. Es stellt Informationen wie ReplicaId, PartitionId, ServiceName usw. bereit.
StateProviderReplica	getStateProviderReplica()
void	onAbort() Benachrichtigung, dass der Dienst abgebrochen wird. RunAsync wird möglicherweise gleichzeitig mit der Ausführung dieser Methode ausgeführt, da für den Abbruchpfad kein Abbruch erwartet wird.
CompletableFuture<?>	onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) Diese Methode wird als letzter Schritt vor dem Abschließen changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) von aufgerufen. Überschreiben Sie diese Methode, um benachrichtigt zu werden, dass ChangeRole für die internen Komponenten dieses Replikats abgeschlossen wurde.
CompletableFuture<?>	onCloseAsync(CancellationToken cancellationToken) Diese Methode wird als letzter Schritt zum Schließen des Diensts aufgerufen. Überschreiben Sie diese Methode, um benachrichtigt zu werden, dass Close für die internen Komponenten dieses Replikats abgeschlossen wurde.
CompletableFuture<Boolean>	onDataLossAsync(RestoreContext context, CancellationToken cancellationToken) Diese Methode wird bei vermutetem Datenverlust aufgerufen. Sie können diese Methode überschreiben, um den Dienst bei Datenverlust wiederherzustellen.
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) Dienste, die eine Verarbeitungsschleife implementieren möchten, die ausgeführt wird, wenn sie primär ist und über schreibgeschützte status verfügt, überschreiben diese Methode einfach mit ihrer Logik.
void	setAddresses(Map<String, String> addresses) Legt die Liste aller Adressen für dieses Dienstreplikat als Schlüssel-Wert-Paar (ListenerName, Endpunkt) fest.
void	setPartition(StatefulServicePartition partition) Dienstpartition, zu der das aktuelle Dienstreplikat gehört.

Details zum Konstruktor

StatefulServiceBase

protected StatefulServiceBase(StatefulServiceContext serviceContext, StateProviderReplica stateProviderReplica)

Erstellt einen neuen StatefulService.

Parameter:

serviceContext - Ein StatefulServiceContext , der den Dienstkontext beschreibt.

stateProviderReplica - Ein StateProviderReplica , das ein zuverlässiges Zustandsanbieterreplikat darstellt.

Details zur Methode

backupAsync

public CompletableFuture backupAsync(BackupDescription backupDescription)

Führt eine Sicherung des gesamten zuverlässigen Zustands aus, der von diesem StatefulServiceBaseverwaltet wird.

Parameter:

backupDescription - Ein BackupDescription , der die Sicherungsanforderung beschreibt.

Gibt zurück:

Aufgabe, die den asynchronen Sicherungsvorgang darstellt.

backupAsync

public CompletableFuture backupAsync(BackupDescription backupDescription, Duration timeout, CancellationToken cancellationToken)

Führt eine Sicherung des gesamten zuverlässigen Zustands aus, der von diesem StatefulServiceBaseverwaltet wird.

Parameter:

backupDescription - Ein BackupDescription , der die Sicherungsanforderung beschreibt.

timeout - Das Timeout für diesen Vorgang.

cancellationToken - Das Token zum Überwachen von Abbruchanforderungen.

Gibt zurück:

Aufgabe, die den asynchronen Sicherungsvorgang darstellt.

createServiceReplicaListeners

protected List createServiceReplicaListeners()

Überschreiben Sie diese Methode, um die Kommunikationslistener für das Dienstreplikat anzugeben. Die vom Kommunikationslistener zurückgegebenen Endpunkte werden als JSON-Zeichenfolge von ListenerName gespeichert, Endpunktzeichenfolgenpaare wie {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Gibt zurück:

Liste der ServiceReplicaListener

getAddresses

protected Map getAddresses()

Ruft eine Liste aller Adressen für dieses Dienstreplikat als Schlüssel-Wert-Paar (ListenerName, Endpunkt) ab.

Gibt zurück:

Ein Map , der die Liste der Adressen als Schlüssel-Wert-Paar (ListenerName, Endpunkt) enthält.

getPartition

protected StatefulServicePartition getPartition()

Dienstpartition, zu der das aktuelle Dienstreplikat gehört.

Gibt zurück:

Ein StatefulServicePartition , das die Partition darstellt, zu der dieses Dienstreplikat gehört.

getServiceContext

public StatefulServiceContext getServiceContext()

Ruft den Dienstkontext ab, unter dem dieser zustandsbehaftete Dienst ausgeführt wird. Es stellt Informationen wie ReplicaId, PartitionId, ServiceName usw. bereit.

Gibt zurück:

Ein StatefulServiceContext , der den Dienstkontext beschreibt.

getStateProviderReplica

protected StateProviderReplica getStateProviderReplica()

onAbort

protected void onAbort()

Benachrichtigung, dass der Dienst abgebrochen wird. RunAsync wird möglicherweise gleichzeitig mit der Ausführung dieser Methode ausgeführt, da für den Abbruchpfad kein Abbruch erwartet wird.

onChangeRoleAsync

protected CompletableFuture onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Diese Methode wird als letzter Schritt vor dem Abschließen changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) von aufgerufen. Überschreiben Sie diese Methode, um benachrichtigt zu werden, dass ChangeRole für die internen Komponenten dieses Replikats abgeschlossen wurde.

Parameter:

newRole - für dieses Dienstreplikat.

cancellationToken -

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

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt.

onCloseAsync

protected CompletableFuture onCloseAsync(CancellationToken cancellationToken)

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

Parameter:

cancellationToken -

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

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt.

onDataLossAsync

protected CompletableFuture onDataLossAsync(RestoreContext context, CancellationToken cancellationToken)

Diese Methode wird bei vermutetem Datenverlust aufgerufen. Sie können diese Methode überschreiben, um den Dienst bei Datenverlust wiederherzustellen.

Parameter:

context - Ein RestoreContext , der zum Wiederherstellen des Diensts verwendet werden soll.

cancellationToken -

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

Gibt zurück:

Ein Task, der den asynchronen Wiederherstellungsvorgang darstellt. True gibt an, dass der Zustand wiederhergestellt wurde. False gibt an, dass der Status des Replikats nicht geändert wurde.

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 den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt.

runAsync

protected CompletableFuture runAsync(CancellationToken cancellationToken)

Dienste, die eine Verarbeitungsschleife implementieren möchten, die ausgeführt wird, wenn sie primär ist und über schreibgeschützte status verfügt, überschreiben diese Methode einfach mit ihrer Logik.

Parameter:

cancellationToken -

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

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt.

setAddresses

protected void setAddresses(Map addresses)

Legt die Liste aller Adressen für dieses Dienstreplikat als Schlüssel-Wert-Paar (ListenerName, Endpunkt) fest.

Parameter:

addresses - Ein Map , der die Liste der Adressen als Schlüssel-Wert-Paar (ListenerName, Endpunkt) enthält.

setPartition

protected void setPartition(StatefulServicePartition partition)

Dienstpartition, zu der das aktuelle Dienstreplikat gehört.

Parameter:

partition - Ein StatefulServicePartition , das die Partition darstellt, zu der dieses Dienstreplikat gehört.