在微服务架构中，hystrix处理容错外，还有实时监控功能，在服务发生调用时，会将每秒请求数、成功请求数等运行指标记录下来。
本文示例代码：springcloud-demo
其中本文相关的项目有：
- 服务发现 Eureka Server: discovery
- 链路追踪 sleuth+zipkin:trace
- 服务提供者：hello
- 服务提供者: world
- 服务消费者： helloworld
- 服务消费者: helloworld-feign
- 服务调用监控: hystrix-dashboard
- 监控聚合： hystrix-turbine
- 监控聚合（消息中间件): hystrix-turbine-mq
通过接口的监控
启动helloworld项目后，访问http://localhost:8020/message后，再次访问http://localhost:8020/hystrix.stream可以看到界面不断地输出监控日志，监控日志里包含了各种指标（各种指标信息请参考官方文档）。
按照同样的步骤操作helloworld-feign项目后，却发现找不到该页面，这是因为需要做一些如下配置：
pom.xml引入hystrix依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
在启动类上加上@EnableCircuitBreaker注解，再次执行上述操作，界面不断输出监控日志。
使用hystrix-board对监控进行图形化展示
上面的日志信息不够直观，借助hystrix-dashboard可对监控进行图形化展示。
- 在service创建hystrix-dashboard项目
- 引入hystrix-dashboard依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
</dependency>
- 启动类配置
@EnableHystrixDashboard注解（同时配置@EnableDiscoveryClient向注册中心注册，方便管理） - 配置文件设置端口
server:
port: 8087
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
instance:
instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${server.port}
spring:
application:
name: hystrix-dashboard
- 测试结果
启动hystrix-dashboard后，输入http://localhost:8087/hystrix地址，出现文章第一张图所示的界面。在第一个文本框输入http://localhost:8020/hystrix.stream或者http://localhost:8030/hystrix.stream后点击Monitor Stream则会显示如下监控结果：
以上的hystrix-dashboard每次只能输入一个监控地址，在微服务架构中往往有很多无法需要监控，该怎么办呢？
可以使用Turbine聚合监控数据，让hystrix-dashboard显示这个聚合数据后的地址。
Turbine聚合监控数据
- 创建一个hystrix-turbine项目，引入如下maven依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-turbine</artifactId>
</dependency>
- 启动类上配置@EnableTurbine注解
- 配置文件
application.yml指明要从收集哪些微服务的监控数据
server:
port: 8088
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
instance:
instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${server.port}
prefer-ip-address: true
spring:
application:
name: hystrix-turbine
turbine:
app-config: helloworld,helloworldfeign
cluster-name-expression: "'default'"
注意turbine的配置，这里收集helloworld和hellowordfeign日志
- 启动项目hystrix-turbine后，在hystrix-dashboard中输入
http://localhost:8089/turbine.stream,则展示如下聚合结果：
以上Turbine聚合微服务的监控数据，然后在hystrix-dashboard展示多个微服务的实时监控数据。 但是Turbine也有它的局限性，比如服务之间无法通信，服务不在Eureka Server上注册，则Turbine无法收集到微服务的日志。那么这种情况下，需要借助消息中间件来解决。
通过消息中间件RabbitMQ收集监控数据
微服务在发生调用时，将监控数据存储到RabbitMQ，监控从RabbitMQ获取数据进行实时展示，这样有利于微服务和监控端进行解耦，可以解决不在服务中心注册的服务的监控数据也可以被收集到。
- 安装RabbitMQ
使用如下docker命令安装RabbitMQ，并暴露相应的端口（本人开发机为linux环境，docker的使用可以极大提高软件安装和项目部署的效率，推荐使用docker）
docker run -d --name rabbitmq -p 5673:5672 -p 15673:15672 docker.io/rabbitmq:3-management
这样向外暴露5673的连接端口和15673的web端口，默认用户名密码是guest。
- 微服务端修改，以便向RabbitMQ传输监控日志
本文以helloworld为例改造微服务，pom中引入依赖
<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>
配置文件中加上连接RabbitMQ的配置
spring:
rabbitmq:
host: localhost
port: 5673
username: guest
password: guest
重启helloworld,并在浏览器输入http://localhost:8020/message形成监控数据。
- 新建hystrix-turbine-mq项目
项目中引入turbine和rabbitmq依赖
<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>
启动类上配置@EnableTurbineStream注解
配置文件：
server:
port: 8089
eureka:
client:
serviceUrl:
defaultZone: http://localhost:8761/eureka/
instance:
instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${server.port}
prefer-ip-address: true
spring:
application:
name: hystrix-turbine-mq
rabbitmq:
host: localhost
port: 5673
username: guest
password: guest
这样指明了监控的数据来源。
- 测试结果
启动hystrix-dashboard后，输入http://localhost:8089即可展示如下的监控结果：
RabbitMQ收集监控数据.png
本文参考了《Spring cloud 与Docker 微服务实战》这本书。
