springcloud学习笔记(六)SpringCloud集成Hystrix(1)

小咪咪 2022-06-01 14:24 213阅读 0赞

对于Hystrix 官方文档如是说：

在微服务架构中，通常有多层服务调用。

![HystrixGraph][]

图1.微服务图

较低级别的服务中的服务故障可能导致用户级联故障。当对特定服务的呼叫达到一定阈值时（Hystrix中的默认值为5秒内的20次故障），电路打开，不进行通话。在错误和开路的情况下，开发人员可以提供后备。

![HystrixFallback][]

图2. Hystrix回退防止级联故障

开放式电路会停止级联故障，并允许不必要的或失败的服务时间来愈合。回退可以是另一个Hystrix保护的调用，静态数据或一个正常的空值。回退可能被链接，所以第一个回退使得一些其他业务电话又回到静态数据。

个人理解：

据我初步的了解，其实就是服务一调服务二，服务二调了服务三和四，若是服务三出现了问题，就将服务三断开或转到服务三的备用方法，以防服务级联故障。

下面开始实践：

首先导入依赖包：

完整依赖如下：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="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">
        <parent>
            <artifactId>SpringCloudTest</artifactId>
            <groupId>com.xc.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>EurekaService_hystrix</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</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>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix</artifactId>
            </dependency>
    
        </dependencies>
    
    </project>

启动类加入注解 @EnableCircuitBreaker，完整启动类如下：

package com.xc;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableCircuitBreaker
    public class APP_hystrix {
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        public static void main(String args[]){
            SpringApplication.run(APP_hystrix.class,args);
        }
    
    
    }

接口中应用也十分简单，只需要一个注解@ HystrixCommand ，注解中的值为要回调的方法名，完整代码如下：

package com.xc.controller;
    
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class TestController {
    
        @Autowired
        private RestTemplate restTemplate;
    
        @RequestMapping("/say/{words}")
        @HystrixCommand(fallbackMethod = "sayhelloFallback")
        public String sayhello(@PathVariable String words) {
            String s=restTemplate.getForObject("http://cloud-test2/hello",String.class);
            System.out.println(s);
            return words+":hello";
        }
    
        public String sayhelloFallback( String words) {
            System.out.println("sayhelloFallback");
            return "sayhelloFallback";
        }
    
    
    }

现在开始测试打开eureka服务器：

![SouthEast][]

发现两个客户端服务，现在开始调用hystrix接口：

![SouthEast 1][]

ok,没有问题，现在我们把cloud-test2停掉，再访问：

![SouthEast 2][]

我们发现他进入了回调方法。。[hystrix][]  helloword测试完毕。

忘记贴上参数文件：

spring:
      application:
        name: eureka-hystrix
    server:
      port: 8999
    eureka:
      client:
        healthcheck:
          enabled: true
        serviceUrl:
          defaultZone: http://xc:123@localhost:8761/eureka
      instance:
        prefer-ip-address: true
    #hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 5000

[HystrixGraph]: /images/20220601/9c14c7e075314ed3837a47a4347eaad9.png
[HystrixFallback]: /images/20220601/214082ccde2447bc9af1991caea7b66a.png
[SouthEast]: /images/20220601/2a486235b4ef47fab7ca3d0a77bd41e0.png
[SouthEast 1]: /images/20220601/bead329491cd48148962ccd3382cb3bc.png
[SouthEast 2]: /images/20220601/f06df4fef2114da1914f6e54e355abee.png
[hystrix]: http://192.9.8.3:8999/info