2022-11-20 14:38:59

文章目录

Spring Cloud-Turbine 聚合监控

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

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

主程序上加上@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@EnableTurbinepublicclassHystrixTurbineApp{publicstaticvoidmain( String[] args){
        SpringApplication.run(HystrixTurbineApp.class);}}

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

pom.xml

<!-- spring boot test --><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><!--eureka client --><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//启用熔断publicclassOrderHystrixApp{//相当于xml中的bean标签 用于调用当前方法获取到指定的对象@Beanpublic RestTemplategetRestTemplate(){returnnewRestTemplate();}publicstaticvoidmain( 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
 */@RestControllerpublicclassOrderController{//spring 提供用于访问rest接口的模板对象@Autowiredprivate RestTemplate restTemplate;@Autowiredprivate EurekaClient eurekaClient;@Value("${user.url}")private String url;@GetMapping("/order/{id}")@HystrixCommand(fallbackMethod="defaultMethod")public UsergetOrder(@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 UserdefaultMethod(Integer id){returnnewUser(id+1000,"faild",88);}}

启动Eureka Server,启动提供服务，消费服务以及Turbine应用，此时访问localhost:10000/turbine.stream?cluster=CONSUMER-ORDER-HYSTRIX。

可以看到出现了和之前health类似的界面，实时监控者断路器状态，请求localhost:8900/order/xxx,再次观察页面。

此时便出现了几乎和之前健康指标监控同样类型的监控数据，这里我们修改消费服务项目端口为8901，再次开启一个消费服务，这个时候可以看到Eureka server中会出现同一个应用名下挂有两台消费服务。

然后我们启动上篇博客中介绍的Dashboard仪表盘，将localhost:10000/turbine.stream?cluster=CONSUMER-ORDER-HYSTRIX配置进去。

这个时候我们去访问localhost:8900/order/xx或是localhost:8901/order/xx，都可以发现dashboard中监控到了其断路器的状态。

3.利用Turbine监控多个应用

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

application.yml

server:port:10000spring:application:name: consumer-order-hystrix-turbineeureka:client:serviceUrl:defaultZone: http://user:user@localhost:8888/eurekaturbine:aggregator:clusterConfig: defaultappConfig: consumer-order-hystrix,consumer-order-feign-hystrixcluster-name-expression:"'default'"

这里写图片描述

这里可以看到我们注册了consumer-order-hystrix和consumer-order-feign-hystrix两个消费服务，在监控多个应用的情况下,只需要访问localhost:10000/turbine.stream即可看到断路器状态。

然后启动dashboard仪表板应用,将监控地址填入。

这个时候我们分别去请求localhost:8900/order/xx和localhost:8901/order/xx。

可以看到同时可以实现监控两个应用断路器的状态情况,这里由于请求的接口都为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:8900context-path: /feign-hystrixspring:application:name: consumer-order-feign-hystrixuser: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健康指标

我们直接启动上面turbine应用,此时配置文件如下:

application.yml

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

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

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

application.yml

server:port:10000spring:application:name: consumer-order-hystrix-turbineeureka:client:serviceUrl:defaultZone: http://user:user@localhost:8888/eurekaturbine:aggregator:clusterConfig: CONSUMER-ORDER-FEIGN-HYSTRIX# host:port/turbine.stream?cluster=<CLUSTERNAME> CLUSTERNAME即此处配置名称# clusterConfig: defaultappConfig: 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就会修改检测的地址。

启动dashboard也可以正常访问仪表板