Day17_19_SpringCloud教程之Hystrix Turbine聚合面板

冷不防 2024-02-19 20:52 64阅读 0赞

## 19\_SpringCloud教程之Hystrix Turbine聚合面板 ##

### 一. Hystrix Turbine简介 ###

我们上一篇博客讲解了Hystrix Dashboard的功能及其实现,了解到可以给每个服务添加一个后台监控界面.

但是对我们来说,查看单个的Hystrix Dashboard数据并没有多大的价值,要想看整个系统的Hystrix Dashboard数据,我们可以使用Hystrix Turbine组件.Hystrix Turbine将每个服务的Hystrix Dashboard数据进行了整合.Hystrix Turbine的使用非常简单,只需要引入相应的依赖和加上注解和配置就可以了.

### 二. Hystrix Turbine的实现 ###

我们在上一篇博客代码的基础之上进行改造.

因为我们需要多个服务的Dashboard数据,所以需要再创建一个服务,取名为eureka-ribbon2,它的基本配置等同于eureka-ribbon,但是该服务中的Controller不同.

#### 1. eureka-ribbon2代码改造 ####

我们创建一个新的模块,绝大多数代码复制eureka-ribbon模块中的代码实现即可,但是对Controller代码单独修改一下.

修改了Controller及其接口方法的名称.

package com.syc.cloud.web;
    
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import com.syc.cloud.service.RibbonService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class SayHelloController {
    
        @Autowired
        private RibbonService helloService;
    
        //给需要降级的方法加上注解@HystrixCommand
        @HystrixCommand(fallbackMethod = "handleError")
        @RequestMapping(value = "/sayHello")
        public String sayHello(@RequestParam String name) {
    
            return helloService.helloService(name);
        }
    
        /*熔断处理*/
        public String handleError(String name) {
            return "Hello," + name + ". Sorry,please check your network!";
        }
    
    }

其他基本一样.

#### 2. 创建service-turbine ####

#### 2.1 添加依赖 ####

<?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>ribbon02</artifactId>
            <groupId>com.syc.cloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        
        <modelVersion>4.0.0</modelVersion>
        <artifactId>service_turbine</artifactId>
    
        <dependencies>
            <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-ribbon</artifactId>
            </dependency>
    
            
            
            <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-hystrix-dashboard</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-netflix-turbine</artifactId>
            </dependency>
        </dependencies>
    
    </project>

#### 2.2 入口类添加@EnableTurbine注解 ####

在其入口类ServiceTurbineApplication加上注解@EnableTurbine,开启turbine聚合功能. @EnableTurbine注解包含了@EnableDiscoveryClient注解,即开启了注册服务.

package com.syc.cloud;
    
    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.netflix.eureka.EnableEurekaClient;
    import org.springframework.cloud.netflix.hystrix.EnableHystrix;
    import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    import org.springframework.cloud.netflix.turbine.EnableTurbine;
    import org.springframework.web.bind.annotation.RestController;
    
    @SpringBootApplication
    @EnableEurekaClient
    @EnableDiscoveryClient //注意:必须是@EnableDiscoveryClient注解,不能是@EnableEurekaClient,否则无法实现负载均衡.
    @RestController
    @EnableHystrix
    @EnableHystrixDashboard
    @EnableCircuitBreaker //开启服务熔断功能
    @EnableTurbine //开启聚合面板功能
    public class ServiceTurbineApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(ServiceTurbineApplication.class, args);
        }
    
    }

#### 2.3 修改配置文件application.yml ####

server:
      port: 8767
    
    spring:
      application:
        name: service-turbine
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    
    management:
      endpoints:
        web:
          exposure:
            include: "*"
          cors:
            allowed-origins: "*"
            allowed-methods: "*"
    
    turbine:
      app-config: eureka-ribbon,eureka-ribbon2
      aggregator:
        clusterConfig: default
      clusterNameExpression: new String("default")
      combine-host: true
      instanceUrlSuffix:
        default: actuator/hystrix.stream

#### 3. 项目结构 ####

![Image 1][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70][]

### 三. Turbine功能演示 ###

依次开启项目目录结构截图中的工程.  
![Image 1][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 1][]

#### 1. 查看turbine.stream ####

打开浏览器输入 [http://localhost:8767/turbine.stream,界面如下][http_localhost_8767_turbine.stream]:  
![Image 1][]![20190716164030338.png][]

#### 2. 请求一下接口 ####

[http://localhost:8764/hello?name=一一哥][http_localhost_8764_hello_name]  
![Image 1][]![20190716164052388.png][]

[http://localhost:8766/sayHello?name=一一哥][http_localhost_8766_sayHello_name]  
![Image 1][]![20190716164103686.png][]

#### 3. 查看聚合面板 ####

打开:[http://localhost:8767/hystrix,输入监控流http://localhost:8767/turbine.stream][http_localhost_8767_hystrix_http_localhost_8767_turbine.stream]  
![Image 1][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 2][]

可以看到我们已经实现了面板聚合,把原先每个服务中单独的熔断监控界面整合到了一起.  
![Image 1][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 3][]

###    四. 解决Unable to connect to Command Metric Stream问题(附加) ###

如果出现下图所示异常现象:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 4][]

首先确保eureka，hystrix，hystrix-dashboard，actuator等相关依赖包一个都不少,另外所有该开启的注解功能都enable了.

如果以上都做到了还是有这个异常现象.

#### 则在出现异常的服务中的入口类内部添加如下代码: ####

//解决Unable to connect to Command Metric Stream问题.
        @Bean
        public ServletRegistrationBean getServlet(){
            HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
            ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
            registrationBean.setLoadOnStartup(1);
            registrationBean.addUrlMappings("/actuator/hystrix.stream");
            registrationBean.setName("HystrixMetricsStreamServlet");
            return registrationBean;
        }

此时重启项目,再去查看Hystrix Dashboard监控面板,会发现问题得以解决.

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 5][]

[Image 1]: 
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190716163957131.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20190716164016261.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng==,size_16,color_FFFFFF,t_70
[http_localhost_8767_turbine.stream]: http://localhost:8767/turbine.stream,%E7%95%8C%E9%9D%A2%E5%A6%82%E4%B8%8B
[20190716164030338.png]: https://img-blog.csdnimg.cn/20190716164030338.png
[http_localhost_8764_hello_name]: http://localhost:8764/hello?name=%E4%B8%80%E4%B8%80%E5%93%A5
[20190716164052388.png]: https://img-blog.csdnimg.cn/20190716164052388.png
[http_localhost_8766_sayHello_name]: http://localhost:8766/sayHello?name=%E4%B8%80%E4%B8%80%E5%93%A5
[20190716164103686.png]: https://img-blog.csdnimg.cn/20190716164103686.png
[http_localhost_8767_hystrix_http_localhost_8767_turbine.stream]: http://localhost:8767/hystrix,%E8%BE%93%E5%85%A5%E7%9B%91%E6%8E%A7%E6%B5%81http://localhost:8767/turbine.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20190716164120914.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20190716164138356.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20190716171758150.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20190716172155644.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N5YzAwMDY2Ng==,size_16,color_FFFFFF,t_70