FabricTransportServiceRemotingClientFactory Classe

Paquet:

microsoft.servicefabric.services.remoting.fabrictransport.client

• java.lang.Object
• • CommunicationClientFactory<TCommunicationClient>
  • • ServiceRemotingClientFactory
    • • microsoft.servicefabric.services.remoting.fabrictransport.client.FabricTransportServiceRemotingClientFactory

public class FabricTransportServiceRemotingClientFactory implements ServiceRemotingClientFactory

ServiceRemotingClientFactory qui utilise le transport TCP fabric pour créer ServiceRemotingClient des communications avec des services sans état et avec état via des interfaces distantes via FabricTransportServiceRemotingListener.

Récapitulatif du constructeur

Constructeur	Description
FabricTransportServiceRemotingClientFactory(FabricTransportRemotingSettings fabricTransportSettings, ServiceRemotingCallbackClient callbackClient, ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers, String traceId)	Construit une fabrique de client de communication à distance basée sur le transport de tissu. Remarques:Cette fabrique utilise un gestionnaire d’exceptions de transport d’infrastructure interne pour gérer les exceptions au niveau du transport TCP de l’infrastructure et un ServiceRemotingExceptionHandler, en plus des gestionnaires d’exceptions fournis au constructeur.

Résumé de la méthode

Modificateur et type	Méthode et description
CompletableFuture<ServiceRemotingClient>	getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) Résout à nouveau 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<ServiceRemotingClient>	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 » ...}}
CompletableFuture<OperationRetryControl>	reportOperationExceptionAsync(ServiceRemotingClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings) Gère les exceptions qui se produisent dans CommunicationClient lors de l’envoi d’un message au service

Membres hérités

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

Détails du constructeur

FabricTransportServiceRemotingClientFactory

public FabricTransportServiceRemotingClientFactory(FabricTransportRemotingSettings fabricTransportSettings, ServiceRemotingCallbackClient callbackClient, ServicePartitionResolver servicePartitionResolver, List exceptionHandlers, String traceId)

Construit une fabrique de client de communication à distance basée sur le transport de tissu.

Remarques:Cette fabrique utilise un gestionnaire d’exceptions de transport d’infrastructure interne pour gérer les exceptions au niveau du transport TCP de l’infrastructure et un ServiceRemotingExceptionHandler, en plus des gestionnaires d’exceptions fournis au constructeur.

Paramètres:

fabricTransportSettings - Paramètres du transport de l’infrastructure. Si les paramètres ne sont pas fournis ou null, les paramètres par défaut sans sécurité.

callbackClient - Client de rappel qui reçoit les rappels du service.

servicePartitionResolver - Programme de résolution de partition de service pour résoudre les points de terminaison de service. S’il n’est pas spécifié, un programme de résolution de partition de service par défaut retourné par getDefault() est utilisé.

exceptionHandlers - Gestionnaires d’exceptions pour gérer les exceptions rencontrées lors de la communication avec le service.

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

Détails de la méthode

getClientAsync

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

Résout à nouveau 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 » ...}}

Remplacements:

FabricTransportServiceRemotingClientFactory.getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Paramètres:

previousRsp - Valeur resolvedServicePartition précédente

targetReplicaSelector - Spécifie à quel réplica dans la partition identifiée par la clé de partition, le client doit se connecter

listenerName - Spécifie l’écouteur dans le point de terminaison du réplica choisi, auquel le client doit se connecter

retrySettings - Spécifie la stratégie de nouvelle tentative qui doit être utilisée pour les exceptions qui se produisent lors de la création du client.

Retours:

qui représente une CompletableFuture opération en attente. 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 » ...}}

Remplacements:

FabricTransportServiceRemotingClientFactory.getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Paramètres:

serviceUri - URI du service à résoudre

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

targetReplicaSelector - Spécifie à quel réplica dans la partition identifiée par la clé de partition, le client doit se connecter

listenerName - Spécifie l’écouteur dans le point de terminaison du réplica choisi, auquel le client doit se connecter

retrySettings - Spécifie la stratégie de nouvelle tentative qui doit être utilisée pour les exceptions qui se produisent lors de la création du client.

Retours:

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

reportOperationExceptionAsync

public CompletableFuture reportOperationExceptionAsync(ServiceRemotingClient 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 sur l’exception qui s’est produite lors de la communication avec le service.

retrySettings - Spécifie la stratégie de nouvelle tentative qui doit être utilisée pour gérer l’exception signalée.

Retours:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est un OperationRetryControl objet qui fournit des informations sur la stratégie de nouvelle tentative pour cette exception.