Hystrix是Netflix开源的一个用于处理分布式系统的延迟和容错的库，可以防止系统间的级联失败，保证系统的弹性。Hystrix断路器模式是其核心功能之一。
Hystrix的断路器执行的核心逻辑如下：
- 请求失败率：监控间隔时间内，调用失败的次数除以总调用次数，如果超过预设的阈值，则触发断路器打开。
- 熔断：一旦断路器打开，后续的请求不再执行，直接 fallback。
- 半开：在一定时间后，断路器会尝试进入半开状态，允许少量请求通过，如果这些请求都成功，则关闭断路器，否则重新触发断路器打开。
以下是一个简单的使用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会执行备用方案并打印出来。