Hystrix断路器执行原理

Hystrix是Netflix开源的一个用于处理分布式系统的延迟和容错的库，可以防止系统间的级联失败，保证系统的弹性。Hystrix断路器模式是其核心功能之一。

Hystrix的断路器执行的核心逻辑如下：

1. 请求失败率：监控间隔时间内，调用失败的次数除以总调用次数，如果超过预设的阈值，则触发断路器打开。
2. 熔断：一旦断路器打开，后续的请求不再执行，直接 fallback。
3. 半开：在一定时间后，断路器会尝试进入半开状态，允许少量请求通过，如果这些请求都成功，则关闭断路器，否则重新触发断路器打开。

以下是一个简单的使用Hystrix Command的例子：

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
 
public class HelloWorldCommand extends HystrixCommand<String> {
    private final String name;
 
    public HelloWorldCommand(String name) {
        super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
        this.name = name;
    }
 
    @Override
    protected String run() {
        // 模拟长时间执行的操作
        return "Hello " + name + "!";
    }
 
    @Override
    protected String getFallback() {
        // 当执行失败时，返回的备用响应
        return "Hello Fail " + name + "!";
    }
}
 
// 使用示例
public class HystrixTest {
    public static void main(String[] args) {
        HelloWorldCommand command = new HelloWorldCommand("World");
        String result = command.execute(); // 同步执行
        // 或者使用
        // String result = command.queue().get(); // 异步执行
        System.out.println(result);
    }
}

在这个例子中，HelloWorldCommand继承自HystrixCommand，并实现了run()方法来执行主逻辑，实现了getFallback()方法作为备用执行方案。当run()方法执行失败或者超时时，Hystrix会执行备用方案并打印出来。