复杂分布式架构通常都具有很多依赖,当一个应用高度耦合其他服务时非常危险且容易导致失败,当某一个服务发生故障,导致请求延迟,将可能会在数秒内导致所有应用资源被耗尽。
在系统高峰时期,大量对微服务的调用可能会堵塞远程服务器的线程池,如果整个线程池没有和主应用服务器的线程池隔离,就可能会导致整个服务器挂机。
Hystrix使用自己的线程池,这样和主应用服务器线程池隔离,如果调用花费很长时间,会停止调用,不同的命令或命令组能够被配置使用它们各自的线程池,可以隔离不同的服务。
熔断器的原理
原理很简单,就像家里的电闸一样,如果发生短路就能立即断电,避免发生灾难。
在分布式系统中,服务调用方可以自己进行判断某个服务反应慢或者存在大量超时的情况,能够主动熔断,防止整个系统被拖垮。
Hystrix可以实现弹性容错,当情况好转后,可以自动重连。
熔断之后,可以将后序的请求直接拒绝掉,一段时间后允许部分请求通过,如果调用成功,则恢复,否则继续断开。
服务降级,服务异常,不是粗暴的直接报错,而是给一个友好的提示;服务繁忙时,一些次要服务暂时中断,优先保证主要服务的畅通,一切资源优先给主要服务使用,在双十一、618时,京东天猫都会采用这样的策略。
Hystix的使用
- 依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
- 开启
@SpringBootApplication
@EnableHystrix
public class HystrixApplication {
public static void main(String[] args) {
SpringApplication.run(HystrixApplication.class);
}
}
- 回滚处理函数
@RestController
public class HelloController {
@Autowired
RestTemplate restTemplate;
@GetMapping("/hello")
//请求失败就会回滚到处理函数error
@HystrixCommand(fallbackMethod = "error")
public String hello(){
String result = restTemplate.getForObject("http://eureka-client-user/hello", String.class);
System.out.println(result);
return result;
}
public String error(){
return "error...";
}
}
-
测试
我们关闭一个eureka-client-user服务,这个时候访问