微服务 Hystrix 实现服务熔断

2020-10-10 11:11:10 浏览数 (3)

什么是熔断器

一句话就是家里的保险丝。

代码实现

使用注解 @HystrixCommand 实现熔断器。

代码语言:javascript复制
/**
 * 服务熔断
 *  在时间窗口期内如果又可以了,那么再次打开开关
 * @param id ID
 * @return 返回提示信息
 */
@HystrixCommand(fallbackMethod = "paymentCircuitBreakerFallback",
        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不能为负数!");
    }
    return "调用成功";
}
public String paymentCircuitBreakerFallback(Integer id) {
    return "Id 不能为负数,请稍后再试: id = "   id;
}

其中 paymentCircuitBreakerFallback 是熔断触发后要执行的方法。

熔断器在什么时候起作用?

熔断器的特点:

  • 如果多次请求错误,然后慢慢的请求真确,也还是访问不到,因为他需要达到一定的正确率才会重新接上熔断的结果。

熔断器开启和关闭的条件:

  1. 当满足一定阀值的时候(默认 10 秒内超过 20 个请求次数);
  2. 当失败率达到一定的时候(默认 10 秒内超过 50% 请求失败);
  3. 到达以上阀值,断路器将会开启;
  4. 当开启的时候,所有请求都不会进行转发,而是执行 服务降级方法
  5. 一段时间之后(默认是 5 秒),这个时候断路器是 半开状态 ,会 让其中一个请求进行转发 。如果成功,断路器会关闭,若失败,继续开启。重复 4 和 5 。

@HystrixCommand 注解完整的配置信息如下:

0 人点赞