SpringCloud 2.x学习笔记：11、断路器聚合监控(Hystrix Turbine)（Greenwich版本）

矫情吗；* 2022-10-02 13:50 183阅读 0赞

参考  
英文原文：[https://stackabuse.com/spring-cloud-turbine/][https_stackabuse.com_spring-cloud-turbine]  
中文版：[https://www.jb51.net/article/162726.htm][https_www.jb51.net_article_162726.htm]

## 1、Hystrix Turbine简介 ##

## 2、样例演示 ##

### 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">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.cntaiping.tpa</groupId>
        <artifactId>turbine</artifactId>
        <packaging>pom</packaging>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
        </properties>
    
        
        
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.5.RELEASE</version>
            <relativePath/>
        </parent>
    
        <modules>
            <module>eureka-server</module>
            <module>user-service</module>
            <module>recommend-service</module>
            <module>hystrix-turbine</module>
        </modules>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

### 2.2 构建简单的Eureka Server ###

（1）pom.xml

(2) application.properties

server.port= 8761
    eureka.client.registerWithEureka= false
    eureka.client.fetchRegistry= false
    eureka.server.waitTimeInMsWhenSyncEmpty= 0

(3)Appliaction类

package com.cntaiping.tpa.eurekaserver;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaServerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaServerApplication.class, args);
        }
    
    }

### 2.3 构建“推荐服务”模块 ###

（1）pom.xml

（2）application.properties

server.port= 7070
    spring.application.name= recommend-service
    eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/
    management.endpoints.web.exposure.include=*

（3）Appliaction类

package com.cntaiping.tpa.recommendservice;
    
    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;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableCircuitBreaker
    public class RecommendServiceApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(RecommendServiceApplication.class, args);
        }
    
    }

（4）控制器

package com.cntaiping.tpa.recommendservice.controller;
    
    import com.cntaiping.tpa.recommendservice.bean.ProductBean;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    import org.springframework.web.bind.annotation.RestController;
    import java.util.*;
    
    
    @RestController
    public class RecommendController {
    
        @RequestMapping(value = "/recommend", method = RequestMethod.GET)
        @HystrixCommand(fallbackMethod = "recommendFallback")
        @ResponseBody
        public List<ProductBean> recommend() {
            List<ProductBean> products = new ArrayList<ProductBean>();
            products.add(new ProductBean("Product1", "Description1", "link1"));
            products.add(new ProductBean("Product2", "Description2", "link3"));
            products.add(new ProductBean("Product3", "Description3", "link3"));
            return products;
        }
    
        public List<ProductBean> recommendFallback() {
            System.out.println("=======recommendationFallback=========");
            return new ArrayList<ProductBean>();
        }
    }

（5）bean

package com.cntaiping.tpa.recommendservice.bean;
    
    public class ProductBean {
        private String name;
    
        private String description;
    
        private String detailsLink;
    
        public ProductBean(String name, String description, String detailsLink) {
            super();
            this.name = name;
            this.description = description;
            this.detailsLink = detailsLink;
        }
    
        public ProductBean() {
            // TODO Auto-generated constructor stub
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public String getDescription() {
            return description;
        }
    
        public void setDescription(String description) {
            this.description = description;
        }
    
        public String getDetailsLink() {
            return detailsLink;
        }
    
        public void setDetailsLink(String detailsLink) {
            this.detailsLink = detailsLink;
        }
    
    }

### 2.4 构建“用户服务”模块 ###

（1）pom.xml

（2）application.properties

server.port= 7060
    spring.application.name= user-service
    eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/
    management.endpoints.web.exposure.include=*

（3）Appliaction类

package com.cntaiping.tpa.userservice;
    
    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 UserServiceApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserServiceApplication.class, args);
        }
    
        @LoadBalanced
        @Bean
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

（4）控制器

package com.cntaiping.tpa.userservice.controller;
    
    import com.cntaiping.tpa.userservice.bean.ProductBean;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class UserController {
    
        @Autowired
        RestTemplate restTemplate;
    
        @GetMapping(value = "/personalized/{id}")
        @HystrixCommand(fallbackMethod = "recommendFallback")
        public ProductBean[] personalized(@PathVariable int id) {
            ProductBean[] result = restTemplate.getForObject("http://recommend-service/recommend", ProductBean[].class);
            return result;
        }
    
        public ProductBean[] recommendFallback(int id) {
            System.out.println("=======recommendFallback=========" + id);
            return new ProductBean[0];
        }
    }

（5）bean

public class ProductBean {
        private String name;
    
        private String description;
    
        private String detailsLink;
    
        public ProductBean(String name, String description, String detailsLink) {
            super();
            this.name = name;
            this.description = description;
            this.detailsLink = detailsLink;
        }
        ...
      }

