3.spring cloud服务注册中心eureka server---Hystrix Dashboard的turbine集成(第四章)

水深无声 2022-04-17 04:23 102阅读 0赞

### Hystrix Dashboard的turbine集成 ###

本文中示例代码的引用版本：  
org.springframework.boot 版本 ：2.1.0.RELEASE  
org.springframework.cloud 版本：Greenwich.M1  
[示例代码-码云][-] [https://gitee.com/sharps/springcloud][-]  
在复杂的分布式系统中，相同服务的节点经常需要部署上百甚至上千个，很多时候，运维人员希望能够把相同服务的节点状态以一个整体集群的形式展现出来，这样可以更好的把握整个系统的状态。 为此，Netflix提供了一个开源项目（Turbine）来提供把多个hystrix.stream的内容聚合为一个数据源供Dashboard展示。

### 第一步、新建0406spring-cloud-hystrix-dashboard-turbine项目 ###

#### 1、添加依赖 ####

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-turbine</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-netflix-turbine</artifactId>
    		</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-dashboard</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>

#### 2、配置文件 ####

spring.application.name=hystrix-dashboard-turbine
    server.port=8001
    turbine.appConfig=node01,node02
    turbine.aggregator.clusterConfig= default
    turbine.clusterNameExpression= new String("default")
    spring.security.user.name=user
    spring.security.user.password=123456
    eureka.client.serviceUrl.defaultZone=http://user:123456@localhost:8000/eureka/
    turbine.instanceUrlSuffix=hystrix.stream

*  turbine.appConfig ：配置Eureka中的serviceId列表，表明监控哪些服务
 *  turbine.aggregator.clusterConfig  
    ：指定聚合哪些集群，多个使用”,”分割，默认为default。可使用http://…/turbine.stream?cluster=\{clusterConfig之一\}访问
 *  turbine.clusterNameExpression ：  
    A. clusterNameExpression指定集群名称，默认表达式appName；此时：turbine.aggregator.clusterConfig需要配置想要监控的应用名称；  
    B. 当clusterNameExpression: default时，turbine.aggregator.clusterConfig可以不写，因为默认就是default；  
    C. 当clusterNameExpression:metadata\[‘cluster’\]时，假设想要监控的应用配置了eureka.instance.metadata-map.cluster: ABC，则需要配置，同时turbine.aggregator.clusterConfig: ABC

#### 3、启动类 ####

启动类添加@EnableTurbine，激活对Turbine的支持

@SpringBootApplication
    @EnableHystrixDashboard
    @EnableTurbine
    public class TurbineApplication { 
    	public static void main(String[] args) { 
    		SpringApplication.run(TurbineApplication.class, args);
    	}
    }

到此Turbine（0406spring-cloud-hystrix-dashboard-turbin）配置完成

### 第二步、新建0404spring-cloud-consumer-node1和0405spring-cloud-consumer-node2 ###

在示例项目0303spring-cloud-consumer-hystrix基础上修改为两个服务的调用者0404spring-cloud-consumer-node1和0405spring-cloud-consumer-node2

#### 1、添加依赖 ####

##### 0404spring-cloud-consumer-node1和0405spring-cloud-consumer-node2添加依赖 #####

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-openfeign</artifactId>
    		</dependency>
    		<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>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-autoconfigure</artifactId>
    		</dependency>

#### 2、配置文件 ####

##### 0404spring-cloud-consumer-node1项目改动如下： #####

###### application.properties文件内容 ######

spring.application.name=node01
    server.port=9991
    spring.security.basic.enabled=true
    spring.security.user.name=user
    spring.security.user.password=123456
    feign.hystrix.enabled=true
    eureka.client.serviceUrl.defaultZone=http://user:123456@localhost:8000/eureka/

##### 0405spring-cloud-consumer-node2项目改动如下： #####

###### application.properties文件内容: ######

spring.application.name=node02
    server.port=9992
    spring.security.basic.enabled=true
    spring.security.user.name=user
    spring.security.user.password=123456
    eureka.client.serviceUrl.defaultZone=http://user:123456@localhost:8000/eureka/
    feign.hystrix.enabled=true

#### 3、启动类 ####

##### 0404spring-cloud-consumer-node1和0405spring-cloud-consumer-node2项目改动如下： #####

###### SpringCloudConsumerApplication启动类修改 ######

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    @EnableCircuitBreaker
    @EnableHystrixDashboard
    public class SpringCloudConsumerApplication { 
    	public static void main(String[] args) { 
    		SpringApplication.run(SpringCloudConsumerApplication.class, args);
    	}
    	@Bean
    	public ServletRegistrationBean getServlet() { 
    		HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
    		ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
    		registrationBean.setLoadOnStartup(1);
    		registrationBean.addUrlMappings("/hystrix.stream");
    		registrationBean.setName("hystrixMetricsStreamServlet");
    		return registrationBean;
    	}
    }

##### 0405spring-cloud-consumer-node2项目改动如下： #####

###### HelloRemote类修改： ######

@FeignClient(name= "spring-cloud-producer2", fallback = HelloRemoteHystrix.class)
    public interface HelloRemote { 
        @RequestMapping(value = "/hello")
        public String hello2(@RequestParam(value = "name") String name);
    }

对应的HelloRemoteHystrix和ConsumerController类跟随修改，具体查看代码

### 第三步、测试 ###

依次启动0401spring-cloud-eureka、0403spring-cloud-producer、0404spring-cloud-consumer-node1、0405spring-cloud-consumer-node1、0406spring-cloud-hystrix-dashboard-turbine项目

1、服务注册中心 0401spring-cloud-eureka [http://localhost:8000/][http_localhost_8000]  
打开eureka后台可以看到注册了四个服务：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70]

2、服务提供者 0403spring-cloud-producer [http://localhost:9001/hello?name=llx][http_localhost_9001_hello_name_llx]  
![在这里插入图片描述][20181113150449641.png]  
3、服务消费者  
0404spring-cloud-consumer-node1  
[http://localhost:9991/hello/llx][http_localhost_9991_hello_llx]  
[http://localhost:9991/hystrix.stream][http_localhost_9991_hystrix.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 1]

0405spring-cloud-consumer-node2  
[http://localhost:9992/hello/llx][http_localhost_9992_hello_llx]  
[http://localhost:9992/hystrix.stream][http_localhost_9992_hystrix.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 2]  
4、hystrix-dashboard-turbine服务  
0406spring-cloud-hystrix-dashboard-turbine  
[http://localhost:8001/turbine.stream][http_localhost_8001_turbine.stream]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 3]  
并且会不断刷新以获取实时的监控数据，说明和单个的监控类似，返回监控项目的信息。进行图形化监控查看，输入：[http://localhost:8001/hystrix，返回酷酷的小熊界面，输入：][http_localhost_8001_hystrix] [http://localhost:8001/turbine.stream，然后点击][http_localhost_8001_turbine.stream 1] Monitor Stream ,可以看到出现了俩个监控列表  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 4]

[-]: https://gitee.com/sharps/springcloud
[http_localhost_8000]: http://localhost:8000/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70]: /images/20220417/2e52a875e8d24c90913625eb66de66a3.png
[http_localhost_9001_hello_name_llx]: http://localhost:9001/hello?name=llx
[20181113150449641.png]: /images/20220417/e6c9b395a1354125b1635128b39c56ae.png
[http_localhost_9991_hello_llx]: http://localhost:9991/hello/llx
[http_localhost_9991_hystrix.stream]: http://localhost:9991/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 1]: /images/20220417/28b81148451345e3b66767346f18f376.png
[http_localhost_9992_hello_llx]: http://localhost:9992/hello/llx
[http_localhost_9992_hystrix.stream]: http://localhost:9992/hystrix.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 2]: /images/20220417/36beab50e7dc45e0b0941f350638c813.png
[http_localhost_8001_turbine.stream]: http://localhost:8001/turbine.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 3]: /images/20220417/8ce3764c12064336910430e2cb357e9c.png
[http_localhost_8001_hystrix]: http://localhost:8001/hystrix%EF%BC%8C%E8%BF%94%E5%9B%9E%E9%85%B7%E9%85%B7%E7%9A%84%E5%B0%8F%E7%86%8A%E7%95%8C%E9%9D%A2%EF%BC%8C%E8%BE%93%E5%85%A5%EF%BC%9A
[http_localhost_8001_turbine.stream 1]: http://localhost:8001/turbine.stream%EF%BC%8C%E7%84%B6%E5%90%8E%E7%82%B9%E5%87%BB
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzQyMDE1_size_16_color_FFFFFF_t_70 4]: /images/20220417/93355a88c3884df6b69fb8e17e823355.png