Turbine使用

Posted edda

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Turbine使用相关的知识，希望对你有一定的参考价值。

一、简介

Turbine是聚合服务器发送事件流数据的一个工具，Hystrix的监控中，只能监控单个节点，实际生产中都为集群，因此可以通过Turbine来监控集群下Hystrix的metrics情况
Turbine的github地址：https://github.com/Netflix/Turbine

二、基本环境

  • 一个eureka模块
  • 两个消费者模块
  • 一个turbine监控模块

三、创建eureka模块

（1）创建项目

创建一个spring boot项目

技术图片

（2）依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.  
  6.     <groupId>com.abc</groupId>
  7.     <artifactId>00-eurekaserver-8000</artifactId>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <packaging>jar</packaging>
  10.  
  11.     <parent>
  12.         <groupId>org.springframework.boot</groupId>
  13.         <artifactId>spring-boot-starter-parent</artifactId>
  14.         <version>2.1.7.RELEASE</version>
  15.         <relativePath/> <!-- lookup parent from repository -->
  16.     </parent>
  17.  
  18.     <properties>
  19.         <java.version>1.8</java.version>
  20.         <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
  21.     </properties>
  22.  
  23.     <dependencies>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  27.         </dependency>
  28.  
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-test</artifactId>
  32.             <scope>test</scope>
  33.         </dependency>
  34.  
  35.         <!--热部署依赖-->
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-devtools</artifactId>
  39.             <optional>true</optional>
  40.         </dependency>
  41.     </dependencies>
  42.  
  43.     <dependencyManagement>
  44.         <dependencies>
  45.             <dependency>
  46.                 <groupId>org.springframework.cloud</groupId>
  47.                 <artifactId>spring-cloud-dependencies</artifactId>
  48.                 <version>${spring-cloud.version}</version>
  49.                 <type>pom</type>
  50.                 <scope>import</scope>
  51.             </dependency>
  52.         </dependencies>
  53.     </dependencyManagement>
  54.  
  55.     <build>
  56.         <plugins>
  57.             <plugin>
  58.                 <groupId>org.springframework.boot</groupId>
  59.                 <artifactId>spring-boot-maven-plugin</artifactId>
  60.             </plugin>
  61.         </plugins>
  62.     </build>
  63.  
  64. </project>

（3）application.yml配置

  1. server:
  2.   port: 8000
  3.  
  4. eureka:
  5.   instance:
  6.     hostname: localhost  # 指定Eureka主机
  7.   client:
  8.     register-with-eureka: false   # 指定当前主机是否向Eureka服务器进行注册
  9.     fetch-registry: false    # 指定当前主机是否要从Eurka服务器下载服务注册列表
  10.     service-url:   # 服务暴露地址
  11.      defaultZone: http://localhost:8000/eureka
  12. #     defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka
  13.  
  14. #  server:
  15. #    enable-self-preservation: false    # 关闭自我保护

（4）启动类

  1. package com.abc.eureka;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  6.  
  7. @SpringBootApplication
  8. @EnableEurekaServer   // 开启Eureka服务
  9. public class EurekaServerApplication {
  10.  
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(EurekaServerApplication.class, args);
  13.     }
  14. }

四、创建消费者09-consumer-turbine-8080

（1）创建项目

创建一个spring boot项目

技术图片

