Freigeben über

FabricServicePartitionResolver Klasse

  • Referenz
Paket:
microsoft.servicefabric.services.client

public class FabricServicePartitionResolver implements ServicePartitionResolver

Implementiert die -Klasse, die bei der Bestimmung des Endpunkts eines Diensts hilft. Diese Klasse umschließt die FabricClient-Methode system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(java.net.URI) und implementiert einen Back-Off-/Wiederholungsmechanismus für Fehler dieser Methode.

Feldzusammenfassung

Modifizierer und Typ Feld und Beschreibung
final Duration defaultMaxRetryBackoffInterval

Dies ist das standardmäßige maximale Wiederholungsbackoffintervall, das von der ResolveAsync-Methode von ServicePartitionResolver verwendet wird, wenn es aufgerufen wird, ohne explizit das Argument maxRetryBackoffInterval anzugeben.

final Duration defaultResolveTimeout

Dies ist das standardmäßige Auflösungstimeout pro Versuch, das von der ResolveAsync-Methode ServicePartitionResolver verwendet wird, wenn es aufgerufen wird, ohne explizit das Argument resolveTimeoutPerTry anzugeben.

Zusammenfassung zum Konstruktor

Konstruktor Beschreibung
FabricServicePartitionResolver(FabricClientSettings settings, String... connectionEndpoints)

Instanziiert einen ServicePartitionResolver, verwendet die angegebenen FabricClient-Einstellungen und die connectionEndpoints, um eine neue instance von FabricClient zu erstellen.
FabricServicePartitionResolver(String... connectionEndpoints)

Instanziiert einen ServicePartitionResolver und verwendet die angegebenen connectionEndpoints, um eine neue instance von FabricClient zu erstellen.
FabricServicePartitionResolver(Supplier<FabricClient> createFabricClient)

Instanziiert einen ServicePartitionResolver, indem der angegebene Delegat aufgerufen wird, um FabricClient zu instanziieren.
FabricServicePartitionResolver(Supplier<FabricClient> createFabricClient, Supplier<FabricClient> recreateFabricClient)

Instanziiert einen ServicePartionResolver, indem der erste Delegat aufgerufen wird, um FabricClient zu instanziieren. Wenn bei der Partitionsauflösung das FabricClient-Objekt verworfen und der zweite Delegat bereitgestellt wird, wird der zweite Delegat verwendet, um den FabricClient neu zu erstellen. Der zweite Delegat bietet eine Möglichkeit, eine alternative Möglichkeit zum Erstellen von FabricClient anzugeben, wenn FabricClient, die mit ersten Delegaten erstellt wurde, entfernt wird.

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
ServicePartitionResolver getDefault()

Ruft den Standardmäßigen ServicePartitionResolver ab.
Duration getResolveTimeout()
Duration getRetryBackoffInterval()
CompletableFuture<ResolvedServicePartition> resolveAsync(ResolvedServicePartition previousRsp)

Löst eine Partition des angegebenen Diensts auf, indem die FabricClient-Methode system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) mit Back-Off-/Wiederholungsfehlern aufgerufen wird. Dies übernimmt die aufgelöste Dienstpartition, die über einen früheren Aufruf der ResolveAsync()-Methode abgerufen wurde. Diese API-Überladung wird in Fällen verwendet, in denen der Client weiß, dass die aufgelöste Dienstpartition, über die er verfügt, nicht mehr gültig ist.
CompletableFuture<ResolvedServicePartition> resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Löst eine Partition des angegebenen Diensts mit Backoff-/Wiederholungsfehlern auf. Dies übernimmt die aufgelöste Dienstpartition, die über einen früheren Aufruf der ResolveAsync()-Methode abgerufen wurde. Diese API-Überladung wird in Fällen verwendet, in denen der Client weiß, dass die aufgelöste Dienstpartition, über die er verfügt, nicht mehr gültig ist.
CompletableFuture<ResolvedServicePartition> resolveAsync(URI serviceUri, ServicePartitionKey partitionKey)

