Spring Retry 为 Spring 应用程序提供声明性重试支持。
该项目的一个子集包括实现断路器功能的能力。
Spring Retry 通过其 CircuitBreakerRetryPolicy 和有状态重试的组合提供断路器实现。
使用 Spring Retry 创建的所有断路器都将使用 和 DefaultRetryState 创建。
这两个类都可以使用 进行配置。CircuitBreakerRetryPolicySpringRetryConfigBuilder
默认配置
要为所有断路器提供缺省配置，请创建一个传递 .
该方法可用于提供默认配置。CustomizerSpringRetryCircuitBreakerFactoryconfigureDefault
@Bean
public Customizer<SpringRetryCircuitBreakerFactory> defaultCustomizer() {
return factory -> factory.configureDefault(id -> new SpringRetryConfigBuilder(id)
.retryPolicy(new TimeoutRetryPolicy()).build());
}特定断路器配置
与提供默认配置类似，您可以创建一个 bean，该 Bean 传递给 .CustomizerSpringRetryCircuitBreakerFactory
@Bean
public Customizer<SpringRetryCircuitBreakerFactory> slowCustomizer() {
return factory -> factory.configure(builder -> builder.retryPolicy(new SimpleRetryPolicy(1)).build(), "slow");
}除了配置创建的断路器外，您还可以在创建断路器之后但在将断路器返回给调用方之前对其进行自定义。
为此，您可以使用该方法。
这对于将事件处理程序添加到 .addRetryTemplateCustomizersRetryTemplate
@Bean
public Customizer<SpringRetryCircuitBreakerFactory> slowCustomizer() {
return factory -> factory.addRetryTemplateCustomizers(retryTemplate -> retryTemplate.registerListener(new RetryListener() {
@Override
public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
return false;
}
@Override
public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
}
@Override
public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
}
}));
}