Spring Cloud Hystrix(断路器)
Hystrix:熔断器,容错管理工具,旨在通过熔断机制控制服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。
github地址:https://github.com/Netflix/hystrix
微服务存在的问题
在微服务架构中,我们将系统拆分为很多个服务,各个服务之间通过注册与订阅的方式相互依赖,由于各个服务都是在各自的进程中运行,就有可能由于网络原因或者服务自身的问题导致调用故障或延迟,随着服务的积压,可能会导致服务崩溃。为了解决这一系列的问题,断路器等一系列服务保护机制出现了。
断路器本身是一种开关保护机制,类似于保险丝,用于在电路上保护线路过载,当线路中有电器发生短路时,断路器能够及时切断故障电路,防止发生过载、发热甚至起火等严重后果。
在分布式架构中,断路器模式的作用也是类似的。
针对上述问题,Spring Cloud Hystrix 实现了断路器、线路隔离等一系列服务保护功能。它也是基于 Netflix 的开源框架 Hystrix 实现的,该框架的目标在于通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。Hystrix 具备服务降级、服务熔断、线程和信号隔离、请求缓存、请求合并以及服务监控等强大功能。
官方完整文档,操作详细信息和其他信息:https://github.com/Netflix/Hystrix/wiki
API文档:https://netflix.github.io/Hystrix/javadoc/
场景展现
在上一篇文章Ribbon
(消费者)的基础下测试
访问http://localhost:9999/consumer
关闭掉8082的实例,再刷新服务的时候可以看到
端口为8082服务挂掉了并显示出错误信息
这样的显示对于用户来说是十分不好的,这样就需要引入断路器
实现断路器Hystrix
本次是在上一篇Ribbon(消费者)的工程上搭建的
https://www.jianshu.com/p/ede7aae5d78e
引入Spring Cloud Hystrix
的依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
使用 @EnableCircuitBreaker
注解开启断路器功能
@SpringBootApplication @EnableEurekaClient @EnableCircuitBreaker public class SpringcloudConsumerRibbonApplication { @Bean @LoadBalanced public RestTemplate restTemplate() { return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(SpringcloudConsumerRibbonApplication.class, args); } }
在Controller
调用方法的method
加上@HystrixCommand
注解,声明依赖服务调用延迟或失败时调用的方法
@RestController public 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
启动服务进行测试
先启动服务端再启动客户端,客户端启动顺序没要求
启动完后我们访问http://localhost:9999/consumer
关闭掉8082的实例,再刷新服务的时候可以看到
设置的服务中断回调方法使用了,说明断路器生效了
使用Hystrix-Dashboard实现hystrix
服务监控功能
github地址:https://github.com/Netflix-Skunkworks/hystrix-dashboardhystrix
还提供了服务监控功能,可以监控服务消费者的接口调用状态,但返回的监控数据为json
数据,不适合我们查看,因此需要我们搭建hystrix-dashboard
服务,把json
数据整理为图形化数据
1.引入hystrix-dashboard
依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId> </dependency>
2.在主类中添加@EnableHystrixDashboard
注解开启Hystrix
仪表盘
@SpringBootApplication @EnableEurekaClient @EnableCircuitBreaker @EnableHystrixDashboard public 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
需要写个配置类
@Configuration public 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
如果不写的话是监控不了的
完成上述配置后,访问http://localhost:9999/hystrix可以看到小熊界面说明配置成功
输入监控的
stream
和title
,点击Monitor Stream
,便会出现图形化的监控页面。 一般只需要填入监控地址就可以了,例如需要监控端口号为9999的服务
就填入http://localhost:9999/hystrix.stream
点击
Monitor Stream
,进去都看到Loading...
,因为端口9999的服务还没调用 下面来访问下http://localhost:9999/consumer
便会出现图形化的监控页面,这样就实现了监控的效果了。
推荐文章:
关于Hystrix和Hystrix-Dashboard各种配置参数可以参考:https://blog.csdn.net/tongtong_use/article/details/78611225
关于hystrix-metrics-event-stream源码解析的可以参考https://www.cnblogs.com/zhangwanhua/p/7904625.html
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
三问(why?what?how?)金融领域的机器学习
机器学习可能会很有魔力,即使它背后没有魔法。尽管如此,机器学习项目的成功更多地取决于构建高效的基础架构,收集合适的数据集以及应用正确的算法。 机器学习已经在金融服务行业中取得重大进展。让我们看看为什么金融公司可以通过AI和机器学习实现什么解决方案,以及他们如何应用这项技术。 定义 我们可以将机器学习定义为数据科学的一个子集,它使用统计模型来绘制洞察并进行预测。下图解释了人工智能,数据科学和机器学习之间的关系。为了简单起见,我们在这篇文章中专注于机器学习。 机器学习解决方案的神奇之处在于,他们可以从经验中学习而无需明确编程。简而言之,你需要选择模型并将数据提供给它们。然后,模型会自动调整其参数以改善结果。 数据科学家使用现有数据集训练机器学习模型,然后将训练有素的模型应用于现实生活中。 模型作为后台进程运行,并根据其训练方式自动提供结果。数据科
- 下一篇
HyperLedger Fabric 1.2 区块链应用场景(3.1)
比特币是区块链应用最早的场景,随着比特币安全稳定运行多年以后,数字货币的场景应用遍地开花,各种山寨币泛滥,通过ICO(Initial Coin Offering 首次币发行)就能融到大量资金,上市后的数字货币就像股票一样可以进自由交易,这类应用主流称为区块链1.0。 技术人员通过对比特币等数字货币的技术研究,梳理出数字货币中涉及的各类技术,如加密算法、端对端传输、共识算法,提炼并形成区块链架构理论;在区块链1.0架构的基础上,加上智能合约,应用扩展到金融领域,解决跨境支付与结算、证券发行与交易、贸易金融等行业痛点,可以大幅减少人工核对工作,为金融机构节省成本,形成了区块链2.0。 在金融领域区块链的快速落地的同时,区块链发展到3.0时代,各种行业使用区块链技术去解决本行业的痛点,区块链去中心化、不可篡改和数据本地化存储的特性,给传统的架构方式带来了变革,最终改善人类互信的社会关系。 各类行业应用场景如下:
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2更换Tomcat为Jetty,小型站点的福音
- CentOS8安装Docker,最新的服务器搭配容器使用
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- 设置Eclipse缩进为4个空格,增强代码规范
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS8编译安装MySQL8.0.19
- SpringBoot2整合Redis,开启缓存,提高访问速度
- SpringBoot2配置默认Tomcat设置,开启更多高级功能