Spring Cloud Circuit Breaker 3.2.2

介绍

Spring Cloud 断路器提供了跨不同断路器实现的抽象。它提供了一个一致的 API 来在您的应用程序中使用，允许您（开发人员）选择最适合您应用程序需求的断路器实现。

支持的实现

• 弹性4J

• 弹簧重试

核心概念

要在代码中创建断路器，您可以使用 API。当您在类路径上包含 Spring Cloud Circuit Breaker 启动器时，将自动为您创建一个实现此 API 的 bean。下面给出了一个使用此 API 的非常简单的示例CircuitBreakerFactory

@Service
public static class DemoControllerService {
	private RestTemplate rest;
	private CircuitBreakerFactory cbFactory;

	public DemoControllerService(RestTemplate rest, CircuitBreakerFactory cbFactory) {
		this.rest = rest;
		this.cbFactory = cbFactory;
	}

	public String slow() {
		return cbFactory.create("slow").run(() -> rest.getForObject("/slow", String.class), throwable -> "fallback");
	}

}

API 将创建一个名为 的类的实例。该方法采用 a 和 a 。是要包装在断路器中的代码。是断路器跳闸时将执行的回退。将传递导致触发回退的函数。如果您不想提供回退，可以选择排除回退。CircuitBreakerFactory.createCircuitBreakerrunSupplierFunctionSupplierFunctionThrowable

响应式代码中的断路器

如果 Project Reactor 在类路径上，那么您也可以用于响应式代码。ReactiveCircuitBreakerFactory

@Service
public static class DemoControllerService {
	private ReactiveCircuitBreakerFactory cbFactory;
	private WebClient webClient;


	public DemoControllerService(WebClient webClient, ReactiveCircuitBreakerFactory cbFactory) {
		this.webClient = webClient;
		this.cbFactory = cbFactory;
	}

	public Mono<String> slow() {
		return webClient.get().uri("/slow").retrieve().bodyToMono(String.class).transform(
		it -> cbFactory.create("slow").run(it, throwable -> return Mono.just("fallback")));
	}
}

API 将创建一个名为 的类的实例。该方法采用 or 并将其包装在断路器中。您可以选择分析一个回退，如果断路器跳闸，将调用该回退，并将传递导致故障的回退。ReactiveCircuitBreakerFactory.createReactiveCircuitBreakerrunMonoFluxFunctionThrowable