当前位置：首页 > Java

如何熔断 java

2026-03-17 22:07:27Java

熔断机制简介

熔断是一种防止系统因依赖服务故障而崩溃的设计模式，类似于电路中的保险丝。当错误率达到阈值时，熔断器会暂时切断请求，避免级联故障。

使用 Hystrix 实现熔断

Hystrix 是 Netflix 开源的熔断库，适用于 Java 应用。

添加依赖
Maven 项目中添加以下依赖：

<dependency>
    <groupId>com.netflix.hystrix</groupId>
    <artifactId>hystrix-core</artifactId>
    <version>1.5.18</version>
</dependency>

定义熔断命令
继承 HystrixCommand 类并重写 run() 和 getFallback() 方法：

public class MyCommand extends HystrixCommand<String> {
    protected MyCommand() {
        super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
    }

    @Override
    protected String run() throws Exception {
        // 业务逻辑，可能抛出异常
        return "Success";
    }

    @Override
    protected String getFallback() {
        // 熔断后的降级逻辑
        return "Fallback Response";
    }
}

调用熔断命令
通过 execute() 或 queue() 方法触发：

String result = new MyCommand().execute();

配置熔断参数

通过 HystrixCommandProperties 自定义熔断行为：

super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"))
    .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
        .withCircuitBreakerErrorThresholdPercentage(50) // 错误率阈值
        .withCircuitBreakerSleepWindowInMilliseconds(5000) // 熔断恢复时间
    )
);

使用 Resilience4j 实现熔断

Resilience4j 是轻量级的熔断库，适合现代 Java 应用。

添加依赖

<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-circuitbreaker</artifactId>
    <version>1.7.1</version>
</dependency>

配置熔断器

CircuitBreakerConfig config = CircuitBreakerConfig.custom()
    .failureRateThreshold(50) // 错误率阈值
    .waitDurationInOpenState(Duration.ofMillis(1000)) // 熔断持续时间
    .build();

CircuitBreaker circuitBreaker = CircuitBreaker.of("serviceName", config);

包装方法调用
使用 CircuitBreaker 装饰函数：

如何熔断 java

Supplier<String> decoratedSupplier = CircuitBreaker
    .decorateSupplier(circuitBreaker, () -> "Service Response");

String result = Try.ofSupplier(decoratedSupplier)
    .recover(throwable -> "Fallback Response").get();