一、Hystrix介绍
1、分布式系统面临问题
多个微服务之间调用的时候,假如微服务A调用微服务B和微服务C,微服务B和微服务C又调用其他的微服务,这就是所谓的”扇出”。
如果扇出的链路上某个微服务的调用响应的时间过长或者不可用,对微服A的调用就会占用越来越多的系统资源,进而引起系统崩溃,即”雪崩效应“。
对于高流量的应用来说,单一的后端依赖可能会导致所有的服务器上的所有资源都在几秒钟内饱和。比失败更糟糕的是,这些应用程序还可能导致服务之间的延迟增加,备份队列,线程和其他系统资源紧张,导致整个系统发生更多的级联故障。这些都表示需要对故障和延迟进行隔离和管理,以便单个依赖关系的失败,不能取消整个应用程序或系统。
所以,通常当你发现一个模块下的某个实例失败后,这时候这个模块依然还会接收流量,然后这个有问题的模块还调用了其他的模块,这样就会发生级联故障,或者叫雪崩。
2、Hystrix概念
①Hystrix是一个用于处理分布式系统的延迟和容错的开源库,可以保证一个服务出现故障时,不会导致整个系统出现雪崩效应,以提高分布式系统弹性;
②作为“断路器”,在一个服务出现故障时,可以通过短路器监控,返回一个可以处理的响应结果,保证服务调用线程不会长时间被占用,避免故障蔓延。
3、Hystrix作用
(1)服务降级
服务出现故障时,给故障服务降级到事先准备好的故障处理结果,将此结果返回给服务消费者,如:
客户端访问服务1,服务1调用服务2,服务2出现故障,Hystrix服务降级,返回一个可以处理的结果给服务1,服务1再以友好的错误界面返回给客户端。
(2)服务熔断
熔断机制是应对服务雪崩的一种链路保护机制,当服务出现故障时,服务会进行降级,熔断该服务节点,迅速返回错误响应信息。当检测到服务访问正常时,恢复其链路节点。
二、服务降级案例
1、搭建Eureka服务端
(1)创建maven工程
(2)导入依赖
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
</dependencies>
(3)配置application.yml
①服务端口为7001;
③Eureka客户端:
server:
port: 7001
eureka:
instance:
hostname: localhost
client:
register-with-eureka: false
fetchRegistry: false
service-url:
defaultZone: http://localhost:7001/eureka
(4)创建主启动类
@SpringBootApplication
@EnableEurekaServer
public class Eureka7001 {
public static void main(String[] args) {
SpringApplication.run(Eureka7001.class,args);
}
}
(5)启动Eureka注册中心
2、搭建服务提供者Provider80
(1)创建maven工程
(2)导入依赖
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
</dependencies>
(3)配置application.yml
server:
port: 80
spring:
application:
name: provider
eureka:
client:
register-with-eureka: true
fetchRegistry: true
service-url:
defaultZone: http://localhost:7001/eureka
(4)创建启动类
@SpringBootApplication
@EnableEurekaClient
@EnableCircuitBreaker
public class Provider80 {
public static void main(String[] args) {
SpringApplication.run(Provider80.class,args);
}
}
(5)创建controller(设置自身降级方法)
@RestController
public class FeignController {
@Value("${server.port}")
private String port;
@GetMapping("/provider")
public String hello(){
return "访问端口号为:"+port;
}
@HystrixCommand(fallbackMethod = "TimeoutHandler",commandProperties = {
//2秒钟以内就是正常的业务逻辑
@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="2000")
})
@GetMapping("timeout")
public String timeout(){
try {
//睡眠3秒
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "hello";
}
//降级后方法,上面方法出问题,我来处理,返回一个出错信息
public String TimeoutHandler() {
return "访问请求失败了,服务不可用";
}
}
(6)测试自身降级
测试完成后,为方便后边测试服务消费者降级,我们将服务提供者controller中时间设置为5秒以内业务为正常
@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="5000")
3、搭建服务消费者Consumer83
(1)创建maven工程
(2)导入依赖
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<!--openfeign-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
</dependencies>
(3)配置application.yml
④开启Hystrix降级服务。
server:
port: 83
spring:
application:
name: consumer83
eureka:
client:
register-with-eureka: true
fetch-registry: true
service-url:
defaultZone: http://localhost:7001/eureka
feign:
hystrix:
enabled: true #如果处理自身的容错就开启。开启方式与生产端不一样。
(4)创建主启动类
@EnableEurekaClient
@SpringBootApplication
@EnableFeignClients
@EnableHystrix
public class Consumer83 {
public static void main(String[] args) {
SpringApplication.run(Consumer83.class,args);
}
}
(5)创建远程调用服务接口
①@FeignClient注解,指定远程调用的服务名称,服务提供者Provider80、Provider81对应名称为:provider。
②接口中方法为:调用服务的controller方法。
@Component
@FeignClient(value = "PROVIDER")
public interface FeignService {
//调用远程接口
@GetMapping("/provider")
public String hello();
}
(6)创建controller
@RestController
public class FeignController {
//调用远程服务接口
@Autowired
private FeignService feignService;
@GetMapping("consumer")
public String hello(){
//调用接口
return feignService.hello();
}
//超时降级演示
@HystrixCommand(fallbackMethod = "TimeoutHandler",commandProperties = {
//超过1.5秒就降级自己
@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
})
@GetMapping("time")
public String time(){
return feignService.timeout();
}
//降级方法
public String TimeoutHandler(){
return "远程调用服务超时,调用失败";
}
}
4、测试案例
①启动Eureka7001
③启动·Consumer83
三、服务熔断
1、熔断设置参数
①circuitBreaker.enabled:是否开启熔断;
②circuitBreaker.requestVolumeThreshold:当前服务失败几次后开启断路,默认20次;
③circuitBreaker.sleepWindowInMilliseconds:设置断路时间,过了该时间后会尝试恢复,在断路时间内,即使请求正确也会走降级方法;
2、熔断类型
(1)熔断打开
(2)熔断关闭
(3)熔断半开
熔断半开时,请求可以访问服务,若请求正常访问,则熔断会关闭;若请请求不正常,继续熔断,调用降级方法。
原文地址:https://blog.csdn.net/weixin_50616848/article/details/124542186
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_46958.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!