Hystrix简介

Hystrix简介

多个微服务之间调用的时候，微服务A调用微服务B，微服务B调用微服务C，如果微服务C出现问题或者响应时间过长，就会导致微服务A占用越来越多的系统资源，进而导致系统崩溃，称为服务雪崩

Hystrix是什么

Hystrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统，许多依赖不可避免的会调用失败，比如超时、异常等，Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性，”断路器”本身是一种开关装置，当某个服务单元发生故障之后，通过断路器的故障监控，向调用方返回一个符合预期的、可处理的备选响应(FallBack)，而不是长时间等待或抛出调用方无法处理的异常，保证了调用方的线程不会被长时间的占用，从而避免了故障在分布式系统中的蔓延，乃至雪崩

作用

• 服务熔断 某个服务故障或者异常引起的，类似于保险丝，当某个异常条件被触发时，直接熔断整个服务，而不是一直等到此服务超时，用于应对雪崩效应的一种保护机制，注解是@HystrixCommand，失败次数达到一定阈值，就会启动熔断，当检测到该服务响应正常后，则恢复调用
• 服务降级 熔断会导致服务降级，从而调用fallback，返回一个缺省值，虽然服务水平下降，但是不会导致整体挂掉。
• 服务限流 防止高并发情况下所有请求一窝蜂地全部打到服务上，导致服务崩溃

依赖

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

如果是F版及以上的话，需要使用该依赖

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

服务端使用hystrix

启动Hystrix

@SpringBootApplication
@EnableEurekaClient  // 服务启动后注册到Eureka Server注册中心中
@EnableHystrix  // 启动对于Hystrix的支持
public class HystrixProviderApp {

    public static void main(String[] args) {
        SpringApplication.run(HystrixProviderApp.class,args);
    }
}

@RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET)
@HystrixCommand(fallbackMethod = "fallback_get") // 熔断配置，出现熔断则调用fallbackMethod中配置的方法
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

@DefaultProperties(defaultFallback="defaultFallback")

如果方法上有fallback，走方法上的；如果方法上没有，则走类上的全局默认fallback

客户端使用hystrix

由于服务端的降级需要对每个方法进行@HystrixCommand配置，并且声明一个fallback回调方法，过于耦合，所以可以使用客户端来进行解耦

使用feign搭配hystrix来进行服务降级

// feign接口配置回调工厂
@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);
}

回调工厂当出现错误时，会执行对应的方法

@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;
            }
        };
    }
}

配置

feign:
  hystrix:
    enabled: true