### 2.5 构建“Hystrix Turbine ”模块 ###

（1）pom.xml

（2）application.properties

server.port= 7090
    spring.application.name= hystirx-turbine
    eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/
    turbine.appConfig= user-service,recommend-service
    turbine.clusterNameExpression= new String("default")

（3）Application类

package com.cntaiping.tpa.hystrixturbine;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    import org.springframework.cloud.netflix.turbine.EnableTurbine;
    
    @SpringBootApplication
    @EnableTurbine
    @EnableDiscoveryClient
    @EnableHystrixDashboard
    public class HystrixTurbineApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(HystrixTurbineApplication.class, args);
        }
    
    }

## 3、运行效果 ##

### 3.1 依次运行 ###

*  Eureka Server ：作为服务注册运行并在端口8761上运行。
 *  推荐服务：一个简单的REST服务，单个API：/recommend，并在端口7070上运行。
 *  用户服务：一个简单的REST服务，单个API：/personalized/\{id\}，并在端口7060上运行。
 *  Hystrix Turbine ：Hystrix dashboard服务，用于显示Hystrix流，并在端口’7090’上运行。

其中Eureka Server运行效果如下图  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70]

### 3.2 验证用户服务与推荐服务 ###

[http://localhost:7060/personalized/1][http_localhost_7060_personalized_1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 1]

### 3.3 hystrix.stream ###

user-service和recommend-service都实现了Hystrix回退机制，并通过Actuator暴露了/hystrix.stream端点：

用户服务的Hystrix端点：[http://localhost:7060/actuator/hystrix.stream][http_localhost_7060_actuator_hystrix.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 2]  
用于推荐服务的Hystrix端点：[http://localhost:7070/actuator/hystrix.stream][http_localhost_7070_actuator_hystrix.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 3]

### 3.4 Hystrix dashboard单项查询 ###

[http://localhost:7090/hystrix][http_localhost_7090_hystrix]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 4]  
输入：[http://localhost:7060/actuator/hystrix.stream][http_localhost_7060_actuator_hystrix.stream]

[http://localhost:7090/hystrix/monitor?stream=http%3A%2F%2Flocalhost%3A7060%2Factuator%2Fhystrix.stream&delay=2000&title=user][http_localhost_7090_hystrix_monitor_stream_http_3A_2F_2Flocalhost_3A7060_2Factuator_2Fhystrix.stream_delay_2000_title_user]![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 5]

### 3.5 聚合流 ###

Turbine可以将所有单独的hystrix.stream聚合成一个turbine.stream，以便在Hystrix Dashboard上查看

我们可以打开http://localhost:7090/turbine.stream?cluster=default来查看user-service和recommend-service的聚合流：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 6]

### 3.6 Hystrix dashboard聚合视图 ###

输入  
[http://localhost:7090/turbine.stream?cluster=default][http_localhost_7090_turbine.stream_cluster_default]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 7]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 8]

[https_stackabuse.com_spring-cloud-turbine]: https://stackabuse.com/spring-cloud-turbine/
[https_www.jb51.net_article_162726.htm]: https://www.jb51.net/article/162726.htm
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70]: /images/20220112/218f21f670e845cdaebef1a0997cefe3.png
[http_localhost_7060_personalized_1]: http://localhost:7060/personalized/1
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 1]: /images/20220112/8fd8780bc86848a381f3c89144f4b864.png
[http_localhost_7060_actuator_hystrix.stream]: http://localhost:7060/actuator/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 2]: /images/20220112/54f1bc7f888b4b4c8c33b589d77e1352.png
[http_localhost_7070_actuator_hystrix.stream]: http://localhost:7070/actuator/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 3]: /images/20220112/f5bd716c30414702a049230925dde74d.png
[http_localhost_7090_hystrix]: http://localhost:7090/hystrix
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 4]: /images/20220112/efc4ae799f134083a9a49b3fffc24fc8.png
[http_localhost_7090_hystrix_monitor_stream_http_3A_2F_2Flocalhost_3A7060_2Factuator_2Fhystrix.stream_delay_2000_title_user]: http://localhost:7090/hystrix/monitor?stream=http%3A%2F%2Flocalhost%3A7060%2Factuator%2Fhystrix.stream&delay=2000&title=user
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 5]: /images/20220112/22f59ca5f27d4c17b2bcc86df05264f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 6]: /images/20220112/e78186ea772741e9bd72a657a6ec4928.png
[http_localhost_7090_turbine.stream_cluster_default]: http://localhost:7090/turbine.stream?cluster=default
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 7]: /images/20220112/6c3a9896d41245beb15ffa493a464583.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5neXVxaWFuZw_size_16_color_FFFFFF_t_70 8]: /images/20220112/7de22ab7273340a98264d932104b8b06.png