（2）依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.7.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.abc</groupId>
  12.     <artifactId>09-consumer-turbine-8080</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>09-consumer-turbine-8080</name>
  15.     <description>Demo project for Spring Boot</description>
  16.  
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
  20.     </properties>
  21.  
  22.     <dependencies>
  23.  
  24.         <!--hystrix依赖-->
  25.         <dependency>
  26.             <groupId>org.springframework.cloud</groupId>
  27.             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  28.         </dependency>
  29.  
  30.         <!--feign依赖-->
  31.         <dependency>
  32.             <groupId>org.springframework.cloud</groupId>
  33.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  34.         </dependency>
  35.  
  36.         <!-- hystrix-dashboard依赖 -->
  37.         <dependency>
  38.             <groupId>org.springframework.cloud</groupId>
  39.             <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
  40.         </dependency>
  41.  
  42.         <!--actuator依赖-->
  43.         <dependency>
  44.             <groupId>org.springframework.boot</groupId>
  45.             <artifactId>spring-boot-starter-actuator</artifactId>
  46.         </dependency>
  47.  
  48.         <!--eureka客户端依赖-->
  49.         <dependency>
  50.             <groupId>org.springframework.cloud</groupId>
  51.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  52.         </dependency>
  53.  
  54.         <dependency>
  55.             <groupId>org.springframework.boot</groupId>
  56.             <artifactId>spring-boot-starter-web</artifactId>
  57.         </dependency>
  58.  
  59.         <!-- https://mvnrepository.com/artifact/org.webjars.bower/jquery -->
  60.         <dependency>
  61.             <groupId>org.webjars.bower</groupId>
  62.             <artifactId>jquery</artifactId>
  63.             <version>2.1.1</version>
  64.         </dependency>
  65.  
  66.         <dependency>
  67.             <groupId>org.projectlombok</groupId>
  68.             <artifactId>lombok</artifactId>
  69.             <optional>true</optional>
  70.         </dependency>
  71.  
  72.         <dependency>
  73.             <groupId>org.springframework.cloud</groupId>
  74.             <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
  75.         </dependency>
  76.         <!--热部署依赖-->
  77.         <dependency>
  78.             <groupId>org.springframework.boot</groupId>
  79.             <artifactId>spring-boot-devtools</artifactId>
  80.             <optional>true</optional>
  81.         </dependency>
  82.  
  83.     </dependencies>
  84.  
  85.     <dependencyManagement>
  86.         <dependencies>
  87.             <dependency>
  88.                 <groupId>org.springframework.cloud</groupId>
  89.                 <artifactId>spring-cloud-dependencies</artifactId>
  90.                 <version>${spring-cloud.version}</version>
  91.                 <type>pom</type>
  92.                 <scope>import</scope>
  93.             </dependency>
  94.         </dependencies>
  95.     </dependencyManagement>
  96.  
  97.     <build>
  98.         <plugins>
  99.             <plugin>
  100.                 <groupId>org.springframework.boot</groupId>
  101.                 <artifactId>spring-boot-maven-plugin</artifactId>
  102.             </plugin>
  103.         </plugins>
  104.     </build>
  105.  
  106. </project>

（3）application.yml配置

  1. # 在微服务网关zuul中演示时需要该工程的端口号为8090
  2. server:
  3.   port: 8080
  4.  
  5. spring:
  6.   application:  # 指定微服务对外暴露的名称
  7.     name: abcmsc-consumer-depart01
  8.  
  9. eureka:
  10.   client:
  11.     service-url:
  12.       defaultZone: http://localhost:8000/eureka
  13.     #  instance:
  14.       #   metadata-map:
  15.     #   cluster: ribbon
  16. # 开启Feign对Hystrix的支持
  17. feign:
  18.   hystrix:
  19.     enabled: true
  20.  
  21.   client:
  22.     config:
  23.       default:
  24.         connectTimeout: 5000  # 指定Feign连接提供者的超时时限
  25.         readTimeout: 5000    # 指定Feign从请求到获取提供者响应的超时时限
  26.  
  27. # 开启actuator的所有web终端
  28. management:
  29.   endpoints:
  30.     web:
  31.       exposure:
  32.         include: "*"
  33.  
  34. # 设置服务熔断时限
  35. hystrix:
  36.   command:
  37.     default:
  38.       execution:
  39.         isolation:
  40.           thread:
  41.             timeoutInMilliseconds: 3000

（4）实体类Depart

  1. package com.abc.consumer.bean;
  2.  
  3. import lombok.Data;
  4.  
  5. @Data
  6. public class Depart {
  7.     private Integer id;
  8.     private String name;
  9. }

（5）DepartCodeConfig类

  1. package com.abc.consumer.codeconfig;
  2.  
  3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.web.client.RestTemplate;
  7.  
  8. @Configuration
  9. public class DepartCodeConfig {
  10.  
  11.     @LoadBalanced    // 开启消息者端的负载均衡功能，默认是轮询策略
  12.     @Bean
  13.     public RestTemplate restTemplate() {
  14.         return new RestTemplate();
  15.     }
  16.  
  17. }

