SpringCloud-Hystrix

Hystrix 是什么?

  在微服务架构中,我们是将一个单体应用拆分成多个服务单元,各个服务单元之 间通过注册中心彼此发现和消费对方提供的服务,每个服务单元都是单独部署, 在各自的服务进程中运行,服务之间通过远程调用实现信息交互,那么当某个服务的响应太慢或者故障,又或者因为网络波动或故障,则会造成调用者延迟或调 用失败,当大量请求到达,则会造成请求的堆积,导致调用者的线程挂起,从而 引发调用者也无法响应,调用者也发生故障。 比如电商中的用户下订单,我们有两个服务,一个下订单服务,一个减库存服务, 当用户下订单时调用下订单服务,然后下订单服务又调用减库存服务,如果减库 存服务响应延迟或者没有响应,则会造成下订单服务的线程挂起等待,如果大量 的用户请求下订单,或导致大量的请求堆积,引起下订单服务也不可用,如果还 有另外一个服务依赖于订单服务,比如用户服务,它需要查询用户订单,那么用 户服务查询订单也会引起大量的延迟和请求堆积,导致用户服务也不可用。 所以在微服务架构中,很容易造成服务故障的蔓延,引发整个微服务系统瘫痪不 可用。 为了解决此问题,微服务架构中引入了一种叫熔断器的服务保护机制。
 
熔断器也有叫断路器,他们表示同一个意思,最早来源于微服务之父 Martin Fowler的论文CircuitBreaker一文。“熔断器”本身是一种开关装置,用于在 电路上保护线路过载,当线路中有电器发生短路时,能够及时切断故障电路,防 止发生过载、发热甚至起火等严重后果。 微服务架构中的熔断器,就是当被调用方没有响应,调用方直接返回一个错误响 应即可,而不是长时间的等待,这样避免调用时因为等待而线程一直得不到释放, 避免故障在分布式系统间蔓延;
 
Spring Cloud Hystrix实现了熔断器、线程隔离等一系列服务保护功能。该功能 也是基于 Netflix 的开源框架 Hystrix 实现的,该框架的目标在于通过控制那些 访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能 力。Hystrix 具备服务降级、服务熔断、线程和信号隔离、请求缓存、请求合并 以及服务监控等强大功能。

  一.导入依赖

  

1       <dependency>
2             <groupId>org.springframework.cloud</groupId>
3             <artifactId>spring-cloud-starter-hystrix</artifactId>
4             <version>1.4.6.RELEASE</version>
5         </dependency>

  二.编写配置参考提供者配置  改个id就可以了

   三.开启功能,启动类

1 @EnableCircuitBreaker //添加对熔断的支持

  四.在方法上添加注解

1 @HystrixCommand(fallbackMethod = "hystrixGet") //这个注解下的方法失败了,就会去调用hystrixGet备案方法

  扩展:鼠标放在UP后面的项目上,左下角显示 

  

  总结:Hystrix服务熔断就是,当消费者访问提供者,访问某些内容访问不到,不会报500异常,而是返回hystrix设置的备份。

   

    熔断在服务端,降级在客户端

    服务熔断: 服务端~ 某个服务超时或者异常,引起熔断~

    服务降级: 客户端~ 从整体网站请求负载考虑,当某个服务熔断或者关闭之后,服务将不再被调用,此时在客户端,我们准备一个FallbackFactory,返回一个默认的值(缺省的),整体的服务水平下降了,但是好歹能用~比直接挂掉强。

              

Hystrix:服务降级

  手写一个类继承FallbackFactory,从写里面的方法,假设当服务器关闭之后,用户来访问不会报异常而是告诉用户不能用。

  我们这里用的是Feign负载均衡,所有要设置被扫描的类

   •在客户端开启降级

  

#开启降级
feign:
  hystrix:
    enabled: true

  

   •测试,当服务关闭,用户访问,返回的结果不是异常而是自己手写返回的信息。

Hystrix:Dashboard流监控

  提示:创建一个新项目专门用来监控

  •消费者客户端添加依赖

    <!--Hystrix依赖~-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>

  保证提供者有监控依赖

  

  <!--actuator完善监控信息-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

  •编写配置

  

server:
  port: 9001
eureka:
  client:
    register-with-eureka: false

  •开启功能

  

@EnableHystrixDashboard//开启

  •监控某个提供者服务端需要导入依赖

  

 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>

  •在提供者服务端启动类中编写Bean配置

  

   
//增加一个Servlet
@Bean
public ServletRegistrationBean hystrixMetricsStreamServlet(){
ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
registrationBean.addUrlMappings("/actuator/hystrix.stream");
return registrationBean;
}

  •这些前提下必须保证是有熔断的提供者,也就是添加了熔断支持,配置了熔断命令,并且必须提前访问一个服务,才能监控。

  测试

  

  访问某些请求

  

  实施监控

  

    

    监控图

    

原文地址:https://www.cnblogs.com/Spring-M/p/12781681.html