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 "开启服务降级~";
}
};
}
}
