Alibaba Cloud SDK:Retry mechanism

Désactiver le mécanisme de nouvelle tentative

Le mécanisme de nouvelle tentative est désactivé par défaut. Pour le désactiver explicitement, définissez la politique de nouvelle tentative à none au niveau du client ou de la requête :

// Specify a retry policy for the client to disable the retry mechanism.
client.setSysRetryPolicy(RetryPolicy.none());

// Specify a retry policy for the request. The retry policy configuration of the request takes precedence over the retry policy configuration of the client.
request.setSysRetryPolicy(RetryPolicy.none());

Politiques de nouvelle tentative

Le SDK prend en charge trois types de politiques de nouvelle tentative :

1. Spécifiez des exceptions.

2. Spécifiez des codes de statut HTTP.

3. Spécifiez des en-têtes de réponse HTTP.

Ces trois conditions sont indépendantes. Dès qu'une condition est remplie, le SDK effectue une nouvelle tentative ou arrête les tentatives. Vous pouvez créer des politiques qui déclenchent les nouvelles tentatives ainsi que des politiques qui les restreignent.

Les exemples suivants montrent comment configurer des politiques pour déclencher ou restreindre les nouvelles tentatives :

• Créez une collection de conditions de nouvelle tentative :

  Set<RetryCondition> retryConditions = new HashSet<RetryCondition>();
  
  // Example of conditions
  // Specify status codes to trigger a retry. In the following example, a retry is performed when the status code 500 or 501 is returned.
  Set<Integer> statusCodes = new HashSet<Integer>();
  statusCodes.add(500); // http statusCode
  statusCodes.add(501); // http statusCode
  // Add the status code configuration to the policy that is used to trigger a retry.
  retryConditions.add(StatusCodeCondition.create(statusCodes));
  
  // Specify exceptions to trigger a retry. In the following example, a retry is performed when a SocketTimeoutException or IOException is thrown.
  Set<Class<?  extends Exception>> exceptions = new HashSet<Class<?  extends Exception>>();
  exceptions.add(SocketTimeoutException.class); // exception
  exceptions.add(IOException.class); // exception
  // Add the exception configuration to the policy that is used to trigger a retry.
  retryConditions.add(ExceptionsCondition.create(exceptions));

• Créez une collection de conditions pour restreindre les nouvelles tentatives :

  Set<RetryCondition> throttlingConditions = new HashSet<RetryCondition>();
  
  // Example of conditions
  // Specify status codes to restrict a retry. In the following example, a retry is prohibited when the status code 429 is returned.
  Set<Integer> code = new HashSet<Integer>();
  code.add(429); // Specify an HTTP status code to restrict a retry. In this example, a retry is prohibited if the status code 429 is returned.
  // Add the status code configuration to the policy that is used to restrict retires.
  throttlingConditions.add(StatusCodeCondition.create(code));

• Ajoutez les conditions à RetryPolicy :

  RetryPolicy retryPolicy = RetryPolicy.builder()
                  .maxNumberOfRetries(3) // The maximum number of retries.
                  .maxDelayTimeMillis(20 * 1000) // The maximum retry interval. Unit: milliseconds. If the specified duration is exceeded, no retries are performed.
                  .retryConditions(retryConditions) // The policy that is used to trigger retries.
                  . .throttlingConditions(throttlingConditions) // The policy that is used to restrict retries.
                  .build();

Les intervalles entre les tentatives sont calculés à l'aide d'un algorithme de backoff exponentiel. L'algorithme EqualJitter détermine le temps d'attente avant chaque nouvelle tentative.

Configurer les paramètres avancés des conditions de nouvelle tentative

Cette section décrit en détail les trois types de conditions intégrées.

1. StatusCodeCondition

   1. Stocke une collection d'entiers. Le SDK compare chaque entier au code de statut HTTP retourné afin de déterminer s'il faut déclencher ou restreindre les nouvelles tentatives.

2. ExceptionsCondition

   1. Stocke une collection d'exceptions. Le SDK compare chaque exception à celle levée lors de l'appel pour décider de déclencher ou de restreindre les nouvelles tentatives.

3. HeadersCondition

   1. Stocke une map à structure complexe. La clé de la map correspond à la clé de l'en-tête de réponse, tandis que la valeur est évaluée via l'interface Pattern (com.aliyuncs.policy.retry.pattern.Pattern). Ce pattern vérifie si la valeur de l'en-tête de réponse contient une chaîne spécifique ou est égale à une valeur donnée.

   2. Deux patterns sont pris en charge : AliyunThrottlingPattern et SimplePattern. AliyunThrottlingPattern applique la politique de limitation fournie par Alibaba Cloud. Pour plus d'informations, consultez Mécanisme de backoff avancé basé sur la politique de limitation. SimplePattern vérifie l'égalité des valeurs.

   3. Pour personnaliser l'interface Pattern, implémentez les trois méthodes suivantes :

      1. meetState() : retourne true lorsque la règle correspond.

      2. escapeTime() : retourne le temps d'échappement en millisecondes. Cette méthode s'applique uniquement aux politiques de restriction des nouvelles tentatives. Si la valeur retournée n'est pas -1, les nouvelles tentatives sont suspendues pendant la durée spécifiée au lieu d'être définitivement interdites. Le SDK attend la fin du temps d'échappement avant de réessayer. Si cette valeur dépasse l'intervalle maximal de nouvelle tentative, la requête échoue immédiatement.

      3. readFormHeadersContent(String content) : analyse et attribue une valeur provenant de l'en-tête. Réutilisez directement l'implémentation de SimplePattern.

4. Conditions personnalisées

   1. Pour créer des conditions personnalisées, implémentez l'interface RetryCondition avec les deux méthodes suivantes :

      1. meetState(RetryPolicyContext var1) : évalue si la condition de nouvelle tentative est remplie en fonction du contexte.

      2. escapeTime(RetryPolicyContext var1) : calcule le temps d'échappement. Cette méthode s'applique uniquement aux politiques de restriction. Pour les politiques de déclenchement, retournez -1.