SpringCloud之Hystrix、Turbine的进阶使用及线上实战

叁歲伎倆 2023-06-08 04:49 34阅读 0赞

## SpringCloud之Hystrix的进阶及线上实战使用 ##

上一小节我们了解Hystrix的基本概念和集成Feign的使用，在这小节中我们将学习Hystrix的高级用法和实际项目中需要使用的技术点。

### 一、Hystrix Dashboard ###

Hystrix Dashboard仪表盘是根据系统一段时间内发生的请求情况来展示的可视化面板，这些信息是每个HystrixCommand执行过程中的信息，这些信息是一个指标集合和具体的系统运行情况，如下图入口界面图。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70]

在Spring Cloud里搭建出这样一个功能也是非常方便的，按照这几个步骤即可。

#### 1.1 父工程 ####

pom.xml

<?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">
        <modelVersion>4.0.0</modelVersion>
        <modules>
            <module>eureka-server</module>
            <module>provider-server</module>
            <module>hello-server</module>
            <module>hystrix-dashboard</module>
        </modules>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.3.RELEASE</version>
        </parent>
        
        <groupId>com.gyoomi</groupId>
        <artifactId>hystrix-dashboard-parent</artifactId>
        <version>1.0-SNAPSHOT</version>
        <packaging>pom</packaging>
    
        
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Finchley.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
        </dependencies>
    
    
    
        
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/libs-milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

#### 1.2 EurekaServer工程（注册中心） ####

pom.xml

application.yml

server:
      port: 8761
    eureka:
      instance:
        hostname: localhost
      client:
        registerWithEureka: false
        fetchRegistry: false
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/

启动类

@SpringBootApplication
    @EnableEurekaServer
    public class EurekaServerApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(EurekaServerApplication.class, args);
        }
    }

#### 1.3 HelloServer工程(对外服务的提供者) ####

pom.xml

application.yml

server:
      port: 9091
    spring:
      application:
        name: sc-hello-service
    eureka:
      client:
        serviceUrl:
          defaultZone: http://${ eureka.host:127.0.0.1}:${ eureka.port:8761}/eureka/
      instance:
        prefer-ip-address: true
    management:
      security:
        enabled: false
      endpoints:
        web:
          exposure:
            include: hystrix.stream
    feign:
      hystrix:
        enabled: true
    ribbon:
      ConnectTimeout: 6000
      ReadTimeout: 6000
      MaxAutoRetries: 0
      MaxAutoRetriesNextServer: 0
    hystrix:
      command:
        default:
          execution:
            timeout:
            isolation:
              thread:
                timeoutInMilliseconds: 15000

启动类

@SpringBootApplication
    @EnableEurekaClient
    @EnableHystrix
    @EnableFeignClients
    public class HelloServiceApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(HelloServiceApplication.class, args);
        }
    
    }

controller及其他辅助测试类

HelloController

@RestController
    public class HelloController { 
    
        @Autowired
        private IHelloService userService;
    
        @GetMapping("/getProviderData")
        public List<String> getProviderData(){ 
            return userService.getProviderData();
        }
    
        /** * test * * @return */
        @RequestMapping(value = "/helloService", method = RequestMethod.GET)
        public String getHelloServiceData() { 
            return "hello Service";
        }
    }

IHelloService

public interface IHelloService { 
    
        List<String> getProviderData();
    }

HelloServiceImpl

@Service
    public class HelloServiceImpl implements IHelloService { 
    
        @Autowired
        private ProviderClient providerClient;
    
        @Override
        public List<String> getProviderData() { 
            return providerClient.getProviderData();
        }
    }

ProviderClient

@FeignClient(name = "sc-provider-service")
    public interface ProviderClient { 
    
        @GetMapping(value = "/getDashboard")
        List<String> getProviderData();
    }

#### 1.4 ProviderServer工程（服务的提供者） ####

pom.xml

application.yml

server:
      port: 8099
      
    spring:
      application:
        name: sc-provider-service
    eureka:
      client:
        serviceUrl:
          defaultZone: http://${ eureka.host:127.0.0.1}:${ eureka.port:8761}/eureka/
      instance:
        prefer-ip-address: true
    feign:
      hystrix:
        enabled: true
    management:
      security:
        enabled: false
      endpoints:
        web:
          exposure:
            include: hystrix.stream

启动类

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableHystrix
    @EnableFeignClients
    public class ProviderApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(ProviderApplication.class, args);
        }
    }

controller及其他辅助类

ProviderController

@RestController
    public class ProviderController { 
    
        @Autowired
        private ConsumerClient consumerClient;
    
    
        /** * test get hello service data * * @return result */
        @GetMapping(value = "/getHelloService")
        public String getHelloService() { 
            return consumerClient.getHelloServiceData();
        }
    
        /** * test get some info * * @return */
        @GetMapping(value = "/getDashboard")
        public List<String> getProviderData() { 
            List<String> provider = new ArrayList<String>();
            provider.add("hystrix dashboard");
            return provider;
        }
    }

ConsumerClient

@FeignClient(value = "sc-hello-service")
    public interface ConsumerClient { 
    
        /** * invoke method * * @return */
        @GetMapping(value = "/helloService")
        String getHelloServiceData();
    }

#### 1.5 Hystrix Dashboard监控工程 ####

pom.xml

application.yml

server:
      port: 9000
    spring:
      application:
        name: sc-hystrix-dashboard
    eureka:
      client:
        serviceUrl:
          defaultZone: http://${ eureka.host:127.0.0.1}:${ eureka.port:8761}/eureka/
      instance:
        prefer-ip-address: true
    management:
      security:
        enabled: false
      endpoints:
        web:
          exposure:
            include: hystrix.stream