Löst eine Partition des angegebenen Diensts auf, indem die FabricClient-Methode system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)mit Back-Off-/Wiederholungsfehlern aufgerufen wird.
CompletableFuture<ResolvedServicePartition> resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Löst eine Partition des angegebenen Diensts durch Aufrufen system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) der Methode mit Back-off/Wiederholungsfehlern auf.
void setDefault(ServicePartitionResolver defaultServiceResolver)

Updates der Standardeinstellung ServicePartitionResolver
void setResolveTimeout(Duration resolveTimeout)
void setRetryBackoffInterval(Duration retryBackoffInterval)

Felddetails

defaultMaxRetryBackoffInterval

public static final Duration defaultMaxRetryBackoffInterval= Duration.ofSeconds(5)

Dies ist das standardmäßige maximale Wiederholungsbackoffintervall, das von der ResolveAsync-Methode von ServicePartitionResolver verwendet wird, wenn es aufgerufen wird, ohne explizit das Argument maxRetryBackoffInterval anzugeben.

defaultResolveTimeout

public static final Duration defaultResolveTimeout= Duration.ofSeconds(30)

Dies ist das standardmäßige Auflösungstimeout pro Versuch, das von der ResolveAsync-Methode ServicePartitionResolver verwendet wird, wenn es aufgerufen wird, ohne explizit das Argument resolveTimeoutPerTry anzugeben.

Details zum Konstruktor

FabricServicePartitionResolver

public FabricServicePartitionResolver(FabricClientSettings settings, String... connectionEndpoints)

Instanziiert einen ServicePartitionResolver, verwendet die angegebenen FabricClient-Einstellungen und die connectionEndpoints, um eine neue instance von FabricClient zu erstellen.

Parameters:

settings - Fabric-Clienteinstellungen
connectionEndpoints - Array von Verwaltungsendpunkten des Clusters

FabricServicePartitionResolver

public FabricServicePartitionResolver(String... connectionEndpoints)

Instanziiert einen ServicePartitionResolver und verwendet die angegebenen connectionEndpoints, um eine neue instance von FabricClient zu erstellen.

Parameters:

connectionEndpoints - Array von Verwaltungsendpunkten des Clusters

FabricServicePartitionResolver

public FabricServicePartitionResolver(Supplier createFabricClient)

Instanziiert einen ServicePartitionResolver, indem der angegebene Delegat aufgerufen wird, um FabricClient zu instanziieren.

Parameters:

createFabricClient - Delegat zum Erstellen eines Fabricclients

FabricServicePartitionResolver

public FabricServicePartitionResolver(Supplier createFabricClient, Supplier recreateFabricClient)

Instanziiert einen ServicePartionResolver, indem der erste Delegat aufgerufen wird, um FabricClient zu instanziieren. Wenn bei der Partitionsauflösung das FabricClient-Objekt verworfen und der zweite Delegat bereitgestellt wird, wird der zweite Delegat verwendet, um den FabricClient neu zu erstellen. Der zweite Delegat bietet eine Möglichkeit, eine alternative Möglichkeit zum Erstellen von FabricClient anzugeben, wenn FabricClient, die mit ersten Delegaten erstellt wurde, entfernt wird.

Parameters:

createFabricClient - Delegat zum Erstellen eines Fabricclients
recreateFabricClient - Delegat zum Erstellen eines Fabricclients

Details zur Methode

getDefault

public static ServicePartitionResolver getDefault()

Ruft den Standardmäßigen ServicePartitionResolver ab.

Returns:

getResolveTimeout

public Duration getResolveTimeout()

getRetryBackoffInterval

public Duration getRetryBackoffInterval()

resolveAsync

public CompletableFuture resolveAsync(ResolvedServicePartition previousRsp)

