1

我最近研究了断路器模式,我正在做一个 POC 来在我的 Spring Boot 应用程序中实现它。我发现spring提供了一个开箱即用的resilience4j实现。

我正在研究一篇我在下面提到的 github repo 的文章

https://github.com/eugenp/tutorials/blob/master/spring-cloud/spring-cloud-circuit-breaker/src/main/java/com/baeldung/circuitbreaker/AlbumService.java

代码如下所示。我的疑问在于突出显示的声明

断路器 circuitBreaker = circuitBreakerFactory.create("断路器");

这是否意味着每次调用 getAlbumList()时都会创建一个新的断路器实例,因此断路器注册的事件的旧值将丢失。跨应用程序不应该只有一个实例。

我在这里很困惑,我忘记了spring框架的一些基本原理,请帮助我。我想了解这是如何工作的。

@Service
public class AlbumService {

    private static final Logger LOGGER = LoggerFactory.getLogger(AlbumService.class);

    @Autowired
    private CircuitBreakerFactory circuitBreakerFactory;

    private RestTemplate restTemplate = new RestTemplate();

    public String getAlbumList() {
        **CircuitBreaker circuitBreaker = circuitBreakerFactory.create("circuitbreaker");**
        String url = "https://jsonplaceholder.typicode.com/albums";

        return circuitBreaker.run(() -> restTemplate.getForObject(url, String.class), throwable -> getDefaultAlbumList());
    }

    private String getDefaultAlbumList() {
        try {
            return new String(Files.readAllBytes(Paths.get(getClass().getClassLoader().getResource("fallback-album-list.json").toURI())));
        } catch (Exception e) {
            LOGGER.error("error occurred while reading the file", e);
        }
        return null;
    }

}
4

0 回答 0