我发现我可以使用RetryTemplate：
RetryTemplate retryTemplate = new RetryTemplate();
FixedBackOffPolicy fixedBackOffPolicy = new FixedBackOffPolicy();
fixedBackOffPolicy.setBackOffPeriod(2000l);
retryTemplate.setBackOffPolicy(fixedBackOffPolicy);
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
retryPolicy.setMaxAttempts(5);
retryTemplate.setRetryPolicy(retryPolicy);
retryTemplate.execute(new RetryCallback<Void, Throwable>() {
@Override
public Void doWithRetry(RetryContext context) throws Throwable {
// do some job
if(context.getRetryCount() < 3){ // unexpected disconnection
log.error("connection Failed");
throw new RuntimeException("retry exception");
}
System.out.println("RETRY" + context);
return null;
}
});
602392714
清零编程群