本文共 3794 字,大约阅读时间需要 12 分钟。
github地址:
在微服务架构中,我们将系统拆分为很多个服务,各个服务之间通过注册与订阅的方式相互依赖,由于各个服务都是在各自的进程中运行,就有可能由于网络原因或者服务自身的问题导致调用故障或延迟,随着服务的积压,可能会导致服务崩溃。为了解决这一系列的问题,断路器等一系列服务保护机制出现了。
断路器本身是一种开关保护机制,类似于保险丝,用于在电路上保护线路过载,当线路中有电器发生短路时,断路器能够及时切断故障电路,防止发生过载、发热甚至起火等严重后果。
在分布式架构中,断路器模式的作用也是类似的。 针对上述问题,Spring Cloud Hystrix 实现了断路器、线路隔离等一系列服务保护功能。它也是基于 Netflix 的开源框架 Hystrix 实现的,该框架的目标在于通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。Hystrix 具备服务降级、服务熔断、线程和信号隔离、请求缓存、请求合并以及服务监控等强大功能。官方完整文档,操作详细信息和其他信息: API文档:在上一篇文章Ribbon
(消费者)的基础下测试 访问 关闭掉8082的实例,再刷新服务的时候可以看到
端口为8082服务挂掉了并显示出错误信息 这样的显示对于用户来说是十分不好的,这样就需要引入断路器
本次是在上一篇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 "服务中断连接,请联系管理员"; }}
配置文件可以不用改(有需要设置参数的可以参考文章下方的推荐文章)
Eureka
服务端 端口号是9090 两个Eureka
客户端 端口号分别是8081和8082 相同的服务名springcloud-eureka-client
Ribbon
消费者客户端 端口号是9999
先启动服务端再启动客户端,客户端启动顺序没要求 启动完后我们访问 关闭掉8082的实例,再刷新服务的时候可以看到
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
如果不写的话是监控不了的
完成上述配置后,访问可以看到小熊界面说明配置成功
stream
和title
,点击Monitor Stream
,便会出现图形化的监控页面。 一般只需要填入监控地址就可以了,例如需要监控端口号为9999的服务 就填入 Monitor Stream
,进去都看到Loading...
,因为端口9999的服务还没调用 推荐文章: 关于Hystrix和Hystrix-Dashboard各种配置参数可以参考: 关于hystrix-metrics-event-stream源码解析的可以参考
转载地址:http://kzisa.baihongyu.com/