Java SpringCloud Hystrix
服务熔断 类似现实生活中的“保险丝“,当某个异常条件被触发,直接熔断保险丝来起到保护电路的作用,
熔断的触发条件可以依据不同的场景有所不同,比如统计一个时间窗口内失败的调用次数。
断路器状态机

Closed:熔断器关闭状态(所有请求返回成功)
Open:熔断器打开状态(调用次数累计到达阈值或者比例,熔断器打开,服务直接返回错误)
Half Open:熔断器半开状态(默认时间过后,进入半熔断状态,允许定量服务请求,如果调用都成功,则认为恢复了,则关闭断路器,反之打开断路器)
断路器原理
(不让客户端“裸调“服务器的rpc接口,而是在客户端包装一层。就在这个包装层里面,实现熔断逻辑)
public class CommandHelloWorld extends HystrixCommand<String> {private final String name;public CommandHelloWorld(String name) {super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));this.name = name;}@Overrideprotected String run() {//关键点:把一个RPC调用,封装在一个HystrixCommand里面return "Hello " + name + "!";}}
客户端调用:以前是直接调用远端RPC接口,现在是把RPC接口封装到HystrixCommand里面,它内部完成熔断逻辑
String s = new CommandHelloWorld("World").execute()
缺省的,上面的HystrixCommand是被扔到一个线程中执行的,也就是说,缺省是线程隔离策略。
还有一种策略就是不搞线程池,直接在调用者线程中执行,也就是信号量的隔离策略。
熔断参数配置
circuitBreaker.requestVolumeThreshold //滑动窗口的大小,默认为20circuitBreaker.sleepWindowInMilliseconds //过多长时间,熔断器再次检测是否开启,默认为5000,即5s钟circuitBreaker.errorThresholdPercentage //错误率,默认50%
每当20个请求中,有50%失败时,熔断器就会打开,此时再调用此服务,将会直接返回失败,不再调远程服务。直到5s钟之后,重新检测该触发条件,判断是否把熔断器关闭,或者继续打开。
案例
@RestController@DefaultProperties(defaultFallback = "defaultFallback")public class FeignClientTestController {@HystrixCommand(commandProperties = {@HystrixProperty(name = "circuitBreaker.enabled",value = "true"),@HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),@HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"),@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60")})public String serverMethod() {return null;}public String defaultFallback() {return "服务器开小差了";}}
总结
服务降级:当服务内部出现异常情况,将触发降级,这个降级是每次请求都会去触发,走默认处理方法**defaultFallback**
服务熔断:在一定周期内,服务异常次数达到设定的阈值或百分比,则触发熔断,熔断后,后面的请求将都走默认处理方法**defaultFallback**
