FabricServicePartitionClient<C> Klasse

Paket:

microsoft.servicefabric.services.communication.client

• java.lang.Object
• • ServicePartitionClient<TCommunicationClient>
  • • microsoft.servicefabric.services.communication.client.FabricServicePartitionClient<C>

Typparameter

C

Typ des Kommunikationsclients

public class FabricServicePartitionClient implements ServicePartitionClient

Gibt einen instance des Kommunikationsclients an, der mit den Replikaten einer bestimmten Partition kommunizieren kann.

Zusammenfassung zum Konstruktor

Konstruktor	Beschreibung
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName)	Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Durch das Dienst-URI-Argument identifizierten Dienstendpunkt zu erstellen.
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey)	Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch den Dienst-URI (Partitionkey-Argumente) identifiziert wird.
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector)	Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch die Argumente Dienst-URI, Partitionsschlüssel und Replikatauswahl identifiziert wird.
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName)	Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch die Argumente Dienst-URI, Partitionsschlüssel, Replikat und Listener identifiziert wird.
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)	Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch die Argumente Dienst-URI, Partitionsschlüssel, Replikat und Listener identifiziert wird.

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
CommunicationClientFactory<C>	getCommunicationClientFactory() Ruft die Kommunikationsclientfactory ab.
ResolvedServicePartition	getLastResolvedServicePartition() Ruft die aufgelöste Dienstpartition ab, die auf dem Client festgelegt wurde.
String	getListenerName() Ruft den Namen des Listeners im Replikat ab, mit dem der Client eine Verbindung herstellen soll.
ServicePartitionKey	getPartitionKey() Ruft den Partitionsschlüssel ab.
URI	getServiceUri() Ruft den Namen des Diensts ab.
TargetReplicaSelector	getTargetReplicaSelector() Ruft die Informationen darüber ab, mit welchem Replikat in der Partition der Client eine Verbindung herstellen soll.
<T> CompletableFuture<T>	invokeWithRetryAsync(Function<C, CompletableFuture<T>> func, CancellationToken cancellationToken, Class<?>... doNotRetryExceptionTypes) Ruft die angegebene Funktion auf und versucht, ausnahmen zu suchen, die nicht in den doNotRetryExceptionTypes ausgelöst werden. Für Ausnahmen, die nicht in doNotRetryExceptionTypes enthalten sind, steuert die ReportOperationExceptionAsync()-Methode von CommunicationClientFactory, ob die Ausnahme wiederholt werden soll.
<T> CompletableFuture<T>	invokeWithRetryAsync(Function<C, CompletableFuture<T>> func, Class<?>... doNotRetryExceptionTypes) Ruft die angegebene Funktion auf und versucht, ausnahmen zu suchen, die nicht in den doNotRetryExceptionTypes ausgelöst werden. Für Ausnahmen, die nicht in doNotRetryExceptionTypes enthalten sind, steuert die ReportOperationExceptionAsync()-Methode von CommunicationClientFactory, ob die Ausnahme wiederholt werden soll.

Details zum Konstruktor

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName)

Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Durch das Dienst-URI-Argument identifizierten Dienstendpunkt zu erstellen.

Parameter:

factory - Communication Client Factory

serviceName - Name des Diensts

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey)

Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch den Dienst-URI (Partitionkey-Argumente) identifiziert wird.

Parameter:

factory - Communication Client Factory

serviceName - Name des Diensts

partitionKey - Der Partitionsschlüssel, der zum Identifizieren der Partition innerhalb des Diensts verwendet wird.

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector)

Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch die Argumente Dienst-URI, Partitionsschlüssel und Replikatauswahl identifiziert wird.

Parameter:

factory - Communication Client Factory

serviceName - Name des Diensts

partitionKey - Der Partitionsschlüssel, der zum Identifizieren der Partition innerhalb des Diensts verwendet wird.

targetReplicaSelector - Zielreplikatinformationen

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName)

Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch die Argumente Dienst-URI, Partitionsschlüssel, Replikat und Listener identifiziert wird.

Parameter:

factory - Communication Client Factory

serviceName - Name des Diensts

