Hystrix

吾尝终日而思矣,不如须臾之所学以。


豪猪
调用流程

相关实现:
继承HystrixCommand/HystrixObservableCommand并重写run()/construct(),执行对应的execute()/queue()/observe()/toObservable()方法,就算是用上这头猪。

客户端底层代码也必须要有超时设置,不能无限制的阻塞以致线程池一直饱和。
.withExecutionTimeoutInMilliseconds(5000)
  • 熔断器
开启熔断,10s内请求满足3个,且80%的都失败了,熔断。
熔断后每隔5秒,放进来一部分请求, 成功了就取消熔断。
.withCircuitBreakerEnabled(true)
.withCircuitBreakerRequestVolumeThreshold(3)
.withCircuitBreakerErrorThresholdPercentage(80)
.withCircuitBreakerSleepWindowInMilliseconds(5)
  • 线程池
3个线程,超过就降级。
.withCoreSize(3)
  • 信号量
开启信号量,并发超过3就降级。降级并发超过1,抛异常。
比起线程池,减少了线程开销,适用于缓存场景。
.withExecutionIsolationStrategy(ExecutionIsolationStrategy.SEMAPHORE)   
.withExecutionIsolationSemaphoreMaxConcurrentRequests(3)
.withFallbackIsolationSemaphoreMaxConcurrentRequests(1)
  • 降级
一般在run方法中出现受检异常就会走这个降级方法。我们也可以在run方法中,抛出非受检异常,就不会走降级方法了。
重写这个方法就实现了。可以在这里完成各种玩法,返回默认值,读redis,调用另外服务等。
@Override
protected String getFallback() {
    return "fallback: " + name;
}
  • 走缓存
HystrixRequestContext.initializeContext()
中间执行的,如果getCacheKey一样,会走缓存。
context.shutdown()
重写此方法,根据返回值判断是否走缓存。
@Override
    protected String getCacheKey() {
        return String.valueOf(value) + value1;
    }
  • 合并
 HystrixRequestContext.initializeContext()
中间执行的,运行间隔太短就会合并请求(还没搞明白。。)。
context.shutdown()
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 原文:https://my.oschina.net/7001/blog/1619842 摘要: Hystrix是N...
    laosijikaichele阅读 4,337评论 0 25
  • 前言 微服务架构以其轻量级、易扩展、稳定性高等特点,近几年受到了热烈的追捧,从互联网项目到企业级系统,都纷纷开始采...
    王勇1024阅读 706评论 0 1
  • 一、推荐阅读 可能有部分同学对 Hystrix 的特性了解的不是很清晰,推荐如下文章,写的真的好; 《【翻译】Hy...
    JiMingQiang阅读 1,252评论 0 7
  • hystrix是什么? 在微服务场景中,通常会有很多层的服务调用。如果一个底层服务出现问题,故障会被向上传播给用户...
    段永平阅读 431评论 0 0
  • 流程图 下图展示了当你使用 Hystrix 来包装你请求依赖服务时的流程: 接下来将详细介绍如下问题: 1.构建H...
    KingsChan阅读 6,077评论 0 21