FabricActorService Classe

Paquet:

microsoft.servicefabric.actors.runtime

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

public class FabricActorService extends StatefulServiceBase implements ActorService

Représente la classe de base pour le service d’acteurs fiables basé sur Microsoft Service Fabric.

Remarques:Dérivez de cette classe pour implémenter votre propre service d’acteur personnalisé si vous souhaitez remplacer tout comportement de niveau de service pour vos acteurs.

Récapitulatif du constructeur

Constructeur	Description
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)	Initialise une nouvelle instance de la classe ActorService.
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory)	Initialise une nouvelle instance de la classe ActorService.
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory, BiFunction<ActorBase, ActorStateProvider, ActorStateManager> stateManagerFactory, ActorStateProvider stateProvider, ActorServiceSettings settings)	Initialise une nouvelle instance de la classe ActorService.

Résumé de la méthode

Modificateur et type	Méthode et description
List<ServiceReplicaListener>	createServiceReplicaListeners() Crée des écouteurs de réplica de service.
CompletableFuture<?>	deleteActorAsync(ActorId actorId, CancellationToken cancellationToken) Supprime un acteur du service Actor. Un acteur actif est désactivé et son état est également supprimé du fournisseur d’état. L’état d’un acteur actif est supprimé du fournisseur d’état. Si cette méthode est appelée pour un ID d’acteur inexistant dans le système, il s’agit d’une opération non opérationnelle.
CompletableFuture<PagedResult<ActorInformation>>	getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken) Obtient la liste des acteurs en interrogeant le service d’acteur.
ActorTypeInformation	getActorTypeInformation() Obtient ActorTypeInformation pour le service actor.
ActorServiceSettings	getSettings() Obtient les paramètres du service d’acteur.
ActorStateProvider	getStateProvider() Obtient un ActorStateProvider qui représente le fournisseur d’état du service acteur.
void	onAbort() Substitue onAbort()
CompletableFuture<?>	onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) Substitue onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)
CompletableFuture<?>	onCloseAsync(CancellationToken cancellationToken) Substitue onCloseAsync(CancellationToken cancellationToken)
CompletableFuture<?>	onOpenAsync(ReplicaOpenMode openMode, 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 est terminé pour les composants internes de cette réplica.
CompletableFuture<?>	runAsync(CancellationToken cancellationToken) Substitue runAsync(CancellationToken cancellationToken)

Membres hérités

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)

Détails du constructeur

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)

Initialise une nouvelle instance de la classe ActorService.

Paramètres:

context - Contexte de service sous lequel le service d’acteur fonctionne.

actorTypeInfo - Informations de type de l’acteur.

FabricActorService

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

Initialise une nouvelle instance de la classe ActorService.

Paramètres:

context - Contexte de service sous lequel le service d’acteur fonctionne.

actorTypeInfo - Informations de type de l’acteur.

actorFactory - Méthode de fabrique pour créer des objets d’acteur.

FabricActorService

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

Initialise une nouvelle instance de la classe ActorService.

Paramètres:

context - Contexte de service sous lequel le service d’acteur fonctionne.

actorTypeInfo - Informations de type de l’acteur.

actorFactory - Méthode de fabrique pour créer des objets d’acteur.

stateManagerFactory - Méthode de fabrique pour créer ActorStateManager.

stateProvider - Fournisseur d’état pour stocker l’état des objets d’acteur.

settings - Paramètres pour configurer le comportement d’Actor Service.

Détails de la méthode

createServiceReplicaListeners

protected List createServiceReplicaListeners()

Crée des écouteurs de réplica de service.

Retours:

Paires de chaînes de point de terminaison telles que {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

deleteActorAsync

public CompletableFuture deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

Supprime un acteur du service Actor.

Un acteur actif est désactivé et son état est également supprimé du fournisseur d’état. L’état d’un acteur actif est supprimé du fournisseur d’état. Si cette méthode est appelée pour un ID d’acteur inexistant dans le système, il s’agit d’une opération non opérationnelle.

Remplacements:

FabricActorService.deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

Paramètres:

actorId -

ActorId de l’acteur à supprimer.

cancellationToken -

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

Retours:

Tâche qui représente l’opération asynchrone d’appel au serveur.

getActorsAsync

public CompletableFuture> getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

Obtient la liste des acteurs en interrogeant le service d’acteur.

Remplacements:

FabricActorService.getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

Paramètres:

continuationToken - Jeton de continuation à partir duquel commencer à interroger les résultats. Une valeur null de jeton de continuation signifie que commencez à retourner des valeurs au début.

cancellationToken -

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

Retours:

CompletableFuture qui représente l’opération asynchrone d’appel au serveur.

getActorTypeInformation

public ActorTypeInformation getActorTypeInformation()

Obtient ActorTypeInformation pour le service actor.

Retours:

ActorTypeInformationpour l’acteur hébergé par le réplica de service.

getSettings

public ActorServiceSettings getSettings()

Obtient les paramètres du service d’acteur.

Retours:

Paramètres du service d’acteur.

getStateProvider

public ActorStateProvider getStateProvider()

Obtient un ActorStateProvider qui représente le fournisseur d’état du service acteur.

Retours:

ActorStateProvider représentant le fournisseur d’état pour le service acteur.

onAbort

protected void onAbort()

Substitue onAbort()

onChangeRoleAsync

protected CompletableFuture onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Substitue onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Paramètres:

newRole - Nouveau rôle pour le réplica.

cancellationToken -

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

Retours:

Tâche qui représente l’opération asynchrone effectuée lorsque le réplica devient principal.

onCloseAsync

protected CompletableFuture onCloseAsync(CancellationToken cancellationToken)

Substitue onCloseAsync(CancellationToken cancellationToken)

Paramètres:

cancellationToken - Jeton pour surveiller les requêtes d'annulation.

Retours:

Tâche qui représente l’opération asynchrone effectuée lorsque le réplica est fermé.

onOpenAsync

protected CompletableFuture onOpenAsync(ReplicaOpenMode openMode, 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 est terminé pour les composants internes de cette réplica.

Paramètres:

openMode - pour ce réplica de service.

cancellationToken -

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

Retours:

qui représente l’opération CompletableFuture en suspens.

runAsync

protected CompletableFuture runAsync(CancellationToken cancellationToken)

Substitue runAsync(CancellationToken cancellationToken)

Paramètres:

cancellationToken -

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

Retours:

Tâche qui représente l’opération asynchrone de chargement des rappels lorsque le réplica devient principal.