（6）DepartController类

  1. package com.abc.consumer.controller;
  2.  
  3. import com.abc.consumer.bean.Depart;
  4. import com.abc.consumer.service.DepartService;
  5. import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.*;
  8.  
  9. import java.util.List;
  10.  
  11. @RestController
  12. @RequestMapping("/consumer/depart")
  13. public class DepartController {
  14.  
  15.     @Autowired
  16.     DepartService service;
  17.  
  18.     // 服务降级：若当前处理器方法发生异常，则执行fallbackMethod属性指定的方法
  19.     @HystrixCommand(fallbackMethod = "getHystrixHandle")
  20.     @GetMapping("/get/{id}")
  21.     public Depart getHandle(@PathVariable("id") int id) {
  22.         return service.getDepartById(id);
  23.     }
  24.  
  25.     public Depart getHystrixHandle(@PathVariable("id") int id) {
  26.         Depart depart = new Depart();
  27.         depart.setId(id);
  28.         depart.setName("no this depart  -- 方法级别");
  29.         return depart;
  30.     }
  31.  
  32.  
  33. }

（7）DepartService类

  1. package com.abc.consumer.service;
  2.  
  3.  
  4. import com.abc.consumer.bean.Depart;
  5. import org.springframework.cloud.openfeign.FeignClient;
  6. import org.springframework.stereotype.Service;
  7. import org.springframework.web.bind.annotation.*;
  8.  
  9. import java.util.List;
  10.  
  11. @Service
  12. // 指定当前Service所绑定的提供者微服务名称
  13. // fallback指定该接口所绑定的服务降级类
  14. @FeignClient(value = "abcmsc-provider-depart")
  15. @RequestMapping("/provider/depart")
  16. public interface DepartService {
  17.     @GetMapping("/get/{id}")
  18.     Depart getDepartById(@PathVariable("id") int id);
  19.  
  20. }

（8）启动类

  1. package com.abc.consumer;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.cloud.client.SpringCloudApplication;
  5. import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
  6. import org.springframework.cloud.openfeign.EnableFeignClients;
  7.  
  8. // 指定Service接口所在的包，开启OpenFeign客户端
  9. @EnableFeignClients(basePackages = "com.abc.consumer.service")
  10. @SpringCloudApplication
  11. @EnableHystrixDashboard   // 开启Hystrix仪表盘功能
  12. public class Consumer01Application {
  13.  
  14.     public static void main(String[] args) {
  15.         SpringApplication.run(Consumer01Application.class, args);
  16.     }
  17.  
  18. }

五、创建消费者09-consumer-turbine-8081

（1）复制项目09-consumer-turbine-8080

技术图片

（2）修改依赖

技术图片

（3）修改application.yml配置

技术图片

（4）修改09-consumer-turbine-8081.iml

技术图片

六、创建消费者turbine监控

（1）创建项目

创建一个spring boot项目

技术图片

（2）依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.7.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.abc</groupId>
  12.     <artifactId>09-consumer-turbine-monitor-9000</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>09-consumer-turbine-monitor-9000</name>
  15.     <description>Demo project for Spring Boot</description>
  16.  
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
  20.     </properties>
  21.  
  22.     <dependencies>
  23.  
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
  27.         </dependency>
  28.  
  29.         <!--hystrix依赖-->
  30.         <dependency>
  31.             <groupId>org.springframework.cloud</groupId>
  32.             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  33.         </dependency>
  34.  
  35.         <!--feign依赖-->
  36.         <dependency>
  37.             <groupId>org.springframework.cloud</groupId>
  38.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  39.         </dependency>
  40.  
  41.         <!-- hystrix-dashboard依赖 -->
  42.         <dependency>
  43.             <groupId>org.springframework.cloud</groupId>
  44.             <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
  45.         </dependency>
  46.  
  47.         <!--actuator依赖-->
  48.         <dependency>
  49.             <groupId>org.springframework.boot</groupId>
  50.             <artifactId>spring-boot-starter-actuator</artifactId>
  51.         </dependency>
  52.  
  53.         <!--eureka客户端依赖-->
  54.         <dependency>
  55.             <groupId>org.springframework.cloud</groupId>
  56.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  57.         </dependency>
  58.  
  59.         <dependency>
  60.             <groupId>org.springframework.boot</groupId>
  61.             <artifactId>spring-boot-starter-web</artifactId>
  62.         </dependency>
  63.  
  64.         <!-- https://mvnrepository.com/artifact/org.webjars.bower/jquery -->
  65.         <dependency>
  66.             <groupId>org.webjars.bower</groupId>
  67.             <artifactId>jquery</artifactId>
  68.             <version>2.1.1</version>
  69.         </dependency>
  70.  
  71.         <dependency>
  72.             <groupId>org.projectlombok</groupId>
  73.             <artifactId>lombok</artifactId>
  74.             <optional>true</optional>
  75.         </dependency>
  76.         <!--热部署依赖-->
  77.         <dependency>
  78.             <groupId>org.springframework.boot</groupId>
  79.             <artifactId>spring-boot-devtools</artifactId>
  80.             <optional>true</optional>
  81.         </dependency>
  82.  
  83.     </dependencies>
  84.     <dependencyManagement>
  85.         <dependencies>
  86.             <dependency>
  87.                 <groupId>org.springframework.cloud</groupId>
  88.                 <artifactId>spring-cloud-dependencies</artifactId>
  89.                 <version>${spring-cloud.version}</version>
  90.                 <type>pom</type>
  91.                 <scope>import</scope>
  92.             </dependency>
  93.         </dependencies>
  94.     </dependencyManagement>
  95.  
  96.     <build>
  97.         <plugins>
  98.             <plugin>
  99.                 <groupId>org.springframework.boot</groupId>
  100.                 <artifactId>spring-boot-maven-plugin</artifactId>
  101.             </plugin>
  102.         </plugins>
  103.     </build>
  104.  
  105. </project>

