Hystrix —— SpringCloud(五)

什么是Hystrix?

  Hystrix,英文意思是豪猪。

  Hystrix是Netflix公司的一款组件,是一种保护机制。

  Hystix是Netflix开源的一个延迟和容错库,用于隔离访问远程服务、第三方库、防止出现级联失败。

什么是雪崩问题?

  微服务中,服务之间的调用关系错综复杂,一个请求,可能需要调用多个微服务接口才能实现,会形成非常复杂的调用链路。

  例如,当一个微服务发生了异常,请求阻塞,用户得不到响应,则Tomcat这个线程不会释放,于是越来越多的用户请求到来,越来越多的线程阻塞。

  服务器支持的线程和并发数有限,请求一直阻塞,会导致服务器的资源耗尽,从而导致其他服务都不可用,形成雪崩效应。

  

如何解决雪崩问题?

  Hystix解决雪崩问题的方法有两个:

    线程隔离

    服务熔断

线程隔离,服务降级

  Hystrix为每个依赖服务分配一个小的线程池,如果线程池调用已满就立即拒绝,默认不采用排队,加速失败判定时间。

  用户的请求将不再直接访问服务,而是通过线程池中空闲的线程来访问服务。

  如果线程池已满,或者请求超时,则会进行降级处理。

  所谓服务降级,就是优先保证核心服务,而非核心服务不可用或者弱可用。

  用户的请求故障时,不会被阻塞,也不会无休止的等待或者系统崩溃,至少可以看到一个执行结果。(返回一个提示信息)

  服务降级虽然会导致请求失败,但是不会导致阻塞,而且最多会影响这个依赖服务对应的线程池中的资源,对其他服务没有影响。

  触发Hystrix服务降级的情况:

    线程池已满

    请求超时

服务熔断

  熔断器,也叫断路器。

  熔断机制的三个状态:

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

    Open:打开状态,所有请求都会被降级。Hystix会对请求情况计数,当一定时间内失败请求百分比达到阈值,则触发熔断,断路器会完全打开。默认失败比例的阈值是百分之五十,请求次数最少不低于二十次。

    Half Open:半开状态,Open状态不是永久的,打开后会进入休眠时间(默认是5s)。随后断路器会自动进入半开状态。此时会释放部分请求通过,如果这些请求都是健康的,则会完全关闭断路器,否则继续保持打开,再次进入休眠计时。

circuitBreaker.requestVolumeThreshold=10      # 触发熔断的最小请求,默认为20
circuitBreaker.sleepWindowInMilliseconds=10000  # 休眠时长,默认是5000毫秒
circuitBreaker.errorThresholdPercentage=50     # 触发熔断的失败请求最小占比,默认百分之五十

Hystrix初步使用

引入依赖

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

 

开启熔断

  在微服务中,经常会引入三个注解:@SpringBootApplication、@EnableDiscoveryClient、@EnableCircuitBreaker。

  于是,Spring提供了一个组合注解:@SpringCloudApplication,用来代替上面三个注解。

编写降级逻辑

@Controller
@RequestMapping("consumer/user")
public class UserController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping
    @ResponseBody
    @HystrixCommand(fallbackMethod = "queryUserByIdFallBack")
    public String queryUserById(@RequestParam("id") Long id) {
        String user = this.restTemplate.getForObject("http://service-provider/user/" + id, String.class);
        return user;
    }

    public String queryUserByIdFallBack(Long id){
        return "请求繁忙,请稍后再试!";
    }
}

  熔断的降级逻辑必须和正常逻辑方法保证,相同的参数列表和返回值声明。

    @HystrixCommand(fallbackMethod="queryByIdFallBack"):用来声明一个降级逻辑的方法。

    @DefaultProperties(defaultFallback = "fallBackMethod"):放在类上,可以指定一个类的全局熔断方法

      @HystrixCommand: 标记该方法采用全局熔断方法

/**
     * 熔断方法
     * 返回值要和被熔断的方法的返回值一致
     * 熔断方法不需要参数
     * @return
     */
    public String fallBackMethod(){
        return "请求繁忙,请稍后再试!";
    }
}

设置超时

  Hystrix的默认超时为一秒,可以通过配置修改这个值。

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 6000 # 设置hystrix的超时时间为6000ms

猜你喜欢

转载自www.cnblogs.com/guancangtingbai/p/12697804.html