Hystrix-断路器核心原理

0. 前言

SpringBoot版本：2.1.9.RELEASE
SpringCloud版本：Greenwich.SR4

1. HystrixCircuitBreaker

public interface HystrixCircuitBreaker {// 是否允许请求public boolean allowRequest();// 断路器是否开启public boolean isOpen();// 关闭断路器void markSuccess();}

2. HystrixCircuitBreakerImpl

static class HystrixCircuitBreakerImpl implements HystrixCircuitBreaker {// 熔断配置信息private final HystrixCommandProperties properties;// 熔断指标信息private final HystrixCommandMetrics metrics;// 断路器是否开启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;}public void markSuccess() {if (circuitOpen.get()) {// 如果断路器开启，则关闭if (circuitOpen.compareAndSet(true, false)) {// 重置熔断指标信息metrics.resetStream();}}}@Overridepublic boolean allowRequest() {if (properties.circuitBreakerForceOpen().get()) {// 如果配置了断路器强制开启，返回 false 不允许发起请求return false;}if (properties.circuitBreakerForceClosed().get()) {// 如果配置了断路器强制关闭，返回 true 允许发起请求// 但是还是要调用 isOpen() 方法处理断路器相关信息isOpen();return true;}// 两个条件满足其一则允许请求：//     1. 断路器认为是关闭的//     2. 允许尝试一次请求return !isOpen() || allowSingleTest();}public boolean allowSingleTest() {long timeCircuitOpenedOrWasLastTested = circuitOpenedOrLastTestedTime.get();if (circuitOpen.get() && System.currentTimeMillis() > timeCircuitOpenedOrWasLastTested + properties.circuitBreakerSleepWindowInMilliseconds().get()) {if (circuitOpenedOrLastTestedTime.compareAndSet(timeCircuitOpenedOrWasLastTested, System.currentTimeMillis())) {// 断路器开启后，每隔一定时间（默认5s）允许尝试一次请求return true;}}return false;}@Overridepublic boolean isOpen() {if (circuitOpen.get()) {// 断路器开启，返回 truereturn true;}// 获取健康指标信息HealthCounts health = metrics.getHealthCounts();if (health.getTotalRequests() < properties.circuitBreakerRequestVolumeThreshold().get()) {// 如果在最近10s（默认）请求总数小于20次（默认）// 则认为断路器是关闭的return false;}if (health.getErrorPercentage() < properties.circuitBreakerErrorThresholdPercentage().get()) {// 如果在最近10s（默认）请求失败率小于50%（默认）// 则认为断路器是关闭的 return false;} else {// 记录断路器状态为开启if (circuitOpen.compareAndSet(false, true)) {circuitOpenedOrLastTestedTime.set(System.currentTimeMillis());return true;} else {return true;}}}}

3. 总结

断路规则：
断路器开启后，单位时间内允许尝试一次请求：

学习参考：掘金小册《SpringCloudNetflix 源码解读与原理分析》

Hystrix-断路器核心原理相关推荐

Hystrix面试 - 深入 Hystrix 断路器执行原理
Hystrix面试 - 深入 Hystrix 断路器执行原理 RequestVolumeThreshold HystrixCommandProperties.Setter().withCircuitB ...
Hystrix断路器执行原理
深入 Hystrix 断路器执行原理 Hystrix熔断机制,用于监控微服务调用情况,当失败的情况达到预定的阈值(5秒失败20次),会打开断路器,拒绝所有请求,直到服务恢复正常为止. circuitB ...
深入 Hystrix 断路器执行原理
本系列内容转载自git项目advancejava RequestVolumeThreshold HystrixCommandProperties.Setter().withCircuitBreaker ...
Hystrix核心原理和断路器源码解析
Hystrix运行原理构造一个HystrixCommand或HystrixObservableCommand对象执行命令. 检查是否已命中缓存,如果命中直接返回. 检查断路器开关是否打开,如果打开 ...
Hystrix断路器原理
断路器作用断路器的作用在于当一个请求无法进行或者需要暂时屏蔽时,我们可以在请求执行前将这个请求打断,从而达到暂时屏蔽请求的目的.在我们的工作过程中,这样的场景通常表现为一个请求的提供端由于某种原因 ...
Hystrix断路器原理及实现（服务降级、熔断、限流）
Hystrix断路器原理及实现(服务降级.熔断.限流) 分布式系统面临的问题 Hystrix重要概念(面试常考) Hystrix案例 Hystrix 服务提供者 Hystrix 服务消费者原因与解决 ...
Hystrix流程分析及断路器工作原理
上一篇转载的文章主要讲了Hystrix的应用场景.基础组件概念以及从源码的角度阐述了基本应用.本篇文章主要借鉴官方文档介绍Hystrix的工作流程及断路器的原理,最后说一下与SpringCloud的简 ...
Netflix Hystrix断路器简介与工作原理
一.前言? 1.Netflix Hystrix断路器是什么? Netflix Hystrix是SOA/微服务架构中提供服务隔离.熔断.降级机制的工具/框架.Netflix Hystrix是断路器的一种 ...
Spring Cloud构建微服务架构：服务容错保护（Hystrix断路器）【Dalston版】
前言在前两篇<Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)>和<Spring Cloud构建微服务架构:服务容错保护(Hystrix依赖隔离)&g ...
RPC 实战与核心原理分析
RPC 实战与核心原理分析 RPCX是一个分布式的Go语言的 RPC 框架,支持Zookepper.etcd.consul多种服务发现方式,多种服务路由方式, 例子服务端 package maini ...

Hystrix-断路器核心原理

0. 前言

1. HystrixCircuitBreaker

2. HystrixCircuitBreakerImpl

3. 总结

Hystrix-断路器核心原理相关推荐

最新文章

热门文章