网站运营经理,岳阳卖房网站,wordpress手机顶部菜单,wordpress合并压缩文章目录 1、实现原理2、DegradeSlot类3、CircuitBreaker4、触发断路器 1、实现原理
Sentinel的降级是基于状态机来实现的#xff1a; 2、DegradeSlot类
熔断降级的逻辑在DegradeSlot类中实现#xff0c;核心API#xff1a;
Override
public void entry(Context context,… 文章目录 1、实现原理2、DegradeSlot类3、CircuitBreaker4、触发断路器 1、实现原理
Sentinel的降级是基于状态机来实现的 2、DegradeSlot类
熔断降级的逻辑在DegradeSlot类中实现核心API
Override
public void entry(Context context, ResourceWrapper resourceWrapper, DefaultNode node, int count, boolean prioritized, Object... args) throws Throwable {// 熔断降级规则判断performChecking(context, resourceWrapper);// 继续下一个slotfireEntry(context, resourceWrapper, node, count, prioritized, args);
}继续进入performChecking方法
void performChecking(Context context, ResourceWrapper r) throws BlockException {// 获取当前资源上的所有的断路器 CircuitBreakerListCircuitBreaker circuitBreakers DegradeRuleManager.getCircuitBreakers(r.getName());if (circuitBreakers null || circuitBreakers.isEmpty()) {return;}for (CircuitBreaker cb : circuitBreakers) {// 遍历断路器逐个判断if (!cb.tryPass(context)) {throw new DegradeException(cb.getRule().getLimitApp(), cb.getRule());}}
}3、CircuitBreaker
进入断路器类CircuitBreaker的tryPass方法中
Override
public boolean tryPass(Context context) {// 判断状态机状态if (currentState.get() State.CLOSED) {// 如果是closed状态直接放行return true;}if (currentState.get() State.OPEN) {// 如果是OPEN状态断路器打开// 继续判断OPEN时间窗是否结束如果是则把状态从OPEN切换到 HALF_OPEN返回truereturn retryTimeoutArrived() fromOpenToHalfOpen(context);}// OPEN状态并且时间窗未到返回falsereturn false;
}有关时间窗的判断在retryTimeoutArrived()方法
protected boolean retryTimeoutArrived() {// 当前时间 大于 下一次 HalfOpen的重试时间return TimeUtil.currentTimeMillis() nextRetryTimestamp;
}OPEN到HALF_OPEN切换在fromOpenToHalfOpen(context)方法
protected boolean fromOpenToHalfOpen(Context context) {// 基于CAS修改状态从 OPEN到 HALF_OPENif (currentState.compareAndSet(State.OPEN, State.HALF_OPEN)) {// 状态变更的事件通知notifyObservers(State.OPEN, State.HALF_OPEN, null);// 得到当前资源Entry entry context.getCurEntry();// 给资源设置监听器在资源Entry销毁时资源业务执行完毕时触发entry.whenTerminate(new BiConsumerContext, Entry() {Overridepublic void accept(Context context, Entry entry) {// 判断 资源业务是否异常if (entry.getBlockError() ! null) {// 如果异常则再次进入OPEN状态currentState.compareAndSet(State.HALF_OPEN, State.OPEN);notifyObservers(State.HALF_OPEN, State.OPEN, 1.0d);}}});return true;}return false;
}到此出现了从OPEN到HALF_OPEN、从HALF_OPEN到OPEN的变化但是还有几个没有
从CLOSED到OPEN从HALF_OPEN到CLOSED
4、触发断路器
请求经过所有插槽 后一定会执行exit方法而在DegradeSlot的exit方法中 会调用CircuitBreaker的onRequestComplete方法。而CircuitBreaker有两个实现 这里以异常比例熔断为例来看进入ExceptionCircuitBreaker的onRequestComplete方法
Override
public void onRequestComplete(Context context) {// 获取资源 EntryEntry entry context.getCurEntry();if (entry null) {return;}// 尝试获取资源中的异常Throwable error entry.getError();// 获取计数器同样采用了滑动窗口来计数SimpleErrorCounter counter stat.currentWindow().value();if (error ! null) {// 如果出现异常则 error计数器 1counter.getErrorCount().add(1);}// 不管是否出现异常total计数器 1counter.getTotalCount().add(1);// 判断异常比例是否超出阈值handleStateChangeWhenThresholdExceeded(error);
}来看阈值判断的方法
private void handleStateChangeWhenThresholdExceeded(Throwable error) {// 如果当前已经是OPEN状态不做处理if (currentState.get() State.OPEN) {return;}// 如果已经是 HALF_OPEN 状态判断是否需求切换状态if (currentState.get() State.HALF_OPEN) {if (error null) {// 没有异常则从 HALF_OPEN 到 CLOSEDfromHalfOpenToClose();} else {// 有一次再次进入OPENfromHalfOpenToOpen(1.0d);}return;}// 说明当前是CLOSE状态需要判断是否触发阈值ListSimpleErrorCounter counters stat.values();long errCount 0;long totalCount 0;// 累加计算 异常请求数量、总请求数量for (SimpleErrorCounter counter : counters) {errCount counter.errorCount.sum();totalCount counter.totalCount.sum();}// 如果总请求数量未达到阈值什么都不做if (totalCount minRequestAmount) {return;}double curCount errCount;if (strategy DEGRADE_GRADE_EXCEPTION_RATIO) {// 计算请求的异常比例curCount errCount * 1.0d / totalCount;}// 如果比例超过阈值切换到 OPENif (curCount threshold) {transformToOpen(curCount);}
}
