CommunicationClientFactoryBase<T> Classe

Paquet:

microsoft.servicefabric.services.communication.client

• java.lang.Object
• • CommunicationClientFactory<TCommunicationClient>
  • • microsoft.servicefabric.services.communication.client.CommunicationClientFactoryBase<T>

Paramètres de type

T

Type de client de communication

public class CommunicationClientFactoryBase implements CommunicationClientFactory

Fournit l’implémentation de base de CommunicationClientFactory pour créer des clients de communication pour communiquer avec les services Service Fabric. Étendez la classe CommunicationClientFactoryBase pour créer des clients de communication pour des implémentations de transport personnalisées. Cette classe gère un cache de clients de communication et tente de réutiliser les clients pour les demandes adressées au même point de terminaison de service.

Récapitulatif du constructeur

Constructeur	Description
CommunicationClientFactoryBase()	Initialise une nouvelle instance de la fabrique du client de communication.
CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers)	Initialise une nouvelle instance de la fabrique du client de communication.
CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers, String traceId)	Initialise une nouvelle instance de la fabrique du client de communication.

Résumé de la méthode

Modificateur et type	Méthode et description
abstract void	abortClient(T client) Abandonne le client donné
abstract CompletableFuture<T>	createClientAsync(String endpoint)
CompletableFuture<T>	getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) Résout une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est au format {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}
CompletableFuture<T>	getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) Résout une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est au format {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}
List<ExceptionHandler>	getExceptionHandlers() Obtient les gestionnaires d’exceptions personnalisés pour la gestion des exceptions sur le canal de communication client-service.
ServicePartitionResolver	getServiceResolver() Obtient le ServicePartitionResolver utilisé par la fabrique cliente pour résoudre le point de terminaison de service.
String	getTraceId() Obtient l’identificateur de trace utilisé pour identifier un instance de CommunicationClientFactory. Il est utilisé comme identificateur de corrélation pour le suivi/journalisation.
CompletableFuture<OperationRetryControl>	reportOperationExceptionAsync(T client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings) Gère les exceptions qui se produisent dans CommunicationClient lors de l’envoi d’un message au service
abstract boolean	validateClient(String endpoint, T client) Retourne true si le client est toujours valide et connecté au point de terminaison spécifié dans le paramètre.
abstract boolean	validateClient(T client) Retourne true si le client est toujours valide. Les transports orientés connexion peuvent utiliser cette méthode pour indiquer que le client n’est plus connecté au service.

Membres hérités

CommunicationClientFactory<TCommunicationClient>.reportOperationExceptionAsync(TCommunicationClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

Détails du constructeur

CommunicationClientFactoryBase

protected CommunicationClientFactoryBase()

Initialise une nouvelle instance de la fabrique du client de communication.

CommunicationClientFactoryBase

protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List exceptionHandlers)

Initialise une nouvelle instance de la fabrique du client de communication.

Paramètres:

servicePartitionResolver - ServicePartitionResolver facultatif

exceptionHandlers - Gestionnaires d’exceptions personnalisés facultatifs pour les exceptions sur le canal de communication client à service

CommunicationClientFactoryBase

protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List exceptionHandlers, String traceId)

Initialise une nouvelle instance de la fabrique du client de communication.

Paramètres:

servicePartitionResolver - ServicePartitionResolver facultatif

exceptionHandlers - Gestionnaires d’exceptions personnalisés facultatifs pour les exceptions sur le canal de communication client à service

traceId - ID à utiliser dans diagnostics traces de ce composant.

Détails de la méthode

abortClient

protected abstract void abortClient(T client)

Abandonne le client donné

Paramètres:

client - Client de communication

createClientAsync

protected abstract CompletableFuture createClientAsync(String endpoint)

Paramètres:

endpoint

getClientAsync

public CompletableFuture getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Résout une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est au format {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

Paramètres:

previousRsp - Précédente ResolvedServicePartition

targetReplicaSelector -

TargetReplicaSelector

listenerName - Nom de l’écouteur

retrySettings - paramètres de nouvelle tentative

Retours:

CompletableFuture qui représente l’opération en cours. Le résultat de la tâche est l’objet CommunicationClient(CommunicationClient).

getClientAsync

public CompletableFuture getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Résout une partition du service spécifié contenant un ou plusieurs écouteurs de communication et retourne un client pour communiquer avec le point de terminaison correspondant à l’écouteurName donné. Le point de terminaison du service est au format {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}

Paramètres:

serviceUri - URI du service à résoudre

partitionKey - Clé qui identifie la partition à résoudre

targetReplicaSelector -

TargetReplicaSelector

listenerName - Nom de l’écouteur

retrySettings - paramètres de nouvelle tentative

Retours:

CompletableFuture qui représente l’opération en cours. Le résultat de la tâche est l’objet CommunicationClient(CommunicationClient).

getExceptionHandlers

public List getExceptionHandlers()

Obtient les gestionnaires d’exceptions personnalisés pour la gestion des exceptions sur le canal de communication client-service.

Retours:

Liste des gestionnaires d’exceptions

getServiceResolver

public ServicePartitionResolver getServiceResolver()

Obtient le ServicePartitionResolver utilisé par la fabrique cliente pour résoudre le point de terminaison de service.

Retours:

ServicePartitionResolver

getTraceId

protected String getTraceId()

Obtient l’identificateur de trace utilisé pour identifier un instance de CommunicationClientFactory. Il est utilisé comme identificateur de corrélation pour le suivi/journalisation.

Retours:

Identificateur de trace

reportOperationExceptionAsync

public CompletableFuture reportOperationExceptionAsync(T client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

Gère les exceptions qui se produisent dans CommunicationClient lors de l’envoi d’un message au service

Paramètres:

client - Client de communication

exceptionInformation - informations d’exception

retrySettings - paramètres de nouvelle tentative

Retours:

CompletableFuture qui représente l’opération en cours. Le résultat de la tâche est un OperationRetryControl objet qui détermine la façon dont la stratégie de nouvelle tentative pour cette exception.

validateClient

protected abstract boolean validateClient(String endpoint, T client)

Retourne true si le client est toujours valide et connecté au point de terminaison spécifié dans le paramètre.

Paramètres:

endpoint - point de terminaison

client - client de communication

Retours:

true si le client est valide, false sinon

validateClient

protected abstract boolean validateClient(T client)

Retourne true si le client est toujours valide. Les transports orientés connexion peuvent utiliser cette méthode pour indiquer que le client n’est plus connecté au service.

Paramètres:

client - client de communication

Retours:

true si le client est valide, false sinon