启动类

@SpringBootApplication
    @EnableHystrixDashboard // 加此注解,表示开启hystrix监控的ui页面
    public class DashboardApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(DashboardApplication.class, args);
        }
    }

#### 1.6 启动测试效果 ####

首先依次启动EurekaServer、HelloService、DashboardService的项目。

1.  首先访问`http://localhost:9000/hystrix`。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 1]

*介绍下这个登录页面的功能*

界面上写的有三个地址，分别是三种监控方式：

*  默认集群监控，通过`http://turbine-hostname:port/turbine.stream`访问。（后面介绍）
 *  指定的集群：`http://turbine-hostname:port/turbine.stream?cluster=[clusterName]`。（后面介绍）
 *  单体监控

由于是在本地启动的应用，这时对上面的9091的hello-service进行监控，访问`http://localhost:9091/actuator/hystrix.stream`，需要注意的是，这里的地址是`actuator`，因为目前F版的SpringBoot版本是2.0，所有端点的前面都加了actuator，所以在输入地址时，应该加上actuator，不然会访问不到，进去后会出现loading的字样，这时访问接口`http://localhost:9091/getProviderData`，会看到如下图所示的失败消息。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 2]

就是图中爆红的那个数字`1`。

1.  此时启动ProviderService。然后再次访问`http://localhost:9091/getProviderData`。会看到如下效果。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 3]

就是图中的绿色的数字`4`。

#### 1.7 Hystrix Dashboard的监控UI理解 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 4]  
**圆圈**

它是代表流量的大小和流量的健康，有绿色、黄色、橙色、红色这几个颜色，通过这些颜色的标识，可以快速发现故障、具体的实例、请求压力等。

**曲线**

它代表2分钟内流量的变化，可以根据它发现流程的浮动趋势。

**数字**

Hystrix Dashboard页面左边第1列数字代表了`请求的成功`，`熔断数`，`错误的请求`，`超时的请求`，`线程池拒绝数`，`失败的请求`和`最近10秒内错误`的比率。

**Host&Cluster**

代表机器和集群的请求频率.

**Circuit**

断路器状态，open/closed

**Hosts&Median&Mean&**

集群下的报告，百分位延迟数

**Thread Pools**

线程池的指标，核心线程池指标，队列大小等

### 二、Turbine 聚合监控Hystrix ###

在上节讲了单个实例的Hystrix Dashboard，但在整个系统和集群的情况下是无法进行很好的监控和使用，所以需要一种方式来聚合整个集群下的监控状况，Turbine就是来聚合所有相关的hystrix. stream流的方案，然后在Hystrix Dashboard中显示。具体使用的步骤参考一下。

#### 2.1 沿用上节的Eureka、ProviderServer、HelloServer服务 ####

并在HelloServer的controller中添加一个方法。

@Autowired
        private ConsumerClient consumerClient;
    
    
        /** * test get hello service data * * @return result */
        @GetMapping(value = "/helloService")
        public String getHelloService() { 
            return consumerClient.getHelloServiceData();
        }

#### 2.2 创建Turbine监控工程 ####

pom.xml

applicatin.yml

server:
      port: 9088
    spring:
      application:
        name: sc-turbine-dashboard
    eureka:
      client:
        serviceUrl:
          defaultZone: http://${ eureka.host:127.0.0.1}:${ eureka.port:8761}/eureka/
      instance:
        prefer-ip-address: true
    management:
      security:
        enabled: false
      endpoints:
        web:
          exposure:
            include: hystrix.stream
    
    # turbine配置在这里
    turbine:
      appConfig: sc-hello-service,sc-provider-service # 设置需要收集监控信息的服务名
      clusterNameExpression: "'default'" # 设置集群的名称

启动类

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableHystrixDashboard
    @EnableTurbine // 必须加，才有效果
    public class TurbineServiceApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(TurbineServiceApplication.class, args);
        }
    }

#### 2.3 启动测试监控效果 ####

**然后依次启动Eureka、Provider、Hello、Turbine监控工程。**

首先访问`http://localhost:9088/hystrix`,如下图。其实这是Turbine的监控页面的入口。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 5]

其次我们选择turbine的监控方式，输入`http://localhost:9088/turbine.stream`,进入到监控页面。

再次访问`http://localhost:9091/getProviderData`, `http://localhost:8099/helloService`，访问数据接口并能成功看到数据接口返回结果。

最后我们回到Turbine的监控页面，我们会看到hello-server和provider-server两个工程的流量监控的Dashboard。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 6]

至此，集成测试完毕。

**其他**

*  Hystrix Dashboard的项目源码： [地址][Link 1]
 *  Turbine 监控项目源码： [地址][Link 2]
 *  个人开源的SpingCloud的脚手架项目 [地址][Link 3] 喜欢的老铁欢迎给星星！！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70]: /images/20230531/b2967dcdc76841e78c9cbba49c940a3c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 1]: /images/20230531/5030a4832a9e4882b5c6f5782f265804.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 2]: /images/20230531/88ac93bbbbdd4bf9ab94a0baa9976570.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 3]: /images/20230531/57ab7953defc4d6d83bd8350ba283f97.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 4]: /images/20230531/3fc9a33b3881426cb6e800f0cb52d7ea.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 5]: /images/20230531/fe46ae786b474a3e8eed6af8cb880e95.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTcyMzU0NA_size_16_color_FFFFFF_t_70 6]: /images/20230531/25ab66aa20c4482d9b2926a03166adbe.png
[Link 1]: https://github.com/gyoomi/hystrix-dashboard-parent
[Link 2]: https://github.com/gyoomi/turbine-dashboard-parent
[Link 3]: https://github.com/gyoomi/miracle