Spring Cloud学习 之 Spring Cloud Hystrix（断路器原理）
2024-08-28 05:08:09
断路器定义：
public interface HystrixCircuitBreaker {
// 每个Hystrix都通过它判断是否被执行
public boolean allowRequest();
// 返回当前断路器是否打开
public boolean isOpen();
// 用来闭合断路器
void markSuccess();
public static class Factory {
// 维护了一个Hystrix命令与HystrixCircuitBreaker的关系
// String类型的key通过HystrixCommandKey定义
private static ConcurrentHashMap<String, HystrixCircuitBreaker> circuitBreakersByCommand = new ConcurrentHashMap<String, HystrixCircuitBreaker>();
public static HystrixCircuitBreaker getInstance(HystrixCommandKey key, HystrixCommandGroupKey group, HystrixCommandProperties properties, HystrixCommandMetrics metrics) {
HystrixCircuitBreaker previouslyCached = circuitBreakersByCommand.get(key.name());
if (previouslyCached != null) {
return previouslyCached;
}
HystrixCircuitBreaker cbForCommand = circuitBreakersByCommand.putIfAbsent(key.name(), new HystrixCircuitBreakerImpl(key, group, properties, metrics));
if (cbForCommand == null) {
return circuitBreakersByCommand.get(key.name());
} else {
return cbForCommand;
}
}
public static HystrixCircuitBreaker getInstance(HystrixCommandKey key) {
return circuitBreakersByCommand.get(key.name());
}
static void reset() {
circuitBreakersByCommand.clear();
}
}
static class HystrixCircuitBreakerImpl implements HystrixCircuitBreaker {
// 断路器对应的HystrixCommand实例的属性对象
private final HystrixCommandProperties properties;
// 用来让HystrixCommand记录各类度量指标的对象
private final HystrixCommand记录各类度量指标的对象Metrics metrics;
// 断路器是否打开的标志，默认未false
private AtomicBoolean circuitOpen = new AtomicBoolean(false);
// 断路器上次打开的时间戳
private AtomicLong circuitOpenedOrLastTestedTime = new AtomicLong();
protected HystrixCircuitBreakerImpl(HystrixCommandKey key, HystrixCommandGroupKey commandGroup, HystrixCommandProperties properties, HystrixCommandMetrics metrics) {
this.properties = properties;
this.metrics = metrics;
}
// 在半开路的情况下使用，若Hystrix命令调用成功，通过调用它将打开的断路器关闭
// 并重置度量指标
public void markSuccess() {
if (circuitOpen.get()) {
if (circuitOpen.compareAndSet(true, false)) {
metrics.resetStream();
}
}
}
// 判断请求是否被允许，先根据配置对象中断路器
@Override
public boolean allowRequest() {
if (properties.circuitBreakerForceOpen().get()) {
// 配置了强制打开，直接返回false
return false;
}
if (properties.circuitBreakerForceClosed().get()) {
// 配置了强制关闭，会允许所有请求，但同时也会调用isOpen()来执行断路器的计算逻辑
isOpen();
return true;
}
// 默认情况下，会用过!isOpen() || allowSingleTest()，来判断请求是否被允许
// 也就是说，断路器闭合，或者断路器关闭，但是allowSingleTest()为true
return !isOpen() || allowSingleTest()，;
}
public boolean allowSingleTest() {
long timeCircuitOpenedOrWasLastTested = circuitOpenedOrLastTestedTime.get();
// 断路器打开的情况下，每隔一段事件允许请求一次，默认为5s
// 此时断路器处于一个半开路的状态下
if (circuitOpen.get() && System.currentTimeMillis() > timeCircuitOpenedOrWasLastTested + properties.circuitBreakerSleepWindowInMilliseconds().get()) {
if (circuitOpenedOrLastTestedTime.compareAndSet(timeCircuitOpenedOrWasLastTested, System.currentTimeMillis())) {
return true;
}
}
return false;
}
// 判断当前断路器是否打开
@Override
public boolean isOpen() {
if (circuitOpen.get()) {
// 如果断路器打开的标志为true就直接返回true,，表示断路器在打开状态
return true;
}
// 否则从度量指标对象中获取HealthCounts统计对象做进一步判断（该对象记录了一个滚动事件窗内 的请求信息快照，默认时间窗为10秒）
HealthCounts health = metrics.getHealthCounts();
if (health.getTotalRequests() <
//如果他的QPS在预设的阈值范围内就返回false,表示断路器处于闭合状态。
//该值的默认值为20
properties.circuitBreakerRequestVolumeThreshold().get()) {
return false;
}
if (health.getErrorPercentage() <
// 错误百分比在阈值内就返回false,该阈值默认为50%
properties.circuitBreakerErrorThresholdPercentage().get()) {
return false;
} else {
// 如果上面两个参数都不满足，就打开断路器
if (circuitOpen.compareAndSet(false, true)) {
circuitOpenedOrLastTestedTime.set(System.currentTimeMillis());
return true;
} else {
return true;
}
}
}
}
// 定义了一个什么都不做的断路器
static class NoOpCircuitBreaker implements HystrixCircuitBreaker {
@Override
public boolean allowRequest() {
return true;
}
@Override
public boolean isOpen() {
return false;
}
@Override
public void markSuccess() {
}
}
}
最新文章
- ffmpeg-20160926[27]-bin.7z
- DATE 日期格式
- JavaEE 获取路径全攻略
- Spring AOP中定义切点（PointCut）和通知（Advice）
- fmri当前相关软件工具整理
- 你真的精通Java吗？
- Android下得到已安装Application信息
- unity A*寻路 （一）导出NavMesh数据
- READ TABLE 的用法
- 初识 MongoDB，MongoDB 的安装运行
- 【读书笔记】iOS-离线可用的Web应用
- Python + Selenium WebDriver Api 知识回顾
- Redis缓存穿透、缓存雪崩、redis并发问题分析
- e783. 监听对JList中项双击和三击
- sqlmap参数
- webservice 菜鸟探索之旅
- ElasticSearch异常归纳(能力工场小马哥)
- Java并发（二）多线程的好处
- ABP zero出现Default language is not defined!的错误的解决方法
- SpringMVC 的使用映射路径展示文件服务器上的图片