熔断Hystrix

Java-其他库 架构

TG架构笔记

1. 熔断
2. 隔离
3. 缓存

Hystrix执行逻辑

熔断器Circuit Breaker

熔断器执行逻辑

熔断器配置项清单

//开启熔断器
.withCircuitBreakerEnabled(true)
//熔断器强制打开
.withCircuitBreakerForceOpen(true)
//熔断器强制关闭
.withCircuitBreakerForceClosed(false)
//默认值20.意思是至少有20个请求才进行errorThresholdPercentage错误百分比计算。
// 比如一段时间（10s）内有19个请求全部失败了。错误百分比是100%，但熔断器不会打开，因为requestVolumeThreshold的值是20.
// 这个参数非常重要，熔断器是否打开首先要满足这个条件。
// 参考图实例【1】
.withCircuitBreakerRequestVolumeThreshold(20)
//设定错误百分比，默认值50%，例如一段时间（10s）内有100个请求，其中有55个超时或者异常返回了，
// 那么这段时间内的错误百分比是55%，大于了默认值50%，这种情况下触发熔断器-打开。
// 参考图实例【2】
.withCircuitBreakerErrorThresholdPercentage(50)
//半开试探休眠时间，默认值5000ms。当熔断器开启一段时间之后比如5000ms，会尝试放过去一部分流量进行试探，确定依赖服务是否恢复。
//如果试探请求成功，熔断器关闭；如果失败，熔断器再次打开，继续等待下一个休眠窗口过去后再重试
// 参考图实例【3】
.withCircuitBreakerSleepWindowInMilliseconds(5000)

隔离

参考博文：http://www.coolxuewang.com/view/4

命令、分组、线程池Key

命令commandKey：默认情况下，命令名称来源于类名。Hystrix默认以commandKey作为信号量隔离的依据

分组groupKey：Hystrix使用命令分组将一起的命令进行管理，比如报告、警报、仪表盘或组/库。默认情况下，Hystrix使用 HystrixCommandGroupKey来定义命令线程池，除非单独定义线程池。

通过设置命令组, Hystrix会根据组来组织和统计命令的告警、仪表盘等信息。那么为什么一定要设置命令组呢?因为除了根据组能实现统计之外, Hystrix命令默认的线程划分也是根据命令分组来实现的。默认情况下, Hystrix会让相同组名的命令使用同一个线程池, 所以我们需要在创建 Hystrix命令时为其指定命令组名来实现默认的线程池划分。
如果 Hystrix的线程池分配仅仅依靠命令组来划分,那么它就显得不够灵活了,所以Hystrix还提供了 Hystrixthreadpoolkey来对线程池进行设置,通过它我们可以实现更细粒度的线程池划分。

线程池threadKey：线程池key，如果在没有特别指定Hystrixthreadpoo1Key的情况下,依然会使用命令组的方式来划分线程池。通常情况下,尽量通过Hystrixthreadpoolkey的方式来指定线程池的划分,而不是通过组名的默认方式实现划分,因为多个不同的命令可能从业务逻辑上来看属于同一个组,但是往往从实现本身上需要跟其他命令进行隔离

隔离策略

1. 信号量
2. 线程池

信号量：

线程池

缓存

重要：Hystrix缓存只能用于同一线程同一请求的上下，且不同线程间缓存不共享。so，其实比较鸡肋，有部分情况下可能有用。

官方建议：HystrixRequestContext.initializeContext()初始化是在filter中进行，但是每一次初始化之前的缓存就失效了，所以要测缓存，就只能在controller中调用两次，才能看到缓存的结果是否相同，在同一用户请求的上下文中，相同依赖服务的返回数据始终保持一致。

Spring体系中@CacheResult注解使用

@Service
public class CustomerService {
    @Autowired
    private RestTemplate restTemplate;
    @CacheResult(cacheKeyMethod = "getKey")
    @HystrixCommand(
            fallbackMethod = "goFallback",
            groupKey = "customerGroup",
            commandKey = "getCustomer")
    public String getCustomer(@CacheKey("id") String id) {
        RibbonMessage msg = restTemplate.getForObject("http://TG-RIBBON-SERVICE/ribbonAccept?id=" + id, RibbonMessage.class);
        System.out.println(msg);
        return msg.toString();
    }
    /**
     * 注意，@CacheRemove必须配合@HystrixCommand使用才有效果
     * @param id
     * @return
     */
    @HystrixCommand
    @CacheRemove(commandKey = "getCustomer", cacheKeyMethod = "getKey")
    public String clearCache(@CacheKey("id") String id) {
        return id;
    }
    public String getKey(String id) {
        return id;
    }
    public String goFallback(String id) {
        return "error:" + id;
    }
}

Spring体系应用

@HystrixCommand(
        fallbackMethod = "goFallback",
        groupKey = "customerGroup",
        commandKey = "getCustomer", commandProperties = {
        //超时
        @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "200"),
        //开启请求缓存
        @HystrixProperty(name = "requestCache.enabled", value = "true"),
        //设置熔断
        @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),
        //断路器的最小请求数
        @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "1"),
        //休眠时间
        @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "200"),
        //断路频率
        @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60")
})
public String getCustomer(String id) {}

常用配置汇总

通过properties配置

监控
https://hot66hot.iteye.com/blog/2155036

隔离策略最好的解释
https://blog.csdn.net/heyutao007/article/details/51006694

spring @CacheResult缓存示例：
https://www.cnblogs.com/wanggangblog/p/8550218.html

有提及缓存的策略，但未确定正确性
http://www.cnblogs.com/hellxz/p/9056806.html