上文我们介绍了如何使用Hystrix进行单节点的实时监控，但是对于使用了微服务的系统，会存在很多节点，并且整个服务治理体系也会存在很多服务节点，这就需要有个统一聚合监控工具，Turbine就是这样的一个存在，它可以方便的聚合所有被监控的节点。
在springcloud下可以直接将数据通过Hystrix Stream将数据聚合到Turbine上，但是使用Hystrix Stream来实现会有一个问题就是，监控服务器和被监控服务器是在同一个局域网，并且网络是完全畅通的，在测试环境还可以这样配置，但是在生产环境这样的网络策略是非常不安全的，但是我们可以通过中间件来将数据聚合到dashboard上，springcloud支持通过RabbitMq和Kafka来作为消息中间件来实效被监控服务器向监控server发送监控数据，今天我们就讲下如何使用RabbitMq来实现聚合监控。 RabbitMQ的安装可以参考我的另一篇文章 //www.greatytc.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的仪表盘就可以查看多个节点信息。
