springCloud(12):使用Hystrix实现微服务的容错处理-Hystrix的监控

简介:

一、简介

Hystrix提供了几乎实时的监控。HystrixCommand和HystrixObserv-ableCommand在执行时,会生成执行结果和运行指标,比如每秒执行的请求数、成功数等,这些监控数据对分析应用系统的状态很有用。


使用Hystrix的模块hystrix-metrics-event-stream,就可将这些监控的指标信息以text/event-stream的格式暴露给外部系统。spring-cloud-starter-hystrix已包含该模块,在此基础上,只须为项目添加spring-boot-starter-actuator,就可使用/hystrix.stream端点获得Hystrix的监控信息了。


我们以前的项目spring-hystrix-consumer中就已经包含了spring-cloud-starter-hystrix、spring-boot-starter-actuator,启动访问:http://localhost:8087/user/1 后,再访问:http://localhost:8087/manage/hystrix.stream ,会重复出现如下内容:

wKiom1maPZvQU-M8AAD290ZwrgM885.jpg

这是因为系统会不断地刷新以获取实时的监控数据.Hystrix的监控指标非常全面,例如HystrixCommand的名称、group名称、断路器状态、错误率、错误数等。

二、使用Hystrix Dashboard可视化监控数据

前面通过访问/hystrix.stream端点获得的数据很难一眼看出系统当前的运行状态,可是使用Hystrix Dashboard可以让监控数据图形化、可视化。

操作:

 1、创建一个maven工程,加入Hystrix Dashboard依赖

1
2
3
4
     <dependency>
         <groupId>org.springframework.cloud< / groupId>
     <artifactId>spring - cloud - starter - hystrix - dashboard< / artifactId>
     < / dependency>

 2、编写启动类,添加@EnableHystrixDashboard注解

 3、配置yml文件端口8086

测试:

 1、访问http://localhost:8087/hystrix.stream,可看到Hystrix Dashbord的主页,如下:

  wKiom1maSoeBBuTuAAFa7YMncZU258.jpg 


 2、随意设置一个title,并点击Monitor Stream,这里Title是:测试,URl是:http://localhost:8087/manage/hystrix.stream

   wKiom1maT7iTdnGsAACpgiSlN9I816.jpg

注意:此处没有将Hystrix Dashboard注册到Eureka Server上,在生产环境中,为了更方便的管理Hystrix Dashboard,可将其注册到Eureka Server上。

三、使用Turbine聚合监控数据

前面使用的/hystrix.stream端点监控单个微服务。然而在使用微服务架构的应用系统一般会包含多个微服务,每个微服务通常都会部署多个实例。如果每次只能查看单个实例的监控数据,就必须在Hystrix Dashboard上切换想要监控的地址,这显然很不方便。

3.1、Turbine简介

Turbine是一个聚合Hystrix监控数据的工具,它可将所有相关/hystrix.stream端点的数据聚合到一个组合的/turbine.stream中,从而让集群的监控更加方便。

wKiom1maU5jBWjnIAAA6qQybiqo607.jpg

3.2、使用Turbine监控多个微服务

a、创建一个maven项目,添加turbine依赖:

1
2
3
4
5
<!-- turbine -->
< dependency >
     < groupId >org.springframework.cloud</ groupId >
     < artifactId >spring-cloud-starter-turbine</ artifactId >
</ dependency >

b、在启动类上添加@EnableTurbine注解

c、编写application.yml配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
spring:
   profiles:
     active:
     - dev
   application:
     name: hystrix-turbine
eureka:
   client:
     service-url:
       defaultZone: http://liuy2:5010/eureka/  # 设置与Eureka Server交互的地址,查询服务和注册服务都需要依赖这个地址,多个用逗号分隔
   instance:
     prefer-ip-address: true
turbine:
   app-config: hystrix-consumer-movie,ribbon-consumer-movie   # 参数指定了需要收集监控信息的服务名
   cluster-name-expression:  "'default'"  # 参数指定了集群名称为
---
spring:
   profiles:
     active: dev
server:
   port: 5014

说明:使用上面配置,Turbine会在Eureka Server中找到hystrix-consumer-movie和ribbon-consumer-movie这两个微服务,并聚合这两个微服务的监控数据。

d、测试

 第一步:依次启动Eureka Server(4010)、provide-user(4011)、hystrix-consumer-movie(5012)、ribbon-consumer-movie(5011)、hystrix-turbine(5014)、hystrix-dashboard(5013)

 第二步:访问http://localhost:5012/user/1,让hystrix-consumer-movie微服务产生监控数据

 第三步:访问http://localhost:5011/user/1,让ribbon-consumer-movie微服务产生监控数据

 第四步:打开Hystrix Dashboard首页http://localhost:5013/hystrix.stream,在URL栏填写http://localhost:5014/turbine.stream,随意填写title,点击Monitor Stream后出现如下图:

  wKiom1mbirHhhFJjAACC2V2qPCM523.png

问题:在一些场景下,如微服务与Turbine网络不通,监控数据怎么处理? -- 使用消息中间件收集数据

3.3、使用rabbitmq收集监控数据

改造微服务:hystrix-consumer-movie

 a、添加以下依赖

1
2
3
4
5
6
7
8
     < 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 >

 b、在application.yml中添加

1
2
3
4
5
6
     spring:
       rabbitmq:
         host: 192.168.175.13
         port: 5672
         username: liuy
         password: 123456

改造:hystrix-turbine

 a、添加以下依赖

