天天看点

springcloud学习之hystrix机制

hystrix解决雪崩问题的手段有两个:线程隔离与服务熔断

线程隔离:默认开启线程隔离,为每个服务单独开启自己的thread池。当自己线程池跑满之后不用影响到其他服务的进程。如果没有线程隔离,当一个服务无限制被阻塞的时候,服务器的内存将被占满,会影响到整个项目。

服务熔断:当一些服务符合熔断的机制后,该服务会被熔断,其他服务来访问的时候会快速返回我们自定义的fallback方法,防止线程阻塞。

简单使用hystrix:

1、引入相关依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
           

2、在启动类上增加注释@EnableCircuitBreaker

提示:如果同时使用hystrix、eureka和ribbon可将启动类上的@SpringBootApplication 更换成@SpringCloudApplication 。因为@SpringCloudApplication 包含了这个必要的注释。

3、使用范围:

在方法上使用:

增加@HystrixCommand(fallbackMethod = "fallback")注解,fallbackMethod指定一个自定义方法,用来做熔断时执行的方法。

fallback方法的返回值与参数必须要该方法保持一直,不然会找不到该fallback方法。

在类上使用:

增加@DefaultProperties(defaultFallback = "fallback")注解,defaultFallback与fallbackMethod原理一样,但是自定义的方法不需要参数,返回值默认为String,这样保证符合整个类中的所有方法。

4、由于熔断的请求时间默认为1s,1s无法响应则算入失败计数(熔断原理5)。我们可以更改整个默认时长。

针对不同方法更改时长:

@HystrixCommand(commandProperties = {

        @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")

})

针对类更改时长:在@DefaultProperties注解上增加commandProperties,写法与方法上一致。

针对全局更改时长:在配置文件中

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 5000
           

一般我们只需要更改整个参数即可,当然还有其他参数可以更改,见相关配置6

5、熔断原理

默认20次请求有百分之50的超时,就会打开熔断器。断路器状态:

关闭状态:所有请求正常访问。

打开状态:所有请求会被降级。Hystrix会对请求情况计数,当一定时间内失败请求百分比达到阈值,则触发熔断,断路器会完全关闭。

半开状态:断路打开不是永久的,打开后会进入休眠时间(默认5s),放一定请求通过,再次计数。如果正常则关闭,如果不正常继续保持打开。

6、相关配置

可以更改默认请求次数,百分比等。

 @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"),

 @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),

 @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000")

其他配置项可以进入hystrix包下的HystrixCommandProperties类中寻找。

继续阅读