Freigeben über

FabricTransportServiceRemotingClientFactory Klasse

  • Referenz
Paket:
microsoft.servicefabric.services.remoting.fabrictransport.client

public class FabricTransportServiceRemotingClientFactory implements ServiceRemotingClientFactory

Eine ServiceRemotingClientFactory , die fabric TCP-Transport verwendet, um zu erstellen ServiceRemotingClient , die mit zustandslosen und zustandsbehafteten Diensten über Schnittstellen kommunizieren, die über FabricTransportServiceRemotingListenerremoted verwendet werden.

Zusammenfassung zum Konstruktor

Konstruktor Beschreibung
FabricTransportServiceRemotingClientFactory(FabricTransportRemotingSettings fabricTransportSettings, ServiceRemotingCallbackClient callbackClient, ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers, String traceId)

Erstellt eine Fabric-transportbasierte Dienstremoting-Clientfactory.

Bemerkungen:Diese Factory verwendet einen internen Fabric-Transport-Ausnahmehandler zum Behandeln von Ausnahmen auf der Fabric-TCP-Transportebene und ein ServiceRemotingExceptionHandler- zusätzlich zu den Ausnahmehandlern, die für den Konstruktor bereitgestellt werden.

Methodenzusammenfassung

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

Löst eine Partition des angegebenen Diensts erneut auf, die mindestens einen Kommunikationslistener enthält, und gibt einen Client zurück, um mit dem Endpunkt zu kommunizieren, der dem angegebenen listenerName entspricht. Der Endpunkt des Diensts hat die Form : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}
CompletableFuture<ServiceRemotingClient> 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, um mit dem Endpunkt zu kommunizieren, der dem angegebenen listenerName entspricht. Der Endpunkt des Diensts hat die Form : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}
CompletableFuture<OperationRetryControl> reportOperationExceptionAsync(ServiceRemotingClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

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

Geerbte Elemente

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

Details zum Konstruktor

FabricTransportServiceRemotingClientFactory

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

Erstellt eine Fabric-transportbasierte Dienstremoting-Clientfactory.

Bemerkungen:Diese Factory verwendet einen internen Fabric-Transport-Ausnahmehandler zum Behandeln von Ausnahmen auf der Fabric-TCP-Transportebene und ein ServiceRemotingExceptionHandler- zusätzlich zu den Ausnahmehandlern, die für den Konstruktor bereitgestellt werden.

Parameter:

fabricTransportSettings - Die Einstellungen für den Fabric-Transport. Wenn die Einstellungen nicht bereitgestellt oder NULL sind, sind Die Standardeinstellungen ohne Sicherheit.
callbackClient - Der Rückrufclient, der die Rückrufe vom Dienst empfängt.
servicePartitionResolver - Dienstpartitionslöser, um die Dienstendpunkte aufzulösen. Wenn nicht angegeben, wird ein von getDefault() zurückgegebener Standard-Dienstpartitionslöser verwendet.
exceptionHandlers - Ausnahmehandler, um die Bei der Kommunikation mit dem Dienst auftretenden Ausnahmen zu behandeln.
traceId - Id, die in Diagnose Ablaufverfolgungen dieser Komponente verwendet werden soll.

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 mindestens einen Kommunikationslistener enthält, und gibt einen Client zurück, um mit dem Endpunkt zu kommunizieren, der dem angegebenen listenerName entspricht. Der Endpunkt des Diensts hat die Form : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Überschreibt:

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

Parameter:

previousRsp - Previous 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:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt. Das Ergebnis des Tasks 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, um mit dem Endpunkt zu kommunizieren, der dem angegebenen listenerName entspricht. Der Endpunkt des Diensts hat die Form : {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Überschreibt:

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

Parameter:

serviceUri - URI des aufzulösenden Diensts
partitionKey - Schlüssel, der die partition identifiziert, die aufgelöst werden soll
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:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt. Das Ergebnis des Tasks ist das CommunicationClient( CommunicationClient) -Objekt.

reportOperationExceptionAsync

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

Verarbeitet 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:

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

Gilt für: