Springboot Retry组件@Recover失效问题解决方法-eolink官网

Springboot Retry组件@Recover失效问题解决方法

Springboot Retry组件@Recover失效问题解决方法

目录背景问题复现问题解决

背景

在使用springboot的retry模块时，你是否出现过@Recover注解失效的问题呢？下面我会对该问题进行复现，并且简要的说下解决方法。

问题复现

首先我们引入maven

org.springframework.retry

spring-retry

org.aspectj

aspectjweaver

1.9.6

cn.hutool

hutool-all

5.5.2

org.projectlombok

lombok

true

org.springframework.boot

sprinhttp://g-boot-starter-test

test

org.springframework.boot

spring-boot-starter-web

主类配置EnableRetry注解

package ai.guiji.csdn;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.retry.annotation.EnableRetry;

@EnableRetry

@SpringBootApplication

public class CsdnApplication {

public static void main(String[] args) {

SpringApplication.run(CsdnApplication.class, args);

}

准备测试的Retry组件类代码

package ai.guiji.csdn.component;

import lombok.extern.slf4j.Slf4j;

import org.springframework.retry.annotation.Backoff;

import org.springframework.retry.annotation.Recover;

import org.springframework.retry.annotation.Retryable;

import org.springframework.stereotype.Component;

import java.util.function.Supplier;

/** @Author 剑客阿良_ALiang @Date 2021/4/22 16:07 @Description: 重试工具 */

@Slf4j

@Component

public class RetryUtil {

@Retryable(

value = Exception.class,

maxAttempts = 3,

backoff = @Backoff(delay = 5000, multiplier = 1.5))

public String retry(Supplier supplier) throws Exception {

String result = null;

try {

result = supplier.get();

} catch (Exception exception) {

log.error("异常报错:{}", exception.getMessage());

throw exception;

}

return result;

}

@Recover

public void recover(Exception e) {

log.error("调用超过3次异常");

}

代码说明

1、我们可以看到retry方法会重试supplier的get结果，捕获异常并抛出异常。这里抛出后会被retry捕获并且重试。

2、maxAttempts参数为重试的最大次数。

3、backoff中的delay为两次重试之间的延迟，multiplier为重试阻尼，可以这么理解，每次重试间隔时间为上一次重试间隔时间的倍数。

4、如果3次重试均抛出异常，则进入recover方法。

编写测试代码

package ai.guiji.csdn.component;

import cn.hutool.core.convert.Convert;

import cn.hutool.http.HttpUtil;

import org.junit.jupiter.api.Test;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

/** @Author 剑客阿良_ALaing @Date 2021/11/30 13:08 @Description: */

@SpringBootTest

class RetryUtilTest {

@Autowired private RetryUtil retryUtil;

@Test

void retry() {

try {

System.out.println(Convert.toStr(retryUtil.retry(() -> HttpUtil.post("xxxx", "")), "haha"));

} catch (Exception exception) {

exception.printStackTrace();

}

执行测试结果

2021-11-30 13:37:44.012 ERROR 13600 --- [ main] ai.guiji.csdn.component.RetryUtil : 异常报错:UnknownHostException: xxxx

2021-11-30 13:37:49.019 ERROR 13600 --- [ main] ai.guiji.csdn.component.RetryUtil : 异常报错:UnknownHostException: xxxx

2021-11-30 13:37:58.787 ERROR 13600 --- [ main] ai.guiji.csdn.component.RetryUtil : 异常报错:UnknownHostException: xxxx

org.springframework.retry.ExhaustedRetryException: Cannot locate recovery method; nested exception is cn.hutool.core.io.IORuntimeException: UnknownHostException: xxxx

at org.springframework.retry.annotation.RecoverAnnotationRecoveryHandler.recover(RecoverAnnotationRecoveryHandler.java:70)

at org.springframework.retry.interceptor.RetryOperationsInterceptor$ItemRecovererCallback.recover(RetryOperationsInterceptor.java:142)

at org.springframework.retry.support.RetryTemplate.handleRetryExhausted(RetryTemplate.java:539)

at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:387)

at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:225)

at org.springframework.retry.interceptor.RetryOperationsInterceptor.invoke(RetryOperationsInterceptor.java:116)

at org.springframework.retry.annotation.AnnotationAwareRetryOperationsInterceptor.invoke(AnnotationAwareRetryOperationsInterceptor.java:163)

at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)

at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750)

at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:692)

at ai.guiji.csdn.component.RetryUtil$$EnhancerBySpringCGLIB$$d209cbc6.retry()

at ai.guiji.csdn.component.RetryUtilTest.retry(RetryUtilTest.java:17)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)

at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)

at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)

at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)

at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)

at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)

at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)

at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)

at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)

at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)

at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)

at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)

at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)

at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)

at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)