上文我们介绍了如何使用Hystrix进行单节点的实时监控，但是对于使用了微服务的系统，会存在很多节点，并且整个服务治理体系也会存在很多服务节点，这就需要有个统一聚合监控工具，Turbine就是这样的一个存在，它可以方便的聚合所有被监控的节点。

在springcloud下可以直接将数据通过Hystrix Stream将数据聚合到Turbine上，但是使用Hystrix Stream来实现会有一个问题就是，监控服务器和被监控服务器是在同一个局域网，并且网络是完全畅通的，在测试环境还可以这样配置，但是在生产环境这样的网络策略是非常不安全的，但是我们可以通过中间件来将数据聚合到dashboard上，springcloud支持通过RabbitMq和Kafka来作为消息中间件来实效被监控服务器向监控server发送监控数据，今天我们就讲下如何使用RabbitMq来实现聚合监控。 RabbitMQ的安装可以参考我的另一篇文章 http://www.jianshu.com/p/6a4c11b22513

1. 被监控Client端

1）增加pom依赖

在被监控端需要增加hystrix、hystrix－stream和springcloud-stream的rabbitmq依赖，增加了这几个依赖就可以保证服务启动后会作为生产者向rabbitmq的queue中发送监控消息。

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-netflix-hystrix-stream</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
        </dependency>

2）application.yml配置rabbitmq

host表示rabbitmq的ip地址，rabbitmq端口默认为5672，username和password分别为创建的rabbitmq的用户名和密码。

spring:
  application:
      name: hystrix-mq
  rabbitmq:
    host: 10.132.XX.XX
    port: 5672
    username: admin
    password: admin

3）controller增加HystrixCommand注解

@RestController
public class TestController {
    @HystrixCommand(fallbackMethod = "error", commandProperties = {
            @HystrixProperty(name="execution.isolation.strategy", value = "THREAD"),
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "4000"),
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "40")
    }, threadPoolProperties = {
            @HystrixProperty(name = "coreSize", value = "1"),
//          @HystrixProperty(name = "maximumSize", value = "5"),
            @HystrixProperty(name = "maxQueueSize", value = "10"),
            @HystrixProperty(name = "keepAliveTimeMinutes", value = "1000"),
            @HystrixProperty(name = "queueSizeRejectionThreshold", value = "8"),
            @HystrixProperty(name = "metrics.rollingStats.numBuckets", value = "12"),
            @HystrixProperty(name = "metrics.rollingStats.timeInMilliseconds", value = "1440")
    })
    @RequestMapping(value = "/hello", method = RequestMethod.GET, produces = {"application/json;charset=UTF-8"})
    public String hello(){
        return "hello hystrix!";
    }

    public String error() {
        return "hello error!";
    }

}

2.Turbine服务端

在监控server端需要通过MQ接收Metrics，并在Turbine dashboard展示。

1）pom引入依赖

        <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>

2）application.yml

server:
  port: 8031
spring:
  application:
    name: turbine
  rabbitmq:
    host: 10.132.XX.XX
    port: 5672
    username: admin
    password: admin
eureka:
  client:
    service-url:
      defaultZone: http://10.132.33.43:8761/eureka/
  instance:
    prefer-ip-address: true

3)Application

在启动的Application中增加 @EnableTurbineStream 注解，即可在启动后自动从queue中搜集监控信息。

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

3.启动rabbitmq

登陆到安装rabbitmq的机器，在命令行输入 service rabbitmq-server start 启动服务。

mq启动好后，再将刚才创建的被监控的client端和监控端Turbine都启动起来，就可以在浏览器输入client端的hystrix dashboard地址进行查看，http://127.0.0.1:8081/hystrix；
并在输入栏中输入turbine的地址 http://127.0.0.1:8031/turbine.stream,启动后一旦有接口调用就会显示dashboard仪表盘监控信息了，启动多个被监控client端，在turbine的仪表盘就可以查看多个节点信息。

Screenshot 2017-09-21 16.03.02.png

实例源码下载：https://github.com/feiweiwei/springcloud-sample