JAVA微服务Spring Cloud熔断器熔断降级常见三种方案

在Spring Cloud中，熔断器模式用于防止系统中的级联故障，通过短路机制来停止接口的连续失败尝试。下面是使用Hystrix熔断器的三种常见解决方案：

1. 使用注解@HystrixCommand标记方法，并提供熔断逻辑。

@HystrixCommand(fallbackMethod = "fallbackMethod")
public String getData() {
    // 业务逻辑
}
 
public String fallbackMethod() {
    // 熔断逻辑
    return "服务不可用，请稍后再试";
}

2. 使用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 "服务不可用，请稍后再试";
    }
}

3. 使用全局配置或者属性来启用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);
}

在这个例子中，我们创建了一个断路器，当失败率超过阈值时，它会开路，从而阻止过多的请求打到后端服务，防止级联故障。