Partager via

StatelessServiceBase Classe

  • Référence
Paquet:
microsoft.servicefabric.services.runtime
  • java.lang.Object
    • microsoft.servicefabric.services.runtime.StatelessServiceBase

public class StatelessServiceBase

Représente la classe de base pour le service fiable sans état basé sur Microsoft Service Fabric.

Récapitulatif du constructeur

Constructeur Description
StatelessServiceBase()

Résumé de la méthode

Modificateur et type Méthode et description
List<ServiceInstanceListener> createServiceInstanceListeners()

Remplacez cette méthode pour fournir les écouteurs de communication pour le service instance. Les points de terminaison retournés par l’écouteur de communication sont stockés en tant que chaîne JSON de ListenerName, paires de chaînes de point de terminaison telles que {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}
Map<String, String> getAddresses()

Obtient la liste de toutes les adresses de ces instances de service sous la forme d’une paire clé-valeur (ListenerName, Endpoint).
StatelessServicePartition getPartition()

Obtient la partition de service à laquelle appartient le service actuel instance.
StatelessServiceContext getServiceContext()

Obtient le contexte de service sous lequel ce service sans état fonctionne. Il fournit des informations telles que InstanceId, PartitionId, ServiceName, etc.
void onAbort()

Notification indiquant que le service est en cours d’abandon. RunAsync peut s’exécuter simultanément avec l’exécution de cette méthode, car l’annulation n’est pas attendue sur le chemin d’abandon.

CompletableFuture<?> onCloseAsync(CancellationToken cancellationToken)

Cette méthode est appelée comme l’étape finale de la fermeture du service. Remplacez cette méthode pour être averti que close a terminé pour les composants internes de cette instance.
CompletableFuture<?> onOpenAsync(CancellationToken cancellationToken)

Cette méthode est appelée comme dernière étape de l’ouverture du service. Remplacez cette méthode pour être averti qu’Open a terminé pour les composants internes de cette instance.
CompletableFuture<?> runAsync(CancellationToken cancellationToken)

Les services qui souhaitent implémenter une tâche en arrière-plan qui s’exécute lorsqu’elle est ouverte, remplacent simplement cette méthode par leur logique.
void setAddresses(Map<String, String> addresses)

Définit la liste de toutes les adresses de ce service instance en tant que paire clé-valeur (ListenerName, Endpoint).

Détails du constructeur

StatelessServiceBase

protected StatelessServiceBase()

Détails de la méthode

createServiceInstanceListeners

protected List createServiceInstanceListeners()

Remplacez cette méthode pour fournir les écouteurs de communication pour le service instance. Les points de terminaison retournés par l’écouteur de communication sont stockés en tant que chaîne JSON de ListenerName, paires de chaînes de point de terminaison telles que {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

Retours:

Liste de ServiceInstanceListeners

getAddresses

protected Map getAddresses()

Obtient la liste de toutes les adresses de ces instances de service sous la forme d’une paire clé-valeur (ListenerName, Endpoint).

Retours:

Liste Map contenant des adresses sous la forme d’une paire clé-valeur (ListenerName, Endpoint).

getPartition

protected StatelessServicePartition getPartition()

Obtient la partition de service à laquelle appartient le service actuel instance.

Retours:

StatelessServicePartition qui représente la partition à laquelle appartient ce service réplica.

getServiceContext

public StatelessServiceContext getServiceContext()

Obtient le contexte de service sous lequel ce service sans état fonctionne. Il fournit des informations telles que InstanceId, PartitionId, ServiceName, etc.

Retours:

StatelessServiceContext qui décrit le contexte de service.

onAbort

protected void onAbort()

Notification indiquant que le service est en cours d’abandon. RunAsync peut s’exécuter simultanément avec l’exécution de cette méthode, car l’annulation n’est pas attendue sur le chemin d’abandon.

onCloseAsync

protected CompletableFuture onCloseAsync(CancellationToken cancellationToken)

Cette méthode est appelée comme l’étape finale de la fermeture du service. Remplacez cette méthode pour être averti que close a terminé pour les composants internes de cette instance.

Paramètres:

cancellationToken -

CancellationTokenobjet pour indiquer l’annulation status de l’opération.

Retours:

qui représente une CompletableFuture opération en attente.

onOpenAsync

protected CompletableFuture onOpenAsync(CancellationToken cancellationToken)

Cette méthode est appelée comme dernière étape de l’ouverture du service. Remplacez cette méthode pour être averti qu’Open a terminé pour les composants internes de cette instance.

Paramètres:

cancellationToken -

CancellationTokenobjet pour indiquer l’annulation status de l’opération.

Retours:

qui représente une CompletableFuture opération en attente.

runAsync

protected CompletableFuture runAsync(CancellationToken cancellationToken)

Les services qui souhaitent implémenter une tâche en arrière-plan qui s’exécute lorsqu’elle est ouverte, remplacent simplement cette méthode par leur logique.

Paramètres:

cancellationToken -

CancellationTokenobjet pour indiquer l’annulation status de l’opération.

Retours:

qui représente une CompletableFuture opération en attente.

setAddresses

protected void setAddresses(Map addresses)

Définit la liste de toutes les adresses de ce service instance en tant que paire clé-valeur (ListenerName, Endpoint).

Paramètres:

addresses - Liste Map contenant des adresses sous la forme d’une paire clé-valeur (ListenerName, Endpoint).

S’applique à