（3）application.yml配置

  1.  
  2. server:
  3.   port: 9000
  4.  
  5. spring:
  6.   application:  # 指定微服务对外暴露的名称
  7.     name: 09-consumer-turbine-monitor-9000
  8.  
  9. eureka:
  10.   client:
  11.     service-url: # 指定Eureka服务注册中心
  12.       defaultZone: http://localhost:8000/eureka
  13.  
  14. # 开启Feign对Hystrix的支持
  15. feign:
  16.   hystrix:
  17.     enabled: true
  18.  
  19.   client:
  20.     config:
  21.       default:
  22.         connectTimeout: 5000  # 指定Feign连接提供者的超时时限
  23.         readTimeout: 5000    # 指定Feign从请求到获取提供者响应的超时时限
  24.  
  25. # 开启actuator的所有web终端
  26. management:
  27.   endpoints:
  28.     web:
  29.       exposure:
  30.         include: "*"
  31.  
  32. # 设置服务熔断时限
  33. hystrix:
  34.   command:
  35.     default:
  36.       execution:
  37.         isolation:
  38.           thread:
  39.             timeoutInMilliseconds: 3000
  40. turbine:
  41.   app-config: abcmsc-consumer-depart01,abcmsc-consumer-depart02
  42.   cluster-name-expression: new String("default")
  43.   combine-host-port: true
  44.   instanceUrlSuffix: /actuator/hystrix.stream #turbine默认监控actuator/路径下的端点，修改直接监控hystrix.stream
  45.     #cluster-name-expression: metadata[‘cluster‘]
  46.     #aggregator:
  47.   # cluster-config: ribbon
  48.   #instanceUrlSuffix:  /hystrix.stream #turbine默认监控actuator/路径下的端点，修改直接监控hystrix.stream

（4）启动类

  1. package com.abc.consumer;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  6. import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
  7. import org.springframework.cloud.netflix.turbine.EnableTurbine;
  8.  
  9.  
  10. @SpringBootApplication
  11. @EnableTurbine
  12. @EnableHystrixDashboard
  13. @EnableEurekaClient
  14. public class MonitorApplication {
  15.  
  16.     public static void main(String[] args) {
  17.         SpringApplication.run(MonitorApplication.class, args);
  18.     }
  19.  
  20.    /*@Bean
  21.     public ServletRegistrationBean getServlet() {
  22.         HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
  23.         ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
  24.         registrationBean.setLoadOnStartup(1);
  25.         registrationBean.addUrlMappings("/actuator/hystrix.stream);
  26.         registrationBean.setName("HystrixMetricsStreamServlet");
  27.         return registrationBean;
  28.     }*/
  29.  
  30. }

七、启动

（1）启动eureka模块

（2）启动两个消费者模块

（3）启动turbine监控模块

八、效果

（1）请求http://localhost:8080/consumer/depart/get/1

技术图片

（1）请求http://localhost:8081/consumer/depart/get/1

技术图片

浏览器访问http://localhost:9000/hystrix

输入http://localhost:9000/turbine.stream

技术图片

 

技术图片

其他说明 

图片说明借鉴  https://www.jianshu.com/p/590bad4c8947

技术图片


以上是关于Turbine使用的主要内容，如果未能解决你的问题，请参考以下文章

使用Turbine对集群进行监控

Turbine聚合监控

hystrix-turbine 监控的使用

Hystrix/Turbine 仪表板上的多个服务？

熔断监控集群（Turbine）

微服务设计指导-使用turbine结合nacos监控多集群hystrix