Freigeben über


CommunicationClientFactory<TCommunicationClient> Schnittstelle

Typparameter

TCommunicationClient

public interface CommunicationClientFactory

Definiert die Schnittstelle, die implementiert werden muss, um eine Factory bereitzustellen, damit Kommunikationsclients mit einem Service Fabric-Dienst kommunizieren können.

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
CompletableFuture<TCommunicationClient> getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Löst eine Partition des angegebenen Diensts erneut auf, die einen oder mehrere Kommunikationslistener enthält, und gibt einen Client zurück, der mit dem Endpunkt kommuniziert, der dem angegebenen listenerName entspricht. Der Endpunkt des Diensts hat das Format : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

CompletableFuture<TCommunicationClient> getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Löst eine Partition des angegebenen Diensts auf, die einen oder mehrere Kommunikationslistener enthält, und gibt einen Client zurück, der mit dem Endpunkt kommuniziert, der dem angegebenen ListenerName entspricht. Der Endpunkt des Diensts hat das Format : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

CompletableFuture<OperationRetryControl> reportOperationExceptionAsync(TCommunicationClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

Behandelt die Ausnahmen, die im CommunicationClient auftreten, wenn eine Nachricht an den Dienst gesendet wird

Details zur Methode

getClientAsync

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

Löst eine Partition des angegebenen Diensts erneut auf, die einen oder mehrere Kommunikationslistener enthält, und gibt einen Client zurück, der mit dem Endpunkt kommuniziert, der dem angegebenen listenerName entspricht. Der Endpunkt des Diensts hat das Format : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Parameter:

previousRsp - Vorheriger ResolvedServicePartition-Wert
targetReplicaSelector - Gibt an, mit welchem Replikat in der Partition, die durch den Partitionsschlüssel identifiziert wird, der Client eine Verbindung herstellen soll.
listenerName - Gibt an, welcher Listener im Endpunkt des ausgewählten Replikats, mit dem der Client eine Verbindung herstellen soll
retrySettings - Gibt die Wiederholungsrichtlinie an, die für Ausnahmen verwendet werden soll, die beim Erstellen des Clients auftreten.

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt. Das Ergebnis der Aufgabe ist das CommunicationClient(CommunicationClient)-Objekt.

getClientAsync

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

Löst eine Partition des angegebenen Diensts auf, die einen oder mehrere Kommunikationslistener enthält, und gibt einen Client zurück, der mit dem Endpunkt kommuniziert, der dem angegebenen ListenerName entspricht. Der Endpunkt des Diensts hat das Format : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Parameter:

serviceUri - URI des aufzulösenden Diensts
partitionKey - Schlüssel, der die aufzulösde Partition identifiziert
targetReplicaSelector - Gibt an, mit welchem Replikat in der Partition, die durch den Partitionsschlüssel identifiziert wird, der Client eine Verbindung herstellen soll.
listenerName - Gibt an, welcher Listener im Endpunkt des ausgewählten Replikats, mit dem der Client eine Verbindung herstellen soll
retrySettings - Gibt die Wiederholungsrichtlinie an, die für Ausnahmen verwendet werden soll, die beim Erstellen des Clients auftreten.

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt. Das Ergebnis der Aufgabe ist das CommunicationClient(CommunicationClient)-Objekt.

reportOperationExceptionAsync

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

Behandelt die Ausnahmen, die im CommunicationClient auftreten, wenn eine Nachricht an den Dienst gesendet wird

Parameter:

client - Kommunikationsclient
exceptionInformation - Informationen zu Ausnahmen, die während der Kommunikation mit dem Dienst aufgetreten sind.
retrySettings - Gibt die Wiederholungsrichtlinie an, die für die Behandlung der gemeldeten Ausnahme verwendet werden soll.

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt. Das Ergebnis der Aufgabe ist ein OperationRetryControl -Objekt, das Informationen zur Wiederholungsrichtlinie für diese Ausnahme bereitstellt.

Gilt für: