Hiki

Spring Cloud学习记录：熔断器 Hystrix

2019/06/19

熔断器 Hystrix

熔断器（CircuitBreaker）

熔断器如同电力过载保护器，保护服务高可用。在一段时间内侦测到许多类似的错误，会强迫其以后的多个调用快速失败，不再访问远程服务器，从而防止应用程序不断地尝试执行可能会失败的操作，使得应用程序继续执行而不用等待修正错误，或者浪费CPU时间去等到长时间的超时产生。熔断器也可以使应用程序能够诊断错误是否已经修正，如果已经修正，应用程序会再次尝试调用操作。

熔断器模式就像是那些容易导致错误的操作的一种代理。这种代理能够记录最近调用发生错误的次数，然后决定使用允许操作继续，或者立即返回错误。

Hystrix

熔断机制

  • Hystrix Command请求后端服务失败数量超过一定比例(默认50%), 断路器会切换到开路状态(Open)。 这时所有请求会直接失败而不会发送到后端服务。
  • 断路器保持在开路状态一段时间后(默认5秒), 自动切换到半开路状态(HALF-OPEN)。 这时会判断下一次请求的返回情况,。
  • 如果请求成功, 断路器切回闭路状态(CLOSED)， 否则重新切换到开路状态(OPEN)。
  • 一旦后端服务不可用, 断路器会直接切断请求链, 避免发送大量无效请求影响系统吞吐量, 并且断路器有自我检测并恢复的能力。

Fallback

Fallback相当于是降级操作。对于查询操作, 我们可以实现一个fallback方法, 当请求后端服务出现异常的时候, 可以使用fallback方法返回的值。 fallback方法的返回值一般是设置的默认值或者来自缓存。

资源隔离

  • 在Hystrix中, 主要通过线程池来实现资源隔离。
  • 使用的时候我们会根据调用的远程服务划分出多个线程池。 例如调用产品服务的Command放入A线程池, 调用账户服务的Command放入B线程池。 这样做的主要优点是运行环境被隔离开了。
  • 就算调用服务的代码存在bug或者由于其他原因导致自己所在线程池被耗尽时, 不会对系统的其他服务造成影响。
  • 但是带来的代价就是维护多个线程池会对系统带来额外的性能开销。
  • 如果是对性能有严格要求而且确信自己调用服务的客户端代码不会出问题的话, 可以使用Hystrix的信号模式(Semaphores)来隔离资源.

Feign Hystrix

主要实现是在服务调用方。下面例子用之前在《Eureka 服务调用》 文章中使用的服务调用方。

主要依赖

和服务调用方使用的依赖一致。

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

配置文件

原：

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/,http://localhost:8762/eureka/

spring:
  application:
    name: consumer
    
server:
  port: 9001

多添加：

feign:
  hystrix:
    enabled: true

新建回调类

/**
 * @author ：hiki
 * 2019/6/19 17:44
 */
@Component
public class HelloHystrix implements HelloFeign {
    @Override
    public String hello(@RequestParam(value = "name") String name) {
        return "Hi," + name + ".Sorry,this server is failed";
    }
}

添加fallback属性

只需在@FeignClient注解中添加fallback属性即可。

/**
 * @author ：hiki
 * 2019/6/19 15:31
 */
@FeignClient(name= "client",fallback = HelloHystrix.class)
public interface HelloFeign {
    @RequestMapping("/hello")
    public String hello(@RequestParam String name);
}

测试

  • 启动注册中心、服务提供方、服务调用方
  • 测试这个接口
  • 关掉服务提供方
  • 测试接口

如果成功返回熔断后的信息，则恭喜你！





github: https://github.com/Hikiy
作者：Hiki
创建日期：2019.06.19
更新日期：2019.06.19

（转载本站文章请注明作者和出处 Hiki）

Post Directory