Spring Cloud : Turbine

时间：2020-09-07 18:52:35 阅读：49 评论：0 收藏：0 [点我收藏+]

标签：用户服仪表 Turbine 响应 points consul 通信回退 host

点击左上角，关注：“锅外的大佬”

专注分享国外最新技术内容
帮助每位开发者更优秀地成长

1.概述

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

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

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

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

2.搭建

类似于 SpringCloud:Hystrix的设置，后端服务如下所示：

Eureka Server ：作为服务注册运行并在端口8761上运行。
推荐服务：一个简单的REST服务，只有一个端点： /recommendations，并在端口8070上运行。
用户服务：一个简单的REST服务，单个端点为： /personalized/{id}，并在端口8060上运行。
Hystrix Turbine ： Hystrixdashboard服务，用于显示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
我们可以在 Hystrixdashboard中单独查看这些，方法是在框中键入URL并单击 MonitorStream即可：

你将看到如下指标(metric):
技术图片

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

3.安装Turbine

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

Turbine可以将所有单独的 hystrix.stream聚合成一个 turbine.stream，以便在 HystrixDashboard上查看。

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

要将 Turbine添加到 Hystrixdashboard，请添加以下依赖项：

<dependency>

<groupId>
org.springframework.cloud
</groupId>

<artifactId>
spring-cloud-starter-netflix-turbine
</artifactId>
</dependency>

注意：这是 Turbine的 starter依赖，默认情况下使用 SpringCloudEureka作为服务发现。如果使用的是 SpringCloudConsul，请使用以下依赖项：

<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设为 newString("default")，即默认集群名称为“default”。

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

技术图片
同样，如果没有查看到任何内容，只需点击 user-service和 recommendation-service端点即可生成流。

我们还可以在 Hystrixdashboard上使用此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来禁用此端点。
技术图片