「 从0到1学习微服务SpringCloud 」13 断路器Hystrix

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

//添加Hystrix的注解,并指定回调函数
    @HystrixCommand(fallbackMethod = "fallback")
    @RequestMapping("/hys/hi")
    public String sayHi(){
        return hiService.hi();
    }

    /**
     * 上面方法指定的回调函数
     * 当上面的方法出现异常或在指定时间未返回时(默认超时时间1s),会调用此函数
     * @return
     */
    public String fallback(){
        return "用户拥挤,请稍后再试!";
    }

@HystrixCommand(commandProperties = {
   @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value="3000")
},fallbackMethod = "fallback")

@HystrixCommand(commandProperties = {
            //开启熔断
            @HystrixProperty(name = "circuitBreaker.enabled",value="true"),
            //一个rolling window内最小的请求数。 默认20
            // 如果设为20，那么当一个rolling window(统计时间段,默认10s)的时间内收到19个请求，即使19个请求都失败，也不会触发circuit break(熔断)。
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value="10"),
            //触发短路的时间值，当该值设为5000时，则当触发circuit break后的5000毫秒内都会拒绝request，也就是5000毫秒后才会关闭circuit(断路器)。默认5000
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value="10000"),
            //错误比率阀值，如果错误率>=该值，circuit(断路器)会被打开，并短路所有请求触发fallback。默认50
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value="60")
    },fallbackMethod = "fallback")
    @GetMapping("/hys/circuitSayHi")
    public String circuitSayHi(Integer number){
        if(number == 2){
            return "success";
        }
        return hiService.hi();
    }

    public String fallback(Integer number){
        return "用户拥挤,请稍后再试!";
    }

hystrix:
  command:
    default:
      circuitBreaker:
        #开启熔断
        enabled: true
        #滚动窗口中将使断路器跳闸的最小请求数量
        requestVolumeThreshold: 20
        #设置失败百分比的阈值。如果失败比率超过这个值，则断路器跳闸并且进入fallback逻辑
        errorThresholdPercentage : 60
      execution:
        isolation:
          thread:
            #设置调用者执行的超时时间（单位毫秒）
            timeoutInMilliseconds: 2000
     #为某个方法设定特殊的配置 方法名
     circuitSayHi:
           circuitBreaker:
             #开启熔断
             enabled: true
             #滚动窗口中将使断路器跳闸的最小请求数量
             requestVolumeThreshold: 10
             #设置失败百分比的阈值。如果失败比率超过这个值，则断路器跳闸并且进入fallback逻辑
             errorThresholdPercentage : 40
           execution:
             isolation:
               thread:
                 #设置调用者执行的超时时间（单位毫秒）
                 timeoutInMilliseconds: 1000

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

<dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

management:
  endpoints:
      web:
        exposure:
          # 开启指定端点
          include: 'hystrix.stream'