partitionKey - Der Partitionsschlüssel, der zum Identifizieren der Partition innerhalb des Diensts verwendet wird.

targetReplicaSelector - Zielreplikatinformationen

listenerName - Listener im Replikat, mit dem der Client eine Verbindung herstellen soll

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Instanziiert einen Dienstpartitionsclient, der die angegebene Kommunikationsclientfactory verwendet, um einen Client für die Kommunikation mit dem Dienstendpunkt zu erstellen, der durch die Argumente Dienst-URI, Partitionsschlüssel, Replikat und Listener identifiziert wird.

Parameter:

factory - Communication Client Factory

serviceName - Name des Diensts

partitionKey - Der Partitionsschlüssel, der zum Identifizieren der Partition innerhalb des Diensts verwendet wird.

targetReplicaSelector - Zielreplikatinformationen

listenerName - Listener im Replikat, mit dem der Client eine Verbindung herstellen soll

retrySettings - Wiederholungsrichtlinie für Ausnahmen, die während der Kommunikation auftreten

Details zur Methode

getCommunicationClientFactory

public CommunicationClientFactory getCommunicationClientFactory()

Ruft die Kommunikationsclientfactory ab.

Gibt zurück:

Communication Client Factory

getLastResolvedServicePartition

public ResolvedServicePartition getLastResolvedServicePartition()

Ruft die aufgelöste Dienstpartition ab, die auf dem Client festgelegt wurde.

Gibt zurück:

TRUE, wenn eine ResolvedServicePartition festgelegt wurde

getListenerName

public String getListenerName()

Ruft den Namen des Listeners im Replikat ab, mit dem der Client eine Verbindung herstellen soll.

Gibt zurück:

Name des Listeners

getPartitionKey

public ServicePartitionKey getPartitionKey()

Ruft den Partitionsschlüssel ab.

Gibt zurück:

Partitionsschlüssel

getServiceUri

public URI getServiceUri()

Ruft den Namen des Diensts ab.

Gibt zurück:

Name des Diensts

getTargetReplicaSelector

public TargetReplicaSelector getTargetReplicaSelector()

Ruft die Informationen darüber ab, mit welchem Replikat in der Partition der Client eine Verbindung herstellen soll.

Gibt zurück:

Eine TargetReplicaSelector

invokeWithRetryAsync

public CompletableFuture invokeWithRetryAsync(Function> func, CancellationToken cancellationToken, Class... doNotRetryExceptionTypes)

Ruft die angegebene Funktion auf und versucht, ausnahmen zu suchen, die nicht in den doNotRetryExceptionTypes ausgelöst werden. Für Ausnahmen, die nicht in doNotRetryExceptionTypes enthalten sind, steuert die ReportOperationExceptionAsync()-Methode von CommunicationClientFactory, ob die Ausnahme wiederholt werden soll.

Parameter:

func - Aufgerufene Funktion

cancellationToken - Token, um den Abbruch des asynchronen Vorgangs zu signalisieren.

doNotRetryExceptionTypes - Ausnahmen, für die der Dienstpartitionsclient nicht erneut versuchen sollte

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt. Das Ergebnis der Aufgabe ist das Ergebnis der im Argument angegebenen Funktion.

invokeWithRetryAsync

public CompletableFuture invokeWithRetryAsync(Function> func, Class... doNotRetryExceptionTypes)

Ruft die angegebene Funktion auf und versucht, ausnahmen zu suchen, die nicht in den doNotRetryExceptionTypes ausgelöst werden. Für Ausnahmen, die nicht in doNotRetryExceptionTypes enthalten sind, steuert die ReportOperationExceptionAsync()-Methode von CommunicationClientFactory, ob die Ausnahme wiederholt werden soll.

Parameter:

func - Aufgerufene Funktion

doNotRetryExceptionTypes - Ausnahmen, für die der Dienstpartitionsclient nicht erneut versuchen sollte

Gibt zurück:

Ein CompletableFuture , der einen ausstehenden Vorgang darstellt. Das Ergebnis der Aufgabe ist das Ergebnis der im Argument angegebenen Funktion.