Reintentar llamadas al método de manera genérica

Question

Mi aplicación Java requiere una lógica de reintento en las llamadas remotas. Estas llamadas remotas son:

• dispersos por todo la aplicación
• pertenecen a diferentes clases de servicio remoto.

Además, la lógica de reintento puede tener un intervalo de reintento variable e intentos de reintento variables.

Necesito una implementación genérica de retry() que pueda realizar llamadas al método apropiado según el lugar al que se llame. A continuación se muestra una ilustración de código simple de lo que estoy buscando. Sé que podemos intentar hacer esto usando la reflexión de Java, pero, ¿hay un marco o una fuente abierta disponible en algún lugar que sea de lectura y uso?

try { 
ClassA objA = remoteServiceA.call(paramA1, paramA2, ...); 
} catch (Exception e){ 
ClassA objA = (ClassA)retry(remoteService, listOfParams, ..); // generic method call 
} 
.. 

try { 
ClassB objB = remoteServiceB.call(paramB1, paramB2, ...); 
} catch (Exception e){ 
ClassA objB = (ClassB)retry(remoteService, listOfParams, ..); // generic method call 
} 

Answer 1

¿dónde obtienes los servicios? use una fábrica para Proxy el servicio que obtiene de la fábrica original. El proxy puede implementar el reintento de forma transparente. Ver los Proxy/ProxyGenerators de Java en reflexión.

Answer 2

Este es un ejemplo de libro donde aspectj (o aop en general) pueden usarse, véase 8.2.7 Example in Spring documentation y 5 Reasons Java Developers Should Learn and Use AspectJ.

Básicamente un aspecto intercepta todas las llamadas a métodos determinados (especificados mediante anotación, convención de nomenclatura, lo que sea) y reintentos.

Answer 3

Como ya se ha sugerido, debe usar las anotaciones AOP y Java. Yo recomendaría un mecanismo hecho de leer Desde jcabi-aspects (soy un desarrollador):

@RetryOnFailure(attempts = 3, delay = 5) 
public String load(URL url) { 
    return url.openConnection().getContent(); 
} 

Lea también este blog mensaje: http://www.yegor256.com/2014/08/15/retry-java-method-on-exception.html

actualización: Comprobar RetryFunc de Cactoos.

Answer 4

Supongamos que tiene un método que necesita volverse a unir cada 500 ms y hasta 5 veces. clase actual:

public class RemoteCaller{ 
    Service serviceCaller; 
    public void remoteCall(String message) { 
       serviceCaller.updateDetails(this.message); 
       return null; 
    } 
} 

enfoque de modificación:

public class RetriableHelper<T> implements Callable<T> { 

    private Callable<T> task; 

    private int numberOfRetries; 

    private int numberOfTriesLeft; 

    private long timeToWait; 


    public RetriableHelper(int numberOfRetries, long timeToWait, Callable<T> task) { 
     this.numberOfRetries = numberOfRetries; 
     numberOfTriesLeft = numberOfRetries; 
     this.timeToWait = timeToWait; 
     this.task = task; 
    } 

    public T call() throws Exception { 
     while (true) { 
      try { 
       return task.call(); 
      } catch (InterruptedException e) { 
       throw e; 
      } catch (CancellationException e) { 
       throw e; 
      } catch (Exception e) { 
       numberOfTriesLeft--; 
       if (numberOfTriesLeft == 0) { 
        throw e; 
       } 
       Thread.sleep(timeToWait); 
      } 
     } 
    } 
} 


Backend system/remote call class: 

public class RemoteCaller{ 

    Service serviceCaller; 

    public void remoteCall(String message) { 

     class RemoteCallable implements Callable<Void> { 
      String message; 
      public RemoteCallable(String message) 
      { 
       this.message = message; 
      } 
      public Void call() throws Exception{ 
       serviceCaller.updateDetails(this.message); 
       return null; 
      } 
     } 


     RetriableHelper<Void> retriableHelper = new RetriableHelper<Void>(5, 500, new RemoteCallable(message)); 
     try { 
      retriableHelper.call(); 
     } catch (Exception e) { 
      throw e; 
     } 
    } 
}