Spring Cloud-Turbine 聚合监控

你的名字 2022-05-23 02:08 210阅读 0赞

### 文章目录 ###

*  Spring Cloud-Turbine 聚合监控
 *   *   *   *  1.什么是Turbine?
             *  2.Turbine基本使用
             *   *  pom.xml
                 *  application.yml
                 *  HystrixTurbineApp.java
                 *  pom.xml
                 *  application.yml
                 *  OrderHystrixApp .java
                 *  OrderController .java
             *  3.利用Turbine监控多个应用
             *   *  application.yml
             *  4.Turbine监测配置Context-path服务
             *   *  application.yml
                 *  application.yml
                 *  application.yml

# Spring Cloud-Turbine 聚合监控 #

>  在Spring Cloud Netflix栈中，每个微服务都以HTTP接口的形式暴露自身服务，因此在调用远程服务时就必须使用到HTTP客户端。我们可以使用JDK原生的URLConnection、Apache的Http Client、Netty的异步HTTP Client，还有之前我们使用到Spring的RestTemplate，这些都可以实现远程调用。

#### 1.什么是Turbine? ####

>  在之前我们了解到了hystrix提供了很多方式去监控服务健康状况，开始的话我们利用Hystrix DashBoard只能看到单个服务的状况，但是我们经常接触到的是集群化的服务，这里就需要使用Turbine，可以将各断点聚合在仪表板上

#### 2.Turbine基本使用 ####

>  首先导入所需依赖

##### pom.xml #####

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        <version>1.4.3.RELEASE</version>
    </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-hystrix</artifactId>
        <version>1.4.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
        <version>1.4.3.RELEASE</version>
    </dependency>

>  然后需要配置文件中配置用于查找的Eureka服务

##### application.yml #####

>  主程序上加上@EnableTurbine注解

##### HystrixTurbineApp.java #####

package com.ithzk.spring.cloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.turbine.EnableTurbine;
    
    /** * Hello world! * */
    @SpringBootApplication
    @EnableTurbine
    public class HystrixTurbineApp
    { 
        public static void main( String[] args )
        { 
            SpringApplication.run(HystrixTurbineApp.class);
        }
    }

>  简单几步即可，这里我们需要启动他所监控的服务consumer-order-hystrix,也就是之前博客中的服务，这里也贴出来方便大家查看

##### pom.xml #####

<dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-test</artifactId>
         <scope>test</scope>
     </dependency>
     <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
     </dependency>
     
     <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
         <version>1.4.3.RELEASE</version>
     </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-hystrix</artifactId>
         <version>1.4.3.RELEASE</version>
     </dependency>

##### application.yml #####

server:
      port: 8900
    spring:
      application:
        name: consumer-order-hystrix
    user:
      url: http://localhost:7900/user/
    eureka:
      client:
        service-url:
          defaultZone:  http://user:user@localhost:8888/eureka/

##### OrderHystrixApp .java #####

package com.ithzk.spring.cloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    /** * Hello world! * */
    @SpringBootApplication
    @EnableEurekaClient
    @EnableCircuitBreaker//启用熔断
    public class OrderHystrixApp { 
    
        //相当于xml中的bean标签 用于调用当前方法获取到指定的对象
        @Bean
        public RestTemplate getRestTemplate(){ 
            return new RestTemplate();
        }
    
        public static void main( String[] args )
        { 
            SpringApplication.run(OrderHystrixApp.class);
        }
    }

##### OrderController .java #####

