Freigeben über

StatelessServiceBase Klasse

  • Referenz
Paket:
microsoft.servicefabric.services.runtime
  • java.lang.Object
    • microsoft.servicefabric.services.runtime.StatelessServiceBase

public class StatelessServiceBase

Stellt die Basisklasse für den auf Microsoft Service Fabric basierenden zustandslosen zuverlässigen Dienst dar.

Zusammenfassung zum Konstruktor

Konstruktor Beschreibung
StatelessServiceBase()

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
List<ServiceInstanceListener> createServiceInstanceListeners()

Überschreiben Sie diese Methode, um die Kommunikationslistener für den Dienst instance. Die vom Kommunikationslistener zurückgegebenen Endpunkte werden als JSON-Zeichenfolge von ListenerName und Endpunktzeichenfolgenpaaren wie {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} gespeichert.
Map<String, String> getAddresses()

Ruft eine Liste aller Adressen für diese Dienstinstanzen als Schlüssel-Wert-Paar (ListenerName, Endpunkt) ab.
StatelessServicePartition getPartition()

Ruft die Dienstpartition ab, zu der instance des aktuellen Diensts gehört.
StatelessServiceContext getServiceContext()

Ruft den Dienstkontext ab, unter dem dieser zustandslose Dienst ausgeführt wird. Es stellt Informationen wie InstanceId, PartitionId, ServiceName usw. bereit.
void onAbort()

Benachrichtigung, dass der Dienst abgebrochen wird. RunAsync kann gleichzeitig mit der Ausführung dieser Methode ausgeführt werden, da der Abbruch für den Abbruchpfad nicht erwartet wird.

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 instance abgeschlossen wurde.
CompletableFuture<?> onOpenAsync(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 instance abgeschlossen wurde.
CompletableFuture<?> runAsync(CancellationToken cancellationToken)

Dienste, die eine Hintergrundaufgabe implementieren möchten, die beim Öffnen ausgeführt wird, überschreiben diese Methode einfach mit ihrer Logik.
void setAddresses(Map<String, String> addresses)

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

Details zum Konstruktor

StatelessServiceBase

protected StatelessServiceBase()

Details zur Methode

createServiceInstanceListeners

protected List createServiceInstanceListeners()

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

Gibt zurück:

Liste der ServiceInstanceListener

getAddresses

protected Map getAddresses()

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

Gibt zurück:

Eine Map Liste der Adressen als Schlüssel-Wert-Paar (ListenerName, Endpunkt).

getPartition

protected StatelessServicePartition getPartition()

Ruft die Dienstpartition ab, zu der instance des aktuellen Diensts gehört.

Gibt zurück:

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

getServiceContext

public StatelessServiceContext getServiceContext()

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

Gibt zurück:

Eine StatelessServiceContext , die den Dienstkontext beschreibt.

onAbort

protected void onAbort()

Benachrichtigung, dass der Dienst abgebrochen wird. RunAsync kann gleichzeitig mit der Ausführung dieser Methode ausgeführt werden, da der Abbruch für den Abbruchpfad nicht erwartet wird.

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 instance abgeschlossen wurde.

Parameter:

cancellationToken -

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

Gibt zurück:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt.

onOpenAsync

protected CompletableFuture onOpenAsync(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 instance abgeschlossen wurde.

Parameter:

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)

Dienste, die eine Hintergrundaufgabe implementieren möchten, die beim Öffnen ausgeführt wird, überschreiben diese Methode einfach mit ihrer Logik.

Parameter:

cancellationToken -

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

Gibt zurück:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt.

setAddresses

protected void setAddresses(Map addresses)

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

Parameter:

addresses - Eine Map Liste der Adressen als Schlüssel-Wert-Paar (ListenerName, Endpunkt).

Gilt für: