在Spring Cloud中，熔断器模式用于防止系统中的级联故障，通过短路机制来停止接口的连续失败尝试。下面是使用Hystrix熔断器的三种常见解决方案：
- 使用注解
@HystrixCommand标记方法，并提供熔断逻辑。
@HystrixCommand(fallbackMethod = "fallbackMethod")
public String getData() {
// 业务逻辑
}
public String fallbackMethod() {
// 熔断逻辑
return "服务不可用，请稍后再试";
}
- 使用
HystrixCommand创建自定义熔断逻辑。
public class DataCommand extends HystrixCommand<String> {
protected DataCommand() {
super(HystrixCommandGroupKey.Factory.asKey("DataCommandGroup"));
}
@Override
protected String run() throws Exception {
// 业务逻辑
return "success";
}
@Override
protected String getFallback() {
// 熔断逻辑
return "服务不可用，请稍后再试";
}
}
- 使用全局配置或者属性来启用Hystrix。
@EnableCircuitBreaker
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
在Spring Cloud的新版本中，Hystrix已经被弃用，推荐使用Resilience4j或者Spring Cloud Netflix的替代品。以下是使用Resilience4j的示例：
@Bean
public Function<Integer, Integer> circuitBreaker() {
return CircuitBreaker.ofDefaults(cbName)
.configure(CircuitBreakerConfig.ofDefaults()
.slidingWindowSize(20)
.failureRateThreshold(50)
.waitDurationInOpenState(Duration.ofMillis(1000)))
.onFailure(FAILURE_RATE_EXCEEDED,
event -> log.warn("Circuit breaker opened", event.getEventType()))
.onSuccess(event -> log.info("Circuit breaker closed", event.getEventType()))
.onResult(result -> log.info("Result: {}", result))
.build(backendService::performOperation);
}
在这个例子中，我们创建了一个断路器，当失败率超过阈值时，它会开路，从而阻止过多的请求打到后端服务，防止级联故障。