什么是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