Hystrix是一个用于处理分布式系统延迟和容错的开源库，在分布式系统中，许多依赖会不可避免的调用失败，比如超时、异常等。Hystrix能够保证一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性。

断路器本身是一种开关装置，当某个服务单元发送故障之后，通过断路器的故障监控（类似熔断保险丝），向调用方返回一个符合预期的、可处理的备选响应(FalBack)，而不是长时间的等待或者抛出调用方无法处理的异常。这样就保证了服务调用方线程不会被长时间、不必要的占用，从而避免了故障在分布式系统中的蔓延、乃至雪崩。

序 服务熔断和服务降级的区别

白话：服务降级与熔断的区别

主逻辑失败而采用备用逻辑的过程，叫做服务降级。
而主逻辑由于多次失败，会被暂时性忽略，不再尝试调用，叫做服务熔断。

注：服务降级和熔断都是服务调用者端实现来完成的，与服务提供者无关！

1. 服务熔断

1.1 什么叫做服务熔断

熔断服务时针对雪崩效应的一种微服务链路保护机制。当扇出链路的某个微服务不可用或者响应时间太长，会进行服务的降级——进而熔断微服务的调用，快速返回错误的响应信息。当检测到该节点微服务调用响应正常后恢复调用链路。在SpringCloud框架中熔断机制是通过Hystrix实现。Hystrix会监控微服务间调用的状态，当失败的调用到达一定的阈值(缺省是5s内20次调用失败就启用熔断机制)就会启动熔断机制。熔断机制的注解时@HystrixCommand。

1.2 SpringCloud如何实现

服务降级和熔断是客户端实现的，与服务提供者无关！

1. maven依赖

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

2. 主启动类上注解

@EnableCircuitBreaker注解开启熔断

3. 实现类上添加@HystrixCommand完成服务熔断

当服务调用异常时，会向调用方返回一个符合预期的、备选的调用方案。

@Override
    @HystrixCommand(fallbackMethod = "backupCall")
    public String call(String name) {
        ResponseEntity resultResponseEntity = restTemplate.postForEntity(appServiceUrl + "hello?name=" + name, null, String.class);
        if (resultResponseEntity != null && resultResponseEntity.getBody() != null) {
            return name + " says: " + resultResponseEntity.getBody().toString();
        }
        return null;
    }

    public String backupCall(String name) {
        return "Hi, I'm Hystix.";
    }

若是我们将服务提供者服务停掉，服务调用者调用得到异常后，即主逻辑失败，会重新调用备选逻辑。

1.3 降级的全局处理

若是每个方法上都使用@HystrixCommand注解，虽然可以实现服务降级以及熔断，但是会造成代码的过于臃肿。有什么方式可以实现降级的全局处理呢？

依靠于Feign，实现降级的全局处理。

1. 新增maven依赖

    <dependencies>
        <!--集成eureka client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--集成web-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--Fegin依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>

2. yml配置

server:
  port: 82

#本机服务名
spring:
  application:
    name: microservicecloud-consumer-fegin-82

#注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7000/eureka #单机版
    register-with-eureka: false #不需要注册

#开启熔断器
feign:
  hystrix:
    enabled: true

3. 主启动类

@SpringBootApplication(scanBasePackages = {"com.galax"})
@EnableEurekaClient
@EnableDiscoveryClient  //服务发现
@EnableFeignClients  //开启Fegin
public class Consumer_Feign_82 {
   public static void main(String[] args)
   {
       SpringApplication.run(Consumer_Feign_82.class, args);
   }
}

4. 在service中配置熔断请求

//value是服务提供者的application.name
@FeignClient(value = "microservicecloud-provider",fallbackFactory = ClientFallbackFactory.class)
public interface XxxtService {
    @RequestMapping("/XXX/getAxx")
    String getAccount();
}

@Component  //必须要使用Client
public class ClientFallbackFactory implements FallbackFactory<XxxService> {
    @Override
    public XxxService create(Throwable throwable) {
        return new XxxService() {
            @Override
            public String getXxx() {
                return "开启服务降级~";
            }
        };
    }
}

文章参考

Hystrix官网配置

Greenwich.SR2版本的Spring Cloud Hystrix实例