Spring Boot @Retryable 根据异常的 maxAttempts 配置

huangapple
go评论154阅读模式
英文:

Spring Boot @Retryable maxAttempts according to exception

问题

关于Spring Boot的@Retryable注解，我有一个疑问。

我想根据异常类型来实现@Retryable的最大尝试次数，就像这样：

如果异常类型是ExceptionA：

  1. @Retryable(value = ExceptionA.class, maxAttempts = 2)

如果异常类型是ExceptionB：

  1. @Retryable(value = ExceptionB.class, maxAttempts = 5)

是否可以使用@Retryable注解来实现这个功能，或者是否有什么建议？

英文:

I wonder something about Spring Boot @Retryable annotation.

I want to implement @Retryable maxAttemps count according to Exception type, like:

  1. if Exception type is ExceptionA:
  2. @Retryable(value = ExceptionA.class, maxAttempts = 2)
  3. if Exception type is ExceptionB:
  4. @Retryable(value = ExceptionB.class, maxAttempts = 5)

Is it possible to do it with @Retryable annotation, or is there any suggestion?

答案1

得分: 1

不直接进行; 您需要构建一个自定义的拦截器 (RetryInterceptorBuilder) bean，并在 @Retryable.interceptor 中提供其 bean 名称。

使用 ExceptionClassifierRetryPolicy 为每个异常使用不同的策略。

编辑

这里是一个示例：

  1. @SpringBootApplication
  2. @EnableRetry
  3. public class So64029544Application {
  5. 	public static void main(String[] args) {
  6. 		SpringApplication.run(So64029544Application.class, args);
  7. 	}
  9. 	@Bean
  10. 	public ApplicationRunner runner(Retryer retryer) {
  11. 		return args -> {
  12. 			retryer.toRetry("state");
  13. 			retryer.toRetry("arg");
  14. 		};
  15. 	}
  17. 	@Bean
  18. 	public Object retryInterceptor(Retryer retryer) throws Exception {
  19. 		ExceptionClassifierRetryPolicy policy = new ExceptionClassifierRetryPolicy();
  20. 		policy.setPolicyMap(Map.of(
  21.             IllegalStateException.class, new SimpleRetryPolicy(2),
  22. 			IllegalArgumentException.class, new SimpleRetryPolicy(3)));
  23. 		Method recover = retryer.getClass().getDeclaredMethod("recover", Exception.class);
  24. 		return RetryInterceptorBuilder.stateless()
  25. 				.retryPolicy(policy)
  26. 				.backOffOptions(1_000, 1.5, 10_000)
  27. 				.recoverer(new RecoverAnnotationRecoveryHandler<>(retryer, recover))
  28. 				.build();
  29. 	}
  30. }
  32. @Component
  33. class Retryer {
  35. 	@Retryable(interceptor = "retryInterceptor")
  36. 	public void toRetry(String in) {
  37. 		System.out.println(in);
  38. 		if ("state".equals(in)) {
  39. 			throw new IllegalStateException();
  40. 		}
  41. 		else {
  42. 			throw new IllegalArgumentException();
  43. 		}
  44. 	}
  46. 	@Recover
  47. 	public void recover(Exception ex) {
  48. 		System.out.println("Recovered from " + ex
  49. 				+ ", retry count:" + RetrySynchronizationManager.getContext().getRetryCount());
  50. 	}
  52. }
  1. state
  2. state
  3. Recovered from java.lang.IllegalStateException, retry count:2
  4. arg
  5. arg
  6. arg
  7. Recovered from java.lang.IllegalArgumentException, retry count:3
英文:

Not directly; you would have to construct a custom interceptor (RetryInterceptorBuilder) bean and provide its bean name in @Retryable.interceptor.

Use an ExceptionClassifierRetryPolicy to use a different policy for each exception.

EDIT

Here's an example:

  1. @SpringBootApplication
  2. @EnableRetry
  3. public class So64029544Application {
  5. 	public static void main(String[] args) {
  6. 		SpringApplication.run(So64029544Application.class, args);
  7. 	}
  10. 	@Bean
  11. 	public ApplicationRunner runner(Retryer retryer) {
  12. 		return args -&gt; {
  13. 			retryer.toRetry(&quot;state&quot;);
  14. 			retryer.toRetry(&quot;arg&quot;);
  15. 		};
  16. 	}
  18. 	@Bean
  19. 	public Object retryInterceptor(Retryer retryer) throws Exception {
  20. 		ExceptionClassifierRetryPolicy policy = new ExceptionClassifierRetryPolicy();
  21. 		policy.setPolicyMap(Map.of(
  22.                 IllegalStateException.class, new SimpleRetryPolicy(2),
  23. 				IllegalArgumentException.class, new SimpleRetryPolicy(3)));
  24. 		Method recover = retryer.getClass().getDeclaredMethod(&quot;recover&quot;, Exception.class);
  25. 		return RetryInterceptorBuilder.stateless()
  26. 				.retryPolicy(policy)
  27. 				.backOffOptions(1_000, 1.5, 10_000)
  28. 				.recoverer(new RecoverAnnotationRecoveryHandler&lt;&gt;(retryer, recover))
  29. 				.build();
  30. 	}
  31. }
  33. @Component
  34. class Retryer {
  36. 	@Retryable(interceptor = &quot;retryInterceptor&quot;)
  37. 	public void toRetry(String in) {
  38. 		System.out.println(in);
  39. 		if (&quot;state&quot;.equals(in)) {
  40. 			throw new IllegalStateException();
  41. 		}
  42. 		else {
  43. 			throw new IllegalArgumentException();
  44. 		}
  45. 	}
  47. 	@Recover
  48. 	public void recover(Exception ex) {
  49. 		System.out.println(&quot;Recovered from &quot; + ex
  50. 				+ &quot;, retry count:&quot; + RetrySynchronizationManager.getContext().getRetryCount());
  51. 	}
  53. }
  1. state
  2. state
  3. Recovered from java.lang.IllegalStateException, retry count:2
  4. arg
  5. arg
  6. arg
  7. Recovered from java.lang.IllegalArgumentException, retry count:3

huangapple
  • 本文由 发表于 2020年9月23日 21:54:08
  • 转载请务必保留本文链接：https://go.coder-hub.com/64029544.html
  • java
  • spring
  • spring-boot
  • spring-retry
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定