2

我正在使用 spring boot 1.3.1 和 spring cloudl Brixtom.M4，在使用 springboot 1.3.1 时，我发现 Turbine-AMQP 项目不再可用，而是我们现在拥有 Spring Turbine Stream 项目。我用 rabbitmq 或 kafka 使用 SpringTurbine 并想要监视在 Zuul 中注册的所有路由的 hystrix 流，我能够看到 zuul 的 hystrix.stream 并且还能够在 hystrix 仪表板中看到它，但不知道如何使用弹簧涡轮流。在网上我找到了使用 Turbine AMQP 的代码和文档。

我有 zuul 服务器运行 ad http://localhost:9003/与依赖

 <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

和 main.java 作为

@SpringBootApplication
@EnableZuulProxy
@EnableCircuitBreaker
public class EdgeServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(EdgeServerApplication.class, args);
    }
}

我也有 springTurbinestream 项目作为

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-turbine-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

org.springframework.boot spring-boot-starter-actuator

TurbineStream 的主类为

@SpringBootApplication
@EnableTurbineStream
@EnableDiscoveryClient
public class WiziqTurbineApplication {

    public static void main(String[] args) {
        SpringApplication.run(WiziqTurbineApplication.class, args);
    }
}

当我运行应用程序并转到http://localhost:9003/hystrix.stream 时，我看到了流，但是如果我转到http://localhost:9003/turbine.stream，它会出错。

我做错了什么？

4

1 回答 1

2

您的客户端应用程序（在端口 9003 上）不应该具有/turbine.stream. 它应该向兔子发送带有 hystrix 指标的消息（例如）。要做到这一点，您需要添加spring-cloud-netflix-hystrix-stream和spring-cloud-starter-stream-rabbit（就像您在服务器上为*-turbine-*依赖项所做的那样）。

于 2016-01-12T15:16:37.150 回答