Hystrix
复杂的分布式体系结构中的应用程序有数十个依赖关系,每个依赖关系在某些时候将不可避免的失败,可能导致系统的级联故障,从而导致系统雪崩。
Hystrix是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统里,许多依赖不可避免的会调用失败,比如超时、异常等,Hystrix能保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,以提高分布式系统的弹性。
“断路器”本身是一种开关装置,当某个服务单元发生故障时,通过断路器的故障监控(类似熔断保险丝),向调用方返回一个符合预期的、可处理的备选响应,而不是长时间的等待或者抛出调用方无法处理的异常,这样就保证了服务调用方的线程不会被长时间的占用、从而避免了故障在分布式系统的蔓延。

使用:
1:maven依赖:
<!-- Hystrix -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
1:服务降级处理:
1.1:springBoot项目主启动类上添加:@EnableHystrix

1.2 调用方法上添加:@HystrixCommand, 并定义处理方法。

如何配置全局服务降级处理?
@DefaultProperties(defaultFallBack = “”)
对于上面每一个方法都配置一个服务降级的方法,技术上可以,但是实现上傻
除了个别的业务有专属的降级方法,其他普通的通过@DefaultProperties(defaultFallBack = “”)统一一个降级方法。
通用的和独享的分开,避免了代码膨胀,合理减少代码量。

服务降级解耦(feign的使用方式):
如果使用feign调用服务需要在yml中开启Hystrix:
# 使feign 启用hystrix
feign:
hystrix:
enabled: true
@Component
@FeignClient(value = "CLOUD-HYSTRIX-PROVIDER-PAYMENT", fallback = PaymentFallBackServiceImpl.class)
public interface IPaymentHystrixServcie {
@GetMapping("payment/hystrix/ok/{id}")
public String paymentInfo(@PathVariable("id") Integer id);
@GetMapping("payment/hystrix/timeout/{id}")
public String paymentInfo_timeout(@PathVariable("id") Integer id);
}
@Component
public class PaymentFallBackServiceImpl implements IPaymentHystrixServcie {
@Override
public String paymentInfo(Integer id) {
return "PaymentFallBackServiceImpl...paymentInfo_ok ,请稍后再试";
}
@Override
public String paymentInfo_timeout(Integer id) {
return "PaymentFallBackServiceImpl。。。paymentInfo_timeout,请稍后再试";
}
}
熔断机制概述:
熔断机制是应对雪崩效应的一种微服务链路保护机制,当扇出链路的某个微服务不可用时或者响应的时间太长,会进行服务的降级,进而熔断该微服务的调用,快熟响应错误的信息。
当检测到该节点微服务调用响应正常后,恢复调用链路。
在springCloud框架里,熔断机制是通过Hystrix实现,Hystrix会监控微服务间的调用状态。
当失败调用到一定的阀值的时候,缺省是10秒内20次请求有10次调用失败(50%),就会启动熔断机制,熔断机制的注解是@HystrixCommand.
// ##########服务熔断########################## @HystrixCommand( fallbackMethod = "paymentCircuitBreaker_fallBack", commandProperties = { @HystrixProperty(name = "circuitBreaker.enabled", value = "true"), // 是否开启断路器(默认是开启的) @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "20"), // 请求次数 @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "5000"), // 时间窗口期 @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50"), // 失败率达到多少跳闸 } ) @GetMapping("payment/circuit/{id}") public String paymentCircuitBreaker(@PathVariable Integer id)
涉及到断路器的三个重要参数:
1:快照时间窗sleepWindowInMilliseconds:断路器确定是否打开需要统计的一些请求和错误数据,而统计的时间范围就是快照时间窗,默认为最近的10秒。
2:请求总阀值requestVolumeThreshold:在快照的时间内,必须满足请求总阀值才有资格熔断,默认是20,意味着在10秒内,如果该hystrix命令的调用次数不足20次,即使所有的请求都失败,断路器都不会断开。
3:错误百分百阀值errorThresholdPercentage:当请求总数在快照时间窗内超过了阀值,并且错误率达到默认的50%这个时候就会将断路器断开。

Hystrix断路器默认10秒内20个请求失败率超过50%,则断路器将会开启,当开启的时候所有的请求都不会进行转发,一段时间后(默认是5秒),这个时候断路器半开的状态,会让其中 的一个请求进行转发,如果成功,断路器会关闭,如失败继续开启,直到有请求能成功为止。
更多参数配置:https://blog.csdn.net/tongtong_use/article/details/78611225
Hystrix dashboard仪表盘监控
maven 依赖:
<!-- hystrix-dashboard -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
所有的Provider微服务的提供者pom都需要依赖(actuator监控信息完善)
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
原文:https://www.cnblogs.com/dw3306/p/12652689.html