Löst eine Partition des angegebenen Diensts auf, indem die FabricClient-Methode system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) mit Back-Off-/Wiederholungsfehlern aufgerufen wird. Dies übernimmt die aufgelöste Dienstpartition, die über einen früheren Aufruf der ResolveAsync()-Methode abgerufen wurde. Diese API-Überladung wird in Fällen verwendet, in denen der Client weiß, dass die aufgelöste Dienstpartition, über die er verfügt, nicht mehr gültig ist.

Parameters:

previousRsp - Vorherige aufgelöste Dienstpartition

Returns:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt. Das Ergebnis aus dem Task ist das ResolvedServicePartition -Objekt, das die Informationen zur aufgelösten Dienstpartition einschließlich der Dienstendpunkte enthält.

resolveAsync

public CompletableFuture resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Löst eine Partition des angegebenen Diensts mit Backoff-/Wiederholungsfehlern auf. Dies übernimmt die aufgelöste Dienstpartition, die über einen früheren Aufruf der ResolveAsync()-Methode abgerufen wurde. Diese API-Überladung wird in Fällen verwendet, in denen der Client weiß, dass die aufgelöste Dienstpartition, über die er verfügt, nicht mehr gültig ist.

Overrides:

FabricServicePartitionResolver.resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Parameters:

previousRsp - Vorherige aufgelöste Dienstpartition
resolveTimeoutPerTry - Das an die ServiceManagementClient::resolveServicePartitionAsync(URI)-Methode übergebene Timeout
maxRetryBackoffInterval - Das Intervall für das Back-off vor dem Wiederholen, wenn bei der Auflösung der Dienstpartition ein Fehler auftritt, mit einer wiederholungsfähigen Ausnahme.

Returns:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt. Das Ergebnis aus dem Task ist das ResolvedServicePartition -Objekt, das die Informationen zur aufgelösten Dienstpartition einschließlich der Dienstendpunkte enthält.

resolveAsync

public CompletableFuture resolveAsync(URI serviceUri, ServicePartitionKey partitionKey)

Löst eine Partition des angegebenen Diensts auf, indem die FabricClient-Methode system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)mit Back-Off-/Wiederholungsfehlern aufgerufen wird.

Parameters:

serviceUri - URI des aufzulösenden Diensts
partitionKey - Schlüssel, der die partition identifiziert, die aufgelöst werden soll

Returns:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt. Das Ergebnis aus dem Task ist das ResolvedServicePartition -Objekt, das die Informationen zur aufgelösten Dienstpartition einschließlich der Dienstendpunkte enthält.

resolveAsync

public CompletableFuture resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Löst eine Partition des angegebenen Diensts durch Aufrufen system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) der Methode mit Back-off/Wiederholungsfehlern auf.

Overrides:

FabricServicePartitionResolver.resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Parameters:

serviceUri - URI des aufzulösenden Diensts
partitionKey - Schlüssel, der die partition identifiziert, die aufgelöst werden soll
resolveTimeoutPerTry - Das an die system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) Methode übergebene Timeout
maxRetryBackoffInterval - Das Intervall, das vor dem erneuten Wiederholen des Vorgangs zurückgegeben werden soll, wenn system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)bei der Methode ein Fehler mit einer wiederholungsfähigen Ausnahme auftritt.

Returns:

Eine CompletableFuture , die einen hervorragenden Vorgang darstellt. Das Ergebnis aus dem Task ist das ResolvedServicePartition -Objekt, das die Informationen zur aufgelösten Dienstpartition einschließlich der Dienstendpunkte enthält.

setDefault

public static void setDefault(ServicePartitionResolver defaultServiceResolver)

Updates der Standardeinstellung ServicePartitionResolver

Parameters:

defaultServiceResolver - Der neue Standardwert

setResolveTimeout

public void setResolveTimeout(Duration resolveTimeout)

Parameters:

resolveTimeout

setRetryBackoffInterval

public void setRetryBackoffInterval(Duration retryBackoffInterval)

Parameters:

retryBackoffInterval

Gilt für: