Hystrix简介
多个微服务之间调用的时候,微服务A调用微服务B,微服务B调用微服务C,如果微服务C出现问题或者响应时间过长,就会导致微服务A占用越来越多的系统资源,进而导致系统崩溃,称为服务雪崩
Hystrix是什么
Hystrix是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统,许多依赖不可避免的会调用失败,比如超时、异常等,Hystrix能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,以提高分布式系统的弹性,”断路器”本身是一种开关装置,当某个服务单元发生故障之后,通过断路器的故障监控,向调用方返回一个符合预期的、可处理的备选响应(FallBack),而不是长时间等待或抛出调用方无法处理的异常,保证了调用方的线程不会被长时间的占用,从而避免了故障在分布式系统中的蔓延,乃至雪崩
作用
- 服务熔断 当下游的服务因为某种原因不可用,上游服务为了保证自己整体服务可用,不再继续调用目标服务,直接返回,快速释放资源,类似于保险丝,当某个异常条件被触发时,直接熔断整个服务,而不是一直等到此服务超时,用于应对雪崩效应的一种保护机制,注解是@HystrixCommand,失败次数达到一定阈值,就会启动熔断,当检测到该服务响应正常后,则恢复调用
- 服务降级 当下游的服务因为某种原因不可用,上游服务主动调用本地的一些降级逻辑,快速返回给用户,防止卡顿,熔断会导致服务降级,从而调用fallback,返回一个缺省值,虽然服务水平下降,但是不会导致整体挂掉。
- 服务限流 防止高并发情况下所有请求一窝蜂地全部打到服务上,导致服务崩溃
依赖
1 2 3 4 5
| <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix</artifactId> </dependency>
|
如果是F版及以上的话,需要使用该依赖
1 2 3 4 5
| <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
|
服务端使用hystrix
启动Hystrix
1 2 3 4 5 6 7 8 9
| @SpringBootApplication @EnableEurekaClient @EnableHystrix public class HystrixProviderApp {
public static void main(String[] args) { SpringApplication.run(HystrixProviderApp.class,args); } }
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
| @RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET) @HystrixCommand(fallbackMethod = "fallback_get") public Dept get(@PathVariable("id") Long id) { Dept dept = deptService.get(id); if(dept == null){ throw new RuntimeException("部门信息不存在"); } return dept; }
public Dept fallback_get(@PathVariable("id") Long id){ Dept dept = new Dept(); dept.setDeptNo(id); dept.setdName("信息不存在@HystrixCommand"); return dept; }
|
由于每个方法上都要配置fallback方法,导致了代码的过度膨胀,可以在接口类上配置一个全局的默认fallback
1
| @DefaultProperties(defaultFallback="defaultFallback")
|
如果方法上有fallback,走方法上的;如果方法上没有,则走类上的全局默认fallback
客户端使用hystrix
由于服务端的降级需要对每个方法进行@HystrixCommand配置,并且声明一个fallback回调方法,过于耦合,所以可以使用客户端来进行解耦
使用feign搭配hystrix来进行服务降级
1 2 3 4 5 6 7
| @FeignClient(value = "MICRO-SERVICE-DEPT-PROVIDER",fallbackFactory = DeptClientFallBackFactory.class) public interface DeptClient {
@RequestMapping(value = "/dept/get/{id}",method = RequestMethod.GET) Dept get(@PathVariable("id") long id); }
|
回调工厂当出现错误时,会执行对应的方法
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
| @Component public class DeptClientFallBackFactory implements FallbackFactory<DeptClient> {
@Override public DeptClient create(Throwable throwable) { return new DeptClient() { @Override public Dept get(long id) { Dept dept = new Dept(); dept.setDeptNo(id); dept.setdName("信息不存在fallback"); return dept; } }; } }
|
配置
1 2 3
| feign: hystrix: enabled: true
|