Alibaba Cloud SDK:Mecanismo de reintento

Deshabilite el mecanismo de reintento

El mecanismo de reintento está deshabilitado de forma predeterminada. Para deshabilitarlo de manera explícita, establezca la política de reintento en none en el nivel de cliente o de solicitud:

// 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());

Políticas de reintento

El SDK es compatible con tres tipos de políticas de reintento:

1. Especifique excepciones.

2. Especifique códigos de estado HTTP.

3. Especifique encabezados de respuesta HTTP.

Estas tres condiciones son independientes. Si se cumple alguna de ellas, el SDK vuelve a intentar la solicitud o detiene los reintentos. Puede crear políticas que desencadenen reintentos y políticas que los restrinjan.

Los ejemplos a continuación muestran cómo configurar políticas que desencadenan o restringen reintentos:

• Cree una colección de condiciones de reintento:

  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));

• Cree una colección de condiciones para restringir reintentos:

  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));

• Agregue condiciones a 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();

El algoritmo de backoff exponencial calcula los intervalos de reintento. El algoritmo EqualJitter determina el tiempo de espera antes de cada reintento.

Configure ajustes avanzados de las condiciones para reintentos

La sección a continuación describe en detalle los tres tipos de condiciones integrados.

1. StatusCodeCondition

   1. Almacena una colección de números enteros. El SDK compara cada número entero con el código de estado HTTP devuelto para determinar si se deben desencadenar o restringir los reintentos.

2. ExceptionsCondition

   1. Almacena una colección de excepciones. El SDK compara cada excepción con la excepción generada durante la llamada para determinar si se deben desencadenar o restringir los reintentos.

3. HeadersCondition

   1. Almacena un mapa con una estructura compleja. La clave del mapa coincide con la clave del encabezado de respuesta y el valor se evalúa mediante la interfaz Pattern (com.aliyuncs.policy.retry.pattern.Pattern). El patrón verifica si el valor del encabezado de respuesta contiene una cadena específica o es igual a un valor determinado.

   2. Se admiten dos patrones: AliyunThrottlingPattern y SimplePattern. AliyunThrottlingPattern aplica la política de limitación proporcionada por Alibaba Cloud. Para obtener más información, consulte Advanced backoff mechanism based on the throttling policy. SimplePattern verifica si los valores son iguales.

   3. Para personalizar la interfaz Pattern, implemente los tres métodos a continuación:

      1. meetState(): devuelve true cuando se cumple la regla.

      2. escapeTime(): devuelve el tiempo de escape en milisegundos. Este método solo se aplica a las políticas de restricción de reintentos. Si el valor de retorno no es -1, los reintentos se pausan durante la duración especificada en lugar de restringirse de forma permanente. El SDK espera a que transcurra el tiempo de escape antes de reintentar. Si este valor supera el intervalo máximo de reintento, la solicitud falla de inmediato.

      3. readFormHeadersContent(String content): analiza y asigna un valor del encabezado. Puede reutilizar directamente la implementación de SimplePattern.

4. Condiciones personalizadas

   1. Para crear condiciones personalizadas, implemente la interfaz RetryCondition con los dos métodos a continuación:

      1. meetState(RetryPolicyContext var1): evalúa si se cumple la condición de reintento según el contexto.

      2. escapeTime(RetryPolicyContext var1): calcula el tiempo de escape. Este método solo se aplica a las políticas de restricción. Para las políticas de desencadenamiento, devuelva -1.