hystrix监控.png

在微服务架构中,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注解,再次执行上述操作,界面不断输出监控日志。
helloworld-feign的hystrix监控日志.png

使用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则会显示如下监控结果:

20.png

以上的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的配置,这里收集helloworldhellowordfeign日志
- 启动项目hystrix-turbine后,在hystrix-dashboard中输入http://localhost:8089/turbine.stream,则展示如下聚合结果:

使用Turbine聚合hystrix监控数据

以上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.png

  • 微服务端修改,以便向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 微服务实战》这本书。

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