Spring Cloud Turbine

1.概述

本文中，我将向你介绍Spring Cloud Netflix Turbine。它将多个Hystrix Metrics Streams 聚合为一个，以便显示在一个仪表板视图中。
简要介绍Hystrix 。 在微服务架构中，咱们有许多小应用程序相互通讯以完成请求。这些下游服务有可能没法正确响应或彻底失败。为了防止发生级联故障，咱们为微服务设置了Hystrix回退机制。

每一个实现Hystrix的微服务均可以选择公开Hystrix Metrics Streams(经过actuator端点/hystrix.stream)，以便经过Hystrix Dashboard查看。

若是您想了解更多信息，我已在Spring Cloud：Hystrix中详细介绍了这一点。

Turbine是Netflix的一个开源工具，用于将多个流聚合到一个流中。 Spring提供了一个很好的包装器，以方便在Spring生态系统中使用。

2.搭建

相似于Spring Cloud:Hystrix的设置，后端服务以下所示：

• Eureka Server ：做为服务注册运行并在端口8761上运行。
• 推荐服务：一个简单的REST服务，只有一个端点：/recommendations，并在端口8070上运行。
• 用户服务：一个简单的REST服务，单个端点为：/personalized/{id}，并在端口8060上运行。
• Hystrix Turbine ：Hystrix dashboard服务，用于显示Hystrix流，并在端口’9090’上运行。

如下是咱们在Eureka服务器上看到的服务列表：

user-service和recommendation-service都实现了Hystrix回退机制，并经过Actuator暴露了/hystrix.stream端点：

• 用户服务的Hystrix端点：http://localhost:8060/actuator/hystrix.stream
• 用于推荐服务的Hystrix端点：http://localhost:8070/actuator/hystrix.stream

咱们能够在Hystrix dashboard中单独查看这些，方法是在框中键入URL并单击Monitor Stream便可：

你将看到以下指标(metric):

注意:若是没有看到任何流(stream)，那么可能必须点击该stream的服务端点。 例如：对于user-service，咱们能够点击http://localhost:8060/personalized/1来生成流。

3.安装Turbine

你可能已经意识到，查看单个流(stream)的效率不高，尤为是有许多微服务时。

Turbine能够将全部单独的hystrix.stream聚合成一个turbine.stream，以便在Hystrix Dashboard上查看。

它使用DiscoveryClient接口找出生产/hystrix.stream的相关服务。

要将Turbine添加到Hystrix dashboard，请添加如下依赖项：

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-turbine</artifactId> </dependency> 

注意：这是Turbine的starter依赖，默认状况下使用Spring Cloud Eureka做为服务发现。 若是使用的是Spring Cloud Consul，请使用如下依赖项：

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-netflix-turbine</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-consul-discovery</artifactId> </dependency> 

在本文中，咱们将使用starter依赖，即spring-cloud-starter-netflix-turbine。

要启用Turbine，只需使用@EnableTurbine注解主类：

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

为了使Turbine按预期工做，咱们必须在application.properties中添加一些细节：

server.port= 9090  
spring.application.name= hystirx-turbine  
eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/  
turbine.appConfig= user-service,recommendation-service  
turbine.clusterNameExpression= new String("default")

在这里，咱们告诉Turbine Eureka服务器的位置，以及它须要获取/ hystrix.stream的应用程序。并将turbine.clusterNameExpression设为new String("default")，即默认集群名称为“default”。

咱们能够打开http://localhost:9090/turbine.stream?cluster=default来查看user-service和recommendation-service的聚合流：

一样，若是没有查看到任何内容，只需点击user-service和recommendation-service端点便可生成流。

咱们还能够在Hystrix dashboard上使用此URL来生成一个很好的聚合视图：

有时，您可能但愿将Eureka的serviceId用做dashboard的集群名称。这能够经过设置turbine.aggregator.clusterConfig来完成：

server.port = 9090
spring.application.name = hystirx-turbine
eureka.client.serviceUrl.defaultZone = http：// localhost：8761 / eureka /
turbine.aggregator.clusterConfig = USER-SERVICE，RECOMMENDATION-SERVICE
turbine.appConfig =用户服务，推荐服务

您还能够经过点击/clusters端点来检查Turbine应用程序中当前已配置的集群。

能够经过将turbine.endpoints.clusters.enabled设置为false来禁用此端点。

因此，如今咱们能够将turbine.stream视为Eureka ID，例如：http://localhost:9090/turbine.stream?cluster=USER-SERVICE

若是特定服务的多个实例正在运行，Turbine将按照集群进行分拣并将其显示在结果中。

4.总结

在本文中，咱们已经介绍了如何在Hystrix stream的基础上设置Turbine以得到聚合视图。咱们首先看到了Turbine从全部服务中获取Hystrix stream的经典方法。

与往常同样，本文中使用的示例代码能够在GitHub上找到。

原文连接：https://stackabuse.com/spring-cloud-turbine/

做者：Dhananjay Singh

译者： Leesen