我已经使这个抽象类在抛出某些异常时自动重试网络调用。
- 我注意不要在
InterruptedException
之后重试 &未知主机异常
。 - 我重试了 5 次。每次失败后 我执行指数回退,从 300 毫秒开始上升到 1500 毫秒。
public abstract class AutoRetry {
private Object dataToReturn = null;
public Object getDataToReturn() {
return this.dataToReturn;
}
public AutoRetry() {
short retry = -1;
while (retry++ < StaticData.NETWORK_RETRY) {
try {
Thread.sleep(retry * StaticData.NETWORK_CALL_WAIT);
this.dataToReturn = doWork();
break;
} catch (InterruptedException | UnknownHostException e) {
e.printStackTrace();
this.dataToReturn = null;
return;
} catch (IOException e) {
e.printStackTrace();
}
}
}
protected abstract Object doWork() throws IOException;
}
我使用它如下:
final Object dataAfterWork = new AutoRetry() {
@Override
protected Object doWork() throws IOException {
return; //a network call which returns something
}
}.getDataToReturn();
那么这个实现是否良好/正确?
编辑
最佳答案
这看起来不错,但我会将正在运行的任务与重试分开。也使用泛型,不要只是抛出 Object
about。
使用 Java 8
lambda 和方法的 return
:
public static <T> Optional<T> doWithRetry(final Supplier<T> t) {
for (int retry = 0; retry <= StaticData.NETWORK_RETRY; ++retry) {
try {
Thread.sleep(retry * StaticData.NETWORK_CALL_WAIT);
return Optional.of(t.get());
} catch (InterruptedException | UnknownHostException e) {
LOGGER.log(Level.SEVERE, "Call failed.", e);
return Optional.empty();
} catch (IOException e) {
LOGGER.log(Level.WARNING, "Call failed. Retry.", e);
}
}
LOGGER.log(Level.SEVERE, "Call failed. Retries exceeded.");
return Optional.empty();
}
此外,使用真正的记录器,而不是printStackTrace
...
用法:
final String data = doWithRetry(() -> {
//do stuff
});
如果您的 lambda 需要抛出异常,您需要定义自己的 @FunctionalInterface
:
@FunctionalInterface
interface StuffDoer<T> {
T doStuff() throws Exception;
}
并在方法签名中使用它,您需要处理通用的Exception
。
Java 8 之前的用法:
final String data = doWithRetry(new StuffDoer<T>() {
@Override
public T get() throws Exception {
return null;
}
});
关于java - 异常后自动重试的功能,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29799001/