如何解决Spring重试异常表达式
所以我试图重试特定的异常并创建一个具有 shouldRetry(Throwable t) 函数的 bean。如果必须重试异常,则该函数返回 true,否则返回 false。 但是我观察到的是 shouldRetry(Throwable t) 为一次重试尝试执行两次(日志打印两次),但是在一次重试尝试中,抛出异常的 serviceImpl 仅执行一次。
如果我在这里做错了什么,请有人告诉我,或者它是 spring 重试本身的默认行为/错误。
@Component("dbRecoverableExceptionHandler")
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Slf4j
public class DBRecoverableExceptionHandler {
private final Environment environment;
private final MultiTaggedCounter exceptionRetryCounter;
public Boolean isRetryable(Throwable t) {
String[] recoverableExceptionClasses = environment
.getRequiredProperty("db-recoverable-exception-classes",String[].class);
for (String s1 : recoverableExceptionClasses) {
if (t.getClass().getSimpleName().contains(s1)) {
exceptionRetryCounter.increment(1,s1);
log.warn("Retrying for exception " + t.toString());
return true;
}
}
return false;
}
}
@Retryable(exceptionExpression = "#{@dbRecoverableExceptionHandler.isRetryable(#root)}",maxAttemptsExpression = "#{${max-attempts}}",backoff = @Backoff(delayExpression = "#{${retry-backoff-delay-time}}",multiplierExpression = "#{${retry-backoff-multiplier}}"))
解决方法
正如预期的那样。
每次执行时,RetryTemplate
都会调用该方法两次...
while (canRetry(retryPolicy,context) && !context.isExhaustedOnly()) {
try {
if (this.logger.isDebugEnabled()) {
this.logger.debug("Retry: count=" + context.getRetryCount());
}
// Reset the last exception,so if we are successful
// the close interceptors will not think we failed...
lastException = null;
return retryCallback.doWithRetry(context);
}
catch (Throwable e) {
lastException = e;
try {
registerThrowable(retryPolicy,state,context,e);
}
catch (Exception ex) {
throw new TerminatedRetryException("Could not register throwable",ex);
}
finally {
doOnErrorInterceptors(retryCallback,e);
}
if (canRetry(retryPolicy,context) && !context.isExhaustedOnly()) {
...
对 canRetry()
的第一次调用(在 while 循环中)在第一次调用时被跳过,因为还没有异常,在后续迭代中,当该方法抛出异常时,它会被调用两次。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。