1
2
3
4
5
6
7
8
9
     < dependency >
         < groupId >org.springframework.cloud</ groupId >
     < artifactId >spring-cloud-starter-turbine-stream</ artifactId >
     </ dependency >
     <!-- rabbit -->
     < dependency >
         < groupId >org.springframework.cloud</ groupId >
     < artifactId >spring-cloud-starter-stream-rabbit</ artifactId >
     </ dependency >

   注意:此处删除spring-cloud-starter-turbine依赖

 b、修改启动类,将@EnableTurbine改成@EnableTurbineStream

 c、修改application.yml

1
2
3
4
5
6
     spring:
       rabbitmq:
         host: 192.168.175.13
         port: 5672
         username: liuy
         password: 123456

   同时删除:turbine


测试:

 第一步:依次启动Eureka Server(4010)、provide-user(4011)、hystrix-dashboard(5013)、hystrix-consumer-movie-rabbitmq(5020)、hystrix-turbine-rabbitmq(5021)

 第二步:访问http://localhost:5020/user/1,可正常获取结果

 第三步:打开Hystrix Dashboard首页http://localhost:5013/hystrix.stream,在URL栏填写http://localhost:5021/,随意填写title,点击Monitor Stream后出现如下图:

  wKioL1mbv4GAwOJoAACbz850ojw096.png

本文转自我爱大金子博客51CTO博客,原文链接http://blog.51cto.com/1754966750/1949857如需转载请自行联系原作者

我爱大金子
相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
10月前
|
算法 Java 微服务
【SpringCloud(1)】初识微服务架构:创建一个简单的微服务;java与Spring与微服务;初入RestTemplate
微服务架构是What?? 微服务架构是一种架构模式,它提出将单一应用程序划分为一组小的服务,服务之间互相协调、互相配合,为用户提供最终价值。 每个服务允许在其独立的进程中,服务于服务间采用轻量级的通信机制互相协作(通常是Http协议的RESTful API或RPC协议)。 每个服务都围绕着具体业务进行构建,并且能够被独立的部署到生产环境、类生产环境等。另外应当尽量避免统一的、集中式的服务管理机制,对具体的一个服务而言,应根据上下文,选择合适的语言、工具对其进行构建
764 126
|
10月前
|
负载均衡 算法 Java
【SpringCloud(2)】微服务注册中心:Eureka、Zookeeper;CAP分析;服务注册与服务发现;单机/集群部署Eureka;连接注册中心
1. 什么是服务治理? SpringCloud封装了Netfix开发的Eureka模块来实现服务治理 在传统pc的远程调用框架中,管理每个服务与服务之间依赖关系比较复杂,管理比较复杂,所以需要使用服务治理,管理服务于服务之间依赖关系,可以实现服务调用、负载均衡、容错等,实现服务发现与注册
511 0
|
10月前
|
负载均衡 Java API
《深入理解Spring》Spring Cloud 构建分布式系统的微服务全家桶
Spring Cloud为微服务架构提供一站式解决方案,涵盖服务注册、配置管理、负载均衡、熔断限流等核心功能,助力开发者构建高可用、易扩展的分布式系统,并持续向云原生演进。
|
11月前
|
监控 安全 Java
Spring Cloud 微服务治理技术详解与实践指南
本文档全面介绍 Spring Cloud 微服务治理框架的核心组件、架构设计和实践应用。作为 Spring 生态系统中构建分布式系统的标准工具箱,Spring Cloud 提供了一套完整的微服务解决方案,涵盖服务发现、配置管理、负载均衡、熔断器等关键功能。本文将深入探讨其核心组件的工作原理、集成方式以及在实际项目中的最佳实践,帮助开发者构建高可用、可扩展的分布式系统。
653 1
|
11月前
|
jenkins Java 持续交付
使用 Jenkins 和 Spring Cloud 自动化微服务部署
随着单体应用逐渐被微服务架构取代,企业对快速发布、可扩展性和高可用性的需求日益增长。Jenkins 作为领先的持续集成与部署工具,结合 Spring Cloud 提供的云原生解决方案,能够有效简化微服务的开发、测试与部署流程。本文介绍了如何通过 Jenkins 实现微服务的自动化构建与部署,并结合 Spring Cloud 的配置管理、服务发现等功能,打造高效、稳定的微服务交付流程。
1185 0
使用 Jenkins 和 Spring Cloud 自动化微服务部署
|
缓存 运维 监控
微服务技术系列教程(22) - SpringCloud- 服务保护机制Hystrix
微服务技术系列教程(22) - SpringCloud- 服务保护机制Hystrix
331 0
|
监控 Java API
Spring cloud Hystrix 、Dashboard、API(zuul)相关报错
Spring cloud Hystrix 、Dashboard、API(zuul)相关报错
410 2
springCloud之服务降级熔断Hystrix、OpenFeign
springCloud之服务降级熔断Hystrix、OpenFeign
1567 0
|
XML 监控 Java
Spring Cloud全解析:熔断之Hystrix简介
Hystrix 是由 Netflix 开源的延迟和容错库,用于提高分布式系统的弹性。它通过断路器模式、资源隔离、服务降级及限流等机制防止服务雪崩。Hystrix 基于命令模式,通过 `HystrixCommand` 封装对外部依赖的调用逻辑。断路器能在依赖服务故障时快速返回备选响应,避免长时间等待。此外,Hystrix 还提供了监控功能,能够实时监控运行指标和配置变化。依赖管理方面,可通过 `@EnableHystrix` 启用 Hystrix 支持,并配置全局或局部的降级策略。结合 Feign 可实现客户端的服务降级。
1050 23
|
Java 对象存储 开发者
故障隔离与容错处理:Hystrix在Spring Cloud和Netflix OSS中的应用
故障隔离与容错处理:Hystrix在Spring Cloud和Netflix OSS中的应用
402 3