如何用Resilience4j断路器装饰外部依赖项中的服务方法（特别是在spring cloud config服务器上）？

Question

EnvironmentController类是一个Spring

我在circuitbreaker中看到了用于修饰调用、函数等的方法，但似乎没有一个适用于此。（我对Resilience4j是完全陌生的，所以我希望我没有找到一个简单的解决方案。）

Answer 1

一种常见的方法（不仅用于Resilience4J，而且通常用于Spring)是使用BeanPostProcessor（您可以在这里看到一个不相关的示例）。

然后，在beanPostProcessor中，您可以获得EnvironmentController的句柄，并用Resilience4JCicrcuitBreaking逻辑环绕其实现/方法。

基本上，这种方法类似于：

null

如果这还不能完全清楚，我可以添加一些示例代码来让您开始，只要让我知道就行了。请记住，这可能只是解决这个问题的许多方法之一。

编辑：

有些代码（不确定它是否有效，没有经过测试，spring-boot在MVC映射autoconfig中使用了大量AOP是出了名的烦人，因此您可能不得不使用方面或代理配置）看起来像（请记住，为了后代，我会使用lombok来避免所有的样板）：

@Configuration
@Slf4j
public class MyConfig {

    // or however the heck you get your breaker config
    private final CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig.custom().build();
    private final CircuitBreakerRegistry circuitBreakerRegistry = CircuitBreakerRegistry.of(circuitBreakerConfig);
    private final CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker("suchBreakerMuchWow");

    @Bean
    public CircuitBreakerAwarePostProcessor circuitBreakerAwarePostProcessor() {
        return new CircuitBreakerAwarePostProcessor();
    }

    public class CircuitBreakerAwarePostProcessor implements BeanPostProcessor {

        @Override
        public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
            if (bean instanceof EnvironmentController) {
                return new CircuitBreakerFriendlyEnvironmentController((EnvironmentController) bean);
            }
            return bean;
        }
    }

    private interface Exclude {
        Environment labelled (String name, String profiles, String label);
    }

    @RequiredArgsConstructor
    private class CircuitBreakerFriendlyEnvironmentController implements Exclude {

        @Delegate(types = EnvironmentController.class, excludes = Exclude.class)
        @NonNull private final EnvironmentController environmentController;

        @Override
        public Environment labelled(String name, String profiles, String label) {
            return circuitBreaker.executeSupplier(() -> {
                log.info("such wow");
                return environmentController.labelled(name, profiles, label);
            });
        }
    }
}