博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spring Cloud Hystrix(断路器)
阅读量:6257 次
发布时间:2019-06-22

本文共 3794 字,大约阅读时间需要 12 分钟。

Hystrix:熔断器,容错管理工具,旨在通过熔断机制控制服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。

github地址:

微服务存在的问题

在微服务架构中,我们将系统拆分为很多个服务,各个服务之间通过注册与订阅的方式相互依赖,由于各个服务都是在各自的进程中运行,就有可能由于网络原因或者服务自身的问题导致调用故障或延迟,随着服务的积压,可能会导致服务崩溃。为了解决这一系列的问题,断路器等一系列服务保护机制出现了。

断路器本身是一种开关保护机制,类似于保险丝,用于在电路上保护线路过载,当线路中有电器发生短路时,断路器能够及时切断故障电路,防止发生过载、发热甚至起火等严重后果。

  在分布式架构中,断路器模式的作用也是类似的。
  针对上述问题,Spring Cloud Hystrix 实现了断路器、线路隔离等一系列服务保护功能。它也是基于 Netflix 的开源框架 Hystrix 实现的,该框架的目标在于通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。Hystrix 具备服务降级、服务熔断、线程和信号隔离、请求缓存、请求合并以及服务监控等强大功能。
官方完整文档,操作详细信息和其他信息:
API文档:

场景展现

在上一篇文章Ribbon(消费者)的基础下测试

访问
关闭掉8082的实例,再刷新服务的时候可以看到

image.png

端口为8082服务挂掉了并显示出错误信息

这样的显示对于用户来说是十分不好的,这样就需要引入断路器

实现断路器Hystrix

本次是在上一篇Ribbon(消费者)的工程上搭建的

引入Spring Cloud Hystrix的依赖

org.springframework.cloud
spring-cloud-starter-netflix-hystrix

使用 @EnableCircuitBreaker 注解开启断路器功能

@SpringBootApplication@EnableEurekaClient@EnableCircuitBreakerpublic class SpringcloudConsumerRibbonApplication {    @Bean    @LoadBalanced    public RestTemplate restTemplate() {        return new RestTemplate();    }    public static void main(String[] args) {        SpringApplication.run(SpringcloudConsumerRibbonApplication.class, args);    }}

Controller调用方法的method加上@HystrixCommand注解,声明依赖服务调用延迟或失败时调用的方法

@RestControllerpublic class RibbonController {    @Autowired    RestTemplate restTemplate;    @GetMapping("/consumer")    @HystrixCommand(fallbackMethod ="Failback")    public String getMsg() {        return restTemplate.getForObject("http://springcloud-eureka-client/client", String.class);    }    public String Failback(){        return "服务中断连接,请联系管理员";    }}

配置文件可以不用改(有需要设置参数的可以参考文章下方的推荐文章)

整体项目结构(基本上可Ribbon的一样)

Eureka服务端 端口号是9090

两个Eureka客户端 端口号分别是8081和8082 相同的服务名springcloud-eureka-client
Ribbon消费者客户端 端口号是9999

启动服务进行测试

先启动服务端再启动客户端,客户端启动顺序没要求

启动完后我们访问
关闭掉8082的实例,再刷新服务的时候可以看到

image.png
设置的服务中断回调方法使用了,说明断路器生效了

使用Hystrix-Dashboard实现hystrix服务监控功能

github地址:

hystrix还提供了服务监控功能,可以监控服务消费者的接口调用状态,但返回的监控数据为json数据,不适合我们查看,因此需要我们搭建hystrix-dashboard服务,把json数据整理为图形化数据

1.引入hystrix-dashboard依赖

org.springframework.cloud
spring-cloud-starter-netflix-hystrix-dashboard

2.在主类中添加@EnableHystrixDashboard注解开启Hystrix仪表盘

@SpringBootApplication@EnableEurekaClient@EnableCircuitBreaker@EnableHystrixDashboardpublic class SpringcloudConsumerRibbonApplication {    @Bean    @LoadBalanced    public RestTemplate restTemplate() {        return new RestTemplate();    }    public static void main(String[] args) {        SpringApplication.run(SpringcloudConsumerRibbonApplication.class, args);    }}

3.配置hystrix-metrics-event-stream

在整个监控统计过程中,最主要的是用到hystrix-metrics-event-stream
hystrix-metrics-event-stream:只要客户端连接还连着,hystrix-metrics-event-stream就会不断的向客户端以text/event-stream的形式推送计数结果(metrics)

使用hystrix-metrics-event-stream需要写个配置类

@Configurationpublic class HystrixMetricsStreamConfig {    @Bean    public HystrixMetricsStreamServlet hystrixMetricsStreamServlet(){        return new HystrixMetricsStreamServlet();    }    @Bean    public ServletRegistrationBean registration(HystrixMetricsStreamServlet servlet){        ServletRegistrationBean registrationBean = new ServletRegistrationBean();        registrationBean.setServlet(servlet);        registrationBean.setEnabled(true);        registrationBean.addUrlMappings("/hystrix.stream");        return registrationBean;    }}

加上@Configuration注解声明为配置类

配置类中默认的监控路径是/hystrix.stream

如果不写的话是监控不了的

image.png

完成上述配置后,访问可以看到小熊界面说明配置成功

image.png
输入监控的streamtitle,点击Monitor Stream,便会出现图形化的监控页面。
一般只需要填入监控地址就可以了,例如需要监控端口号为9999的服务
就填入
image.png
点击Monitor Stream,进去都看到Loading...,因为端口9999的服务还没调用
image.png
下面来访问下
image.png
便会出现图形化的监控页面,这样就实现了监控的效果了。

推荐文章:

关于Hystrix和Hystrix-Dashboard各种配置参数可以参考:
关于hystrix-metrics-event-stream源码解析的可以参考

转载地址:http://kzisa.baihongyu.com/

你可能感兴趣的文章
SVN与TortoiseSVN实战:补丁详解
查看>>
java一些面试题
查看>>
干货型up主
查看>>
获取页面中所有dropdownlist类型控件
查看>>
读《淘宝数据魔方技术架构解析》有感
查看>>
[转载]如何破解Excel VBA密码
查看>>
【BZOJ】2563: 阿狸和桃子的游戏
查看>>
redis 中文字符显示
查看>>
国内外MD5在线解密网站
查看>>
【OC语法要闻速览】一、方法调用
查看>>
Git-命令行-删除本地和远程分支
查看>>
本文将介绍“数据计算”环节中常用的三种分布式计算组件——Hadoop、Storm以及Spark。...
查看>>
顺序图【6】--☆☆
查看>>
Docker Swarm 让你事半功倍
查看>>
string.Format字符串格式说明
查看>>
[转]IC行业的牛人
查看>>
javaScript事件(四)event的公共成员(属性和方法)
查看>>
linux系统常用命令
查看>>
在 Word 中的受支持的区域设置标识符的列表
查看>>
Caffe + Ubuntu 14.04 64bit + CUDA 6.5 配置说明2
查看>>