标签: resilience4j

我使用 Spring Boot2 starter ( https://resilience4j.readme.io/docs/getting-started-3 ) 在我的项目中实现了resilience4j。

我用 @CircuitBreaker 注释了一个方法，该方法使用 http 客户端来调用外部服务，并且断路器工作正常 - 包括其后备。

我想为其添加单元测试，但是当我运行尝试模拟回退的测试时，没有任何反应 - 抛出异常但不由断路器机制处理。

我找到了一些使用其指标的示例，但它对我来说没有用。

有什么想法吗？

这是我的客户的片段：

@CircuitBreaker(name = "MY_CICUIT_BREAKER", fallbackMethod = "fallback")
    public ResponseEntity<String> search(String value) {

        ResponseEntity<String> responseEntity = restTemplate.exchange(
                searchURL,
                HttpMethod.GET,
                new HttpEntity(new HttpHeaders()),
                String.class,
                value);
    }

public ResponseEntity<String> fallback(String value, ResourceAccessException ex) {
        return "fallback executed";
    }

遵循入门指南（https://resilience4j.readme.io/docs/getting-started-3）和演示项目（https://github.com/resilience4j/resilience4j-spring-boot2-demo）我想自己测试它，创建一个更简单的测试应用程序。

这是代码：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class ServiceConfiguration {

    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

控制器：

@RestController
public class ServiceController {

    @Autowired
    private  AlbumService albumService;


    @GetMapping("/albums")
    ResponseEntity<String> getAlbums() {
       return albumService.getAlbums();
    }

}

和服务类：

@Slf4j
@Service
public class AlbumService {

    @Autowired
    private  RestTemplate restTemplate;

    @CircuitBreaker(name = "albumService", fallbackMethod = "getDefaultAlbumList")
    public ResponseEntity<String> getAlbums() {
        String url = MockNeat.secure().probabilites(String.class)
                .add(0.7, "https://wrong-url.com")
                .add(0.3, "https://jsonplaceholder.typicode.com/albums").val();
        return new ResponseEntity<>(restTemplate.getForObject(url, String.class), HttpStatus.OK);
    }

    private …

我有以下配置，用于在运行时创建断路器：

@Configuration
public class CircuitBreakerConfiguration
{

    public final static String DEFAULT_CIRCUIT_BREAKER_REGISTRY = "DEFAULT_CIRCUIT_BREAKER_REGISTRY";

    private CircuitBreakerConfig getCircuitBreakerConfig()
    {
        return CircuitBreakerConfig.custom()
                .failureRateThreshold(10)
                .waitDurationInOpenState(Duration.ofMillis(30000))
                .permittedNumberOfCallsInHalfOpenState(2)
                .slidingWindowType(CircuitBreakerConfig.SlidingWindowType.COUNT_BASED)
                .slidingWindowSize(5)
                .automaticTransitionFromOpenToHalfOpenEnabled(true)
                .recordExceptions(CheckAvailabilityException.class)
                .build();

    }

    @Bean
    @Qualifier(DEFAULT_CIRCUIT_BREAKER_REGISTRY)
    public CircuitBreakerRegistry getCircuitBreakerRegistry()
    {
        return CircuitBreakerRegistry.of(getCircuitBreakerConfig());
    }
}

我想将这些配置移至我的application.properties文件中。

我尝试了以下方法来覆盖默认配置：

resilience4j.circuitbreaker.configs.default.sliding-window-size=10
resilience4j.circuitbreaker.configs.default.sliding-window-type=COUNT_BASED
resilience4j.circuitbreaker.configs.default.failure-rate-threshold=50
resilience4j.circuitbreaker.configs.default.wait-duration-in-open-state=30s
resilience4j.circuitbreaker.configs.default.permitted-number-of-calls-in-half-open-state=2
resilience4j.circuitbreaker.configs.default.automatic-transition-from-open-to-half-open-enabled=true
resilience4j.circuitbreaker.configs.default.record-exceptions=com.example.web.domain.checkavailability.exceptions.CheckAvailabilityException

但是，这似乎也没有覆盖默认配置。

是否可以使用resilience4j 在客户端记录重试尝试？

也许通过某种配置或设置。

目前，我正在使用基于Spring boot Webflux注释的resilience4j 。

它运作良好，该项目很棒。

当我们将服务器日志放在服务器端时，为了查看由于重试而进行的相同 http 调用（我们记录时间、客户端 IP、请求 ID 等...）我是否可以拥有客户端日志？

我期待看到类似“Resilience4j - 客户端：第一次尝试因 someException 失败，因参加编号 2 重试而失败。第二次尝试因 someException 失败，因参加编号 3 重试。第三次尝试成功！”

类似的事情。有没有一个属性、一些配置、一些设置可以帮助轻松地做到这一点？无需添加太多锅炉代码。

@RestController
public class TestController {

    private final WebClient webClient;

    public TestController(WebClient.Builder webClientBuilder) {
        this.webClient = webClientBuilder.baseUrl("http://localhost:8443/serviceBgreeting").build();
    }

    @GetMapping("/greeting")
    public Mono<String> greeting() {
        System.out.println("Greeting method is invoked ");
        return someRestCall();
    }

    @Retry(name = "greetingRetry")
    public Mono<String> someRestCall() {
        return this.webClient.get().retrieve().bodyToMono(String.class);
    }

}

谢谢

使用Spring Boot为外部调用（例如HTTP）提供断路器是一种很容易实施的常见模式，例如使用resilience4j。

我找不到任何有关通过resilience4j 或其他常见模式对数据库调用执行相同操作的信息，这对我来说是出乎意料的。

假设我们有一个服务，通过简单的 JDBC 连接到传统的 SQL 数据库。如果数据库因任何原因发生故障，我希望能够在控制器级别停止对服务的所有传入请求，直到连接恢复。有没有一种方法可以为通过数据库连接发生的所有事务实现本质上的断路器功能？

Netflix 将 Hystrix 正式置于维护模式（https://github.com/Netflix/Hystrix#hystrix-status），我开始寻找替代方案。当涉及到断路器、隔板、重试等模式时，有一些不错的库，例如resilience4j，但我找不到 Hystrix 可以做的请求崩溃的替代方案。

有人知道可以提供此类功能的库吗？

谢谢，本杰明

我有一个 Spring Boot 应用程序，它使用基于resilience4j AOP 的@CircuitBreakers。

现在我想在端点中提供断路器的信息/actuator/health，但我没有在 JSON 输出中看到文档中描述的details.circuitBtreakers对象。

我究竟做错了什么？

相比之下，让动态缓存信息出现在/actuator/metrics端点中需要少量的自定义连接，但这是有详细记录的。我想知道是否有类似的技巧可以应用于动态定义的@CircuitBreaker端点注册/actuator/health。

MyService.java:

@Service
public class MyService {
    @Autowired
    private CacheManager cacheManager;
    @Autowired
    private CacheMetricsRegistrar cacheMetricsRegistrar;

    @PostConstruct
    public void postConstruct() {
        // On-the-fly defined (annotation-based) caches are not auto-registered with micrometer metrics.
        final Cache cache = cacheManager.getCache("myCache");
        cacheMetricsRegistrar.bindCacheToRegistry(cache);
    }

    @CircuitBreaker(name = "myCB", fallbackMethod = "fallbackCallAnApi")
    public String callAnApi() throws RestClientException {
        // ...
    } …