SpringCloud-4-Netflix-4-Hystrix-阿里云开发者社区

SpringCloud-4-Netflix-4-Hystrix

2022-10-10 92

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Hystrix 就是断路器，也叫熔断器。

Hystrix 就是断路器，也叫熔断器。

在分布式系统中有很多的模块相互之间进行交互，如果其中的一个出现了问题，那么就会影响整个流程，导致整个服务出现故障。假如某一个模块无法正常工作时，能够通过我们提前配置的容错措施来使得整个系统能够继续正常运行，这样就可以在单个模块出问题时及时熔断该链路，不影响整个系统的运行。

Spring Cloud 断路器提供了跨不同断路器实现的抽象。

支持的实现

Netfix Hystrix
Resilience4J
Sentinel
Spring Retry

现在我们的一个8080端口服务宕机了，我们@HystrixCommand(fallbackMethod = "error")注解来捕捉到这个事件。

代码实现一下

一、直接使用上篇的eureka client服务，加入hystrix依赖

<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.xing</groupId><artifactId>StudyCloud</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>StudyCloud-eureka-client</artifactId><version>0.0.1-SNAPSHOT</version><dependencies><!--web组件--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--eurekaclient组件--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

二、启动类中加@EnableCircuitBreaker注解启动熔断器

packagecom.xing.study.cloud.eureka;
importcom.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;
importorg.springframework.web.client.RestTemplate;
/*** @author rt*/@RestController@SpringBootApplication@EnableEurekaClient@EnableCircuitBreakerpublicclassApplication {
@RequestMapping("/")
publicStringhome() {
return"Hello World";
    }
@HystrixCommand(fallbackMethod="error")
@RequestMapping("/hystrix")
publicStringhystrix() {
returnnewRestTemplate().getForObject("http://127.0.0.1:8080/",String.class);
    }
/***  回调方法* @return str*/publicStringerror(){
return"/hystrix调用8080端口地址失败拉，回调error方法";
    }
publicstaticvoidmain(String[] args) {
SpringApplication.run(Application.class, args);
    }
}

配置文件还是保持上篇的

spring.application.name=eureka-client1server.port=8882eureka.instance.instance-id=eureka-client1eureka.client.service-url.defaultZone=http://172.23.13.15:8881/eureka/eureka.client.register-with-eureka=trueeureka.client.fetch-registry=true