Hystrix断路器

1. Hystrix断路器简介

hystrix对应的中文名字是"豪猪"，豪猪周身长满了刺，能保护自己不受天敌的伤害，代表了一种防御机制，这与hystrix本身的功能不谋而合，因此Netflix团队将该框架命名为Hystrix，并使用了对应的卡通形象做作为logo。

在一个分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等，如何能够保证在一个依赖出问题的情况下，不会导致整体服务失败，这个就是Hystrix需要做的事情。Hystrix提供了熔断、隔离、Fallback、cache、监控等功能，能够在一个、或多个依赖同时出现问题时保证系统依然可用。

2. 服务雪崩效应

1.1 当一个请求依赖多个服务的时候：正常情况下的访问

1.2 当请求的服务中出现无法访问、异常、超时等问题时，那么用户的请求将会被阻塞

1.3 如果多个用户的请求中，都存在无法访问的服务，那么他们都将陷入阻塞的状态中

2.1 Hystrix的引入，可以通过服务熔断和服务降级来解决这个问题

3. Hystrix服务熔断和服务降级

Hystrix服务熔断@HystrixCommand
Hystrix服务降级fallbackMethod

熔断机制是应对雪崩效应的一种微服务链路保护机制。
当某个服务不可用或者响应时间超时，会进行服务降级，进而熔断该节点的服务调用，快速返回自定义的错误影响页面信息。

4. Hystrix服务熔断和服务降级实例

4.1) 带服务熔断的服务提供者项目microservice-student-provider-hystrix-1004搭建

new -> Maven Module
    -> create a simple project
Module Name:microservice-student-provider-hystrix-1004
Parent Project:microservice
Working set:SpringCloud
    -> Artifact
Group Id:com.andrew.springcloud
Artifact Id:microservice-student-provider-hystrix-1004
Version:0.0.1-SNAPSHOT
Packaging:jar

代码与microservice-student-provider-1001相同

4.2) 带服务熔断的服务提供者项目microservice-student-provider-hystrix-1004的pom.xml增加hystrix依赖

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

4.3) 带服务熔断的服务提供者项目microservice-student-provider-hystrix-1004的application.yml修改下端口和实例名称

port: 1004
 instance-id: microservice-student-hystrix:1004 #客户端实例名称

4.4) 带服务熔断的服务提供者项目microservice-student-provider-hystrix-1004的启动类StudentProviderHystrixApplication_1004.java增加注解@EnableCircuitBreaker和getInfo方法

@ResponseBody
@GetMapping(value="/getInfo")
@HystrixCommand(fallbackMethod="getInfoFallback")
public Map<String,Object> getInfo() throws InterruptedException{
    Thread.sleep(2000);
    Map<String,Object> map=new HashMap<String,Object>();
    map.put("code", 200);
    map.put("info", "业务数据xxxxx");
    return map;
}
public Map<String,Object> getInfoFallback() throws InterruptedException{
    Map<String,Object> map=new HashMap<String,Object>();
    map.put("code", 500);
    map.put("info", "系统出错，稍后重试");
    return map;
}

4.5) 服务消费者microservice-student-consumer-80的StudentConsumerController.java增加getInfo方法

@SuppressWarnings("unchecked")
@GetMapping(value="/getInfo")
@ResponseBody
public Map<String,Object> getInfo(){
    return restTemplate.getForObject(PRE_HOST+"/student/getInfo/", Map.class);
}

正常访问返回的是200业务数据xxxxx
这里使用Thread.sleep(2000)模拟超时
加上@HystrixCommand注解以及fallbackMethod表明这个方法在没有异常以及没有超时(hystrix默认1秒算超时)的情况，才返回正常的业务数据；
否则进入fallback指定的本地方法

启动microservice-eureka-server-2001
启动microservice-eureka-server-2002
启动microservice-eureka-server-2003
启动microservice-student-provider-hystrix-1004
启动microservice-student-consumer-80

测试服务提供者：
http://localhost/student/getInfo

使用Thread.sleep(500);测试正常
{"code":200,"info":"业务数据xxxxx"}

使用Thread.sleep(2000);测试超时
{"code":500,"info":"系统出错，稍后重试"}

5. hystrix默认超时时间的设置

Hystrix默认超时时间是1秒，我们可以通过hystrix源码看到
hystrix-core.jar
  -> com.netflix.hystrix
    -> HystrixCommandProperties类
      -> default_executionTimeoutInMilliseconds属性 默认的超时时间

5.1) 带服务熔断的服务提供者项目microservice-student-provider-hystrix-1004修改application.yml配置

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 3000

启动microservice-eureka-server-2001
启动microservice-eureka-server-2002
启动microservice-eureka-server-2003
启动microservice-student-provider-hystrix-1004
启动microservice-student-consumer-80

测试服务提供者：
http://localhost/student/getInfo

使用Thread.sleep(2000);测试正常
{"code":200,"info":"业务数据xxxxx"}

使用Thread.sleep(4000);测试超时
{"code":500,"info":"系统出错，稍后重试"}