码迷，mamicode.com
首页 > 其他好文 > 详细

Turbine使用

时间：2020-07-07 18:14:33      阅读：74      评论：0      收藏：0      [点我收藏+]

标签：cond   ext   control   template   start   maven   pre   mil   orm   

一、简介

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使用

标签：cond   ext   control   template   start   maven   pre   mil   orm   

原文地址：https://www.cnblogs.com/edda/p/13261853.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！