多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C有屌用其他的微服务,这就是所谓的“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用,对微服务A的调用就会占用越来越多的系统资源,进而引起系统崩溃,所谓的“雪崩效应”。
Hystrix是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统里,许多依赖不可避免地会调用失败,比如超时、异常等,Hystrix能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,以提高分布式系统的弹性。
“断路器”本身是一种开关装置,当某个服务单元发生故障之后,通过断路器的故障监控(类似熔断保险丝),向调用方返回一个符合预期的、可处理的备选响应(FallBack),而不是长时间的等待或者抛出调用方无法处理的异常,这样就保证了服务调用方的线程不会被长时间、不必要地占用,从而避免了故障在分布式系统的蔓延,乃至雪崩。
39.尚硅谷_SpringCloud_服务熔断熔断机制是应对雪崩效应的一种微服务链路保护机制。
当扇出链路的某个微服务不可用或者响应时间太长时,会进行服务的降级,进而熔断该节点微服务的调用,快速返回“错误”的响应信息。当检测到该节点微服务调用相应正常后恢复调用链路。Hystrix会监控微服务间调用的状况,当失败的调用到一定阈值,缺省是5秒内20次调用失败就会启动熔断机制。
添加GAV依赖;
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix</artifactId> </dependency>主程序上添加开启功能注解
@EnableCircuitBreakerController方法修改,添加注解,并增加返回错误信息的方法;
//一旦调用服务方法失败并抛出了错误信息后,会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法 @HystrixCommand(fallbackMethod = "processHystrix_Get") public Dept processHystrix_Get(@PathVariable("id") Long id) { return new Dept().setDeptno(id).setDname("该ID:" + id + "没有没有对应的信息,null--@HystrixCommand") .setDb_source("no this database in MySQL"); } 40.尚硅谷_SpringCloud_服务降级服务降级就是整体资源快不够了,忍痛将某些服务先关掉,待度过难关,再开启回来。
服务降级处理在客户端实现完成,与服务端没有关系。
实现步骤:
根据已有的接口新建一个实现了FallbackFactory接口的类;
@Component // 不要忘记添加,不要忘记添加 public class DeptClientServiceFallbackFactory implements FallbackFactory<DeptClientService> { @Override public DeptClientService create(Throwable throwable) { return new DeptClientService() { @Override public Dept get(long id) { return new Dept().setDeptno(id).setDname("该ID:" + id + "没有没有对应的信息,Consumer客户端提供的降级信息,此刻服务Provider已经关闭") .setDb_source("no this database in MySQL"); } @Override public List<Dept> list() { return null; } @Override public boolean add(Dept dept) { return false; } }; } }在接口上增加注解信息;
@FeignClient(value = "MICROSERVICECLOUD-DEPT",fallbackFactory=DeptClientServiceFallbackFactory.class)客户端项目增加配置;
feign: hystrix: enabled: true 41.尚硅谷_SpringCloud_服务降级熔断小总结熔断代码在服务端上,降级代码在客户端上。
熔断是代码异常,降级是服务关闭。
42.尚硅谷_SpringCloud_豪猪hystrixDashboard实现步骤:
监控服务、被监控服务添加GAV依赖;
监控服务:
被监控服务:
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>主程序上添加开启功能注解;
@EnableHystrixDashboard访问;
:9001/hystrix 43.尚硅谷_SpringCloud_如何查看hystrixDashboard被监控服务:
:8001/hystrix.stream监控服务:
:9001/hystrix