Spring Cloud:Hystrix服务熔断

熔断

熔断机制是应对雪崩效应的一种微服务链路保护机制,当扇出链路的某个微服务出错不可用或者响应时间太长时,会进行服务降级,进而熔断该节点微服务调用,快速返回错误的相应信息。
Spring Cloud中,熔断机制可以通过Hystrix实现,Hystrix可以监控微服务间调用的情况。当失败的调用到一定阈值,缺省是5秒内20次调用失败,就会启动熔断机制,熔断机制的注解是@HystrixCommand。
当启动熔断机制后,后续对该服务接口的调用不再经过网络,直接执行本地的默认方法,达到服务降级的效果。
经过了规定的时间窗口后,服务将从熔断状态恢复过来,再次接受调用方的远程调用。

官网原图:

以下是大致流程(画图工具做的,较为简陋)

熔断类型

熔断打开:请求不再调用当前服务,内部设置时间窗口一般为MTTR(平均故障处理时间),当打开市场达到所设时间窗口则进入半熔断状态。
熔断关闭:熔断关闭不会对服务进行熔断。
熔断半开:部分请求根据规则调用当前服务,如果请求成功且符合规则认为当前服务恢复正常,关闭熔断。

Hystrix实现熔断机制

service

    //========================服务熔断=====================
    @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback",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 paymentCircuitBreaker(Integer id){
        if(id<0){
            throw new RuntimeException("id<0");
        }
        String serialNumber = IdUtil.simpleUUID();
        return Thread.currentThread().getName()+"	"+"调用成功,流水号:"+serialNumber;
    }

    public String paymentCircuitBreaker_fallback(Integer id){
        return "id<0"+":"+id;
    }

controller

@RestController
public class PaymentController {
    @Autowired
    private PaymentService paymentService;

    @GetMapping("/payment/hystrix/breaker/{id}")
    public String paymentCircuitBreaker(@PathVariable Integer id){
        return paymentService.paymentCircuitBreaker(id);
    }
}

上述代码,当请求id小于0时,抛出异常,大于0时,请求正常。
效果:当我连续多次请求id等于负数的请求后,发现短暂时间内,请求id等于整数的发现服务仍然降级了,但是过了一会,请求整数id又成功了,说明服务熔断触发。
熔断触发图:

恢复:

hystrix配置属性

hystrix配置属性主要在HystrixCommandProperties.class中有详细记载:

原文地址:https://www.cnblogs.com/wwjj4811/p/13622247.html