package com.ithzk.spring.cloud.controller;
    
    import com.ithzk.spring.cloud.entity.User;
    import com.netflix.appinfo.InstanceInfo;
    import com.netflix.discovery.EurekaClient;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    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;
    
    /** * @author hzk * @date 2018/5/13 */
    @RestController
    public class OrderController { 
    
        //spring 提供用于访问rest接口的模板对象
        @Autowired
        private RestTemplate restTemplate;
    
        @Autowired
        private EurekaClient eurekaClient;
    
        @Value("${user.url}")
        private String url;
    
        @GetMapping("/order/{id}")
        @HystrixCommand(fallbackMethod = "defaultMethod")
        public User getOrder(@PathVariable Integer id){ 
            //访问提供者 获取数据 通过rest访问获取的json数据转换为的User对象
            //PROVIDER-USER 为eureka中提供者注册服务名称
            InstanceInfo instanceInfo = eurekaClient.getNextServerFromEureka("PROVIDER-USER", false);
            //获取接口项目地址
            String homePageUrl = instanceInfo.getHomePageUrl();
    
            User user = restTemplate.getForObject(homePageUrl + "/user/" +id, User.class);
            return user;
        }
    
        /** * 失败后执行的回调 * @param id * @return */
        public User defaultMethod(Integer id){ 
            return new User(id+1000,"faild",88);
        }
    }

>  启动Eureka Server,启动提供服务，消费服务以及Turbine应用，此时访问`localhost:10000/turbine.stream?cluster=CONSUMER-ORDER-HYSTRIX`。  
> ![这里写图片描述][70]  
>  可以看到出现了和之前health类似的界面，实时监控者断路器状态，请求`localhost:8900/order/xxx`,再次观察页面。  
> ![这里写图片描述][70 1]  
>  此时便出现了几乎和之前健康指标监控同样类型的监控数据，这里我们修改消费服务项目端口为8901，再次开启一个消费服务，这个时候可以看到Eureka server中会出现同一个应用名下挂有两台消费服务。  
> ![这里写图片描述][70 2]  
>  然后我们启动上篇博客中介绍的Dashboard仪表盘，将`localhost:10000/turbine.stream?cluster=CONSUMER-ORDER-HYSTRIX`配置进去。  
> ![这里写图片描述][70 3]  
>  这个时候我们去访问`localhost:8900/order/xx或是localhost:8901/order/xx`，都可以发现dashboard中监控到了其断路器的状态。  
> ![这里写图片描述][70 4]

#### 3.利用Turbine监控多个应用 ####

>  上面我们利用Turbine实现了对同一应用的多台服务进行监控,这里如果我们需要同时监控多个应用需要怎么做呢？hystrix在设计turbine的时候也考虑到了这点,下面我们来了解一下。  
>  这里我们先启动Eureka server、提供服务、以及消费服务consumer-order-hystrix和consumer-order-feign-hystrix这些我们在上面或者之前的博客中都有提到就不再贴出来了。然后我们的关键是来修改下上面所用到的turbine这个项目的配置文件。

##### application.yml #####

server:
      port: 10000
    spring:
      application:
        name: consumer-order-hystrix-turbine
    eureka:
      client:
        serviceUrl:
          defaultZone: http://user:user@localhost:8888/eureka
    turbine:
      aggregator:
        clusterConfig: default
      appConfig: consumer-order-hystrix,consumer-order-feign-hystrix
      cluster-name-expression: "'default'"

![这里写图片描述][70 5]

>  这里可以看到我们注册了consumer-order-hystrix和consumer-order-feign-hystrix两个消费服务，在监控多个应用的情况下,只需要访问localhost:10000/turbine.stream即可看到断路器状态。  
> ![这里写图片描述][70 6]  
>  然后启动dashboard仪表板应用,将监控地址填入。  
> ![这里写图片描述][70 7]  
>  这个时候我们分别去请求`localhost:8900/order/xx和localhost:8901/order/xx`。  
> ![这里写图片描述][70 8]  
>  可以看到同时可以实现监控两个应用断路器的状态情况,这里由于请求的接口都为getOrder，所以可能会造成一点混淆，实质上之前是讲一个应用部署多台服务同时提供,但这里是多个应用分开监控，其实整体实现还是很方便的,如果不是特别需要解析深层,利用简单的配置就能实现。

#### 4.Turbine监测配置Context-path服务 ####

>  在之前我们可以发现健康监测默认路径是`host:port/hystrix.stream`，并且我们使用turbine的时候他也是默认去检测host:port/hystrix.stream这个路径下的数据状况，如果我们项目配置了context-path，导致项目请求都需要加上配置的名称,即`host:port/context-path/`，此时turbine则依然会去检测没有context-path的路径，所以会导致检测不到断路器状态。  
>  在Spring-cloud官方文档里面提到了如何去解决这种情况，首先我们将之前的consumer-order-feign-hystrix服务设置context-path。

##### application.yml #####

server:
      port: 8900
      context-path: /feign-hystrix
    spring:
      application:
        name: consumer-order-feign-hystrix
    user:
      url: http://localhost:7900/user/
    eureka:
      client:
        service-url:
          defaultZone:  http://user:user@localhost:8888/eureka/
    feign:
      hystrix:
        enabled: true # feign启用fallback机制

>  此时启动会发现所有请求都需要加上配置的context-path才可以成功,包括hystrix.stream健康指标  
> ![这里写图片描述][70 9]  
>  我们直接启动上面turbine应用,此时配置文件如下:

##### application.yml #####

server:
      port: 10000
    spring:
      application:
        name: consumer-order-hystrix-turbine
    eureka:
      client:
        serviceUrl:
          defaultZone: http://user:user@localhost:8888/eureka
    turbine:
      aggregator:
        clusterConfig: CONSUMER-ORDER-FEIGN-HYSTRIX # host:port/turbine.stream?cluster=<CLUSTERNAME> CLUSTERNAME即此处配置名称
      appConfig: consumer-order-feign-hystrix
      cluster-name-expression: "'default'"

>  此时去查看localhost:10000/turbine.stream?cluster=CONSUMER-ORDER-FEIGN-HYSTRIX，然后可以发现无论怎么消费,都不会检测到断路器状态,这就是因为他默认是不会去加上context-path，所以后台也会报出无法请求到的异常。

>  官网提出了解决方案,只需简单修改配置文件也可以很容易实现。

##### application.yml #####

server:
      port: 10000
    spring:
      application:
        name: consumer-order-hystrix-turbine
    eureka:
      client:
        serviceUrl:
          defaultZone: http://user:user@localhost:8888/eureka
    turbine:
      aggregator:
        clusterConfig: CONSUMER-ORDER-FEIGN-HYSTRIX # host:port/turbine.stream?cluster=<CLUSTERNAME> CLUSTERNAME即此处配置名称
        # clusterConfig: default
      appConfig: consumer-order-feign-hystrix
      # cluster-name-expression: "'default'"
    turbine.instanceUrlSuffix.CONSUMER-ORDER-FEIGN-HYSTRIX: /feign-hystrix/hystrix.stream # 配置hystrix.stream的访问地址

>  可以看出主要不同的在于`turbine.instanceUrlSuffix.CONSUMER-ORDER-FEIGN-HYSTRIX: /feign-hystrix/hystrix.stream`,这个配置，`turbine.instanceUrlSuffix.ApplicationName(Eureka Server上应用名称): /contenxt-path/hystrix.stream`，只需要配置这一项，turbine.stream就会修改检测的地址。  
> ![这里写图片描述][70 10]  
>  启动dashboard也可以正常访问仪表板  
> ![这里写图片描述][70 11]

[70]: /images/20220523/4c7f92a5886a4e7e86ca20b82d8e8758.png
[70 1]: /images/20220523/34c1ceb946a24b089cbaa4c76e3ef4e8.png
[70 2]: /images/20220523/b967c1b6529448729fe1b4b22dc51ff7.png
[70 3]: /images/20220523/b2eef2119cdb4c9fbee17bb6ca1da5ef.png
[70 4]: /images/20220523/21e582bdcb0c4486b0914e554a03c355.png
[70 5]: /images/20220523/3b67242221494053a71a69d48cb153d0.png
[70 6]: /images/20220523/dc2878d0289a40df97c80d9b72c6f2aa.png
[70 7]: /images/20220523/b8c97a42fe99476082e2027632581692.png
[70 8]: /images/20220523/19c4bb5562854b55a370264f15fffb38.png
[70 9]: /images/20220523/15bdc97809fc4603aaec573ce8e272ff.png
[70 10]: /images/20220523/4c77bd237e0640798721c73224215f41.png
[70 11]: /images/20220523/6ff5aff481424d42be9986a44f078bec.png