用户注册



邮箱:

密码:

用户登录


邮箱:

密码:
记住登录一个月忘记密码?

发表随想


还能输入:200字

初夏    -  云代码空间

——

springcloud(四):熔断器Hystrix

2018-11-27|342阅||

摘要:springcloud(四):熔断器Hystrix

说起springcloud熔断让我想起了去年股市中的熔断,多次痛的领悟,随意实施的熔断对整个系统的影响是灾难性的,好了接下来我们还是说正事。

熔断器

雪崩效应

在微服务架构中通常会有多个服务层调用,基础服务的故障可能会导致级联故障,进而造成整个系统不可用的情况,这种现象被称为服务雪崩效应。服务雪崩效应是一种因“服务提供者”的不可用导致“服务消费者”的不可用,并将不可用逐渐放大的过程。

如果下图所示:A作为服务提供者,B为A的服务消费者,C和D是B的服务消费者。A不可用引起了B的不可用,并将不可用像滚雪球一样放大到C和D时,雪崩效应就形成了。

熔断器(CircuitBreaker)

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

熔断器模式就像是那些容易导致错误的操作的一种代理。这种代理能够记录最近调用发生错误的次数,然后决定使用允许操作继续,或者立即返回错误。 熔断器开关相互转换的逻辑如下图:

熔断器就是保护服务高可用的最后一道防线。

Hystrix特性

1.断路器机制

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

2.Fallback

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

3.资源隔离

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

Feign Hystrix

因为熔断只是作用在服务调用这一端,因此我们根据上一篇的示例代码只需要改动spring-cloud-consumer项目相关代码就可以。因为,Feign中已经依赖了Hystrix所以在maven配置上不用做任何改动。

1、配置文件

application.properties添加这一条:

feign.hystrix.enabled=true

2、创建回调类

创建HelloRemoteHystrix类继承与HelloRemote实现回调的方法

@Component
public class HelloRemoteHystrix implements HelloRemote{

    @Override
    public String hello(@RequestParam(value = "name") String name) {
        return "hello" +name+", this messge send failed ";
    }
}

3、添加fallback属性

在HelloRemote类添加指定fallback类,在服务熔断的时候返回fallback类中的内容。

@FeignClient(name= "spring-cloud-producer",fallback = HelloRemoteHystrix.class)
public interface HelloRemote {

    @RequestMapping(value = "/hello")
    public String hello(@RequestParam(value = "name") String name);

}

改动点就这点,很简单吧。

整体代码结构如下:

 

更多详细源码参考来源

愿意了解框架技术或者源码的朋友直接求求交流分享技术:yuncode.net




顶 0踩 0收藏
文章评论
    发表评论

    个人资料

    • 昵称: 初夏
    • 等级: 中级设计师
    • 积分: 4450
    • 代码: 0 个
    • 文章: 199 篇
    • 随想: 0 条
    • 访问: 4 次
    • 关注

    人气代码

      标签

      java(56)api(3)教程(24)Spring(30)cache(4)+(2)springmvc(5)mybatis(31)(六)(1)(七)(1)Coud--鸿鹄Cl(1)Cloud--鸿鹄C(1)鸿鹄Cloud分布式(1)鸿鹄Cloud分布式(1)鸿鹄Cloud分布式(1)鸿鹄(1)Cloud(23)分布式微服务云系统-(1)SpringClou(1)Cloud--鸿鹄C(1)企业分布式微服务云架(1)Boot(6)源码(7)-(9)项目构建过程(2)整合spring(1)cloud云服务架构(4)登出流程(3)(1)Consul(1)Commons(1)普通抽象(1)云架构代码结构构建(1)Config服务器(1)SpringBoot(83)mybatis分布式(1)企业分布式微服务云架(1)springclou(1)Config-快速开(1)RestTempla(1)Cloud大型互联网(1)企业级(25)(一)(1)(三)(3)cloud项目(1)(五)(1)(六)整合sprin(1)企业云架构commo(1)(七)整合sprin(1)common-ser(1)(八)整合sprin(1)commonserv(1)电子商务云平台b2b(1)b2c(1)o2o(1)Cloud简介(1)springclou(1)springclou(1)springclou(1)springclou(1)关于SpringCl(1)B2B2C(47)Springboot(1)Springclou(1)mybatis电子商(1)(九)Java(2)springclou(1)o2o多用户商城(16)springclou(1)(十)Java(1)springclou(1)SSO单点登录之OA(1)(十一)Java(1)springclou(1)SSO单点登录之OA(1)(十二)(1)springclou(1)(十三)java(2)b2b2c多用户商城(7)(十四)Java(1)(十五)Java(1)(十六)Java(1)b2b2c多用户商城(1)SSO单点登录之OA(1)springclou(1)springclou(1)springclou(1)springclou(1)springclou(1)springclou(1)java版(1)项目构建过程(七)(3)Cloud构建微服务(1)springclou(1)ssm(14)b2b2c多用户商城(1)springclou(1)b2b2c多用户商城(1)springclou(1)b2b2c多用户商城(1)企业级java(8)shop(9)(十二)java(1)(十一)JAVA(1)多用户商城系统源码((1)多用户商城系统源码((1)b2bc商城系统开源(1)b2b2c多用户商城(1)多用户商城系统(3)(十)用spring(3)springclou(1)springboot(1)b2b2c多用户商城(1)springboot(1)B2B2C多用户电子(1)(二)Spring(3)Boot配置文件详解(1)整合JPA(2)Dashboard)(1)Turbine)(1)o2o电子商务云商平(1)多级分销Spring(1)o2o分布式(1)b2bc商城系统开源(1)Cloud集成项目简(1)(一)spring(1)cloud微服务分布(1)Cloud简介((1)springclou(1)企业云架构commo(1)springclou(1)common-ser(1)(二)java(1)mybatis多租户(1)Initializr(1)(五)企业级java(1)springclou(1)b2bc商城系统开源(1)Dashboard和(1)springclou(1)b2b2c多用户商城(1)(十四)企业级jav(1)springclou(1)b2bc商城系统开源(1)(四)JAVA(1)springclou(1)b2b2c多用户商城(1)b2bc商城系统开源(1)多用户商城系统源码-(1)多用户商城系统-do(1)springboot(1)(六)(1)(四)java(1)多用户商城系统源码:(1)多级分销Spring(1)(九)Java(1)springclou(1)(十)企业级java(1)b2bc商城系统开源(1)SSO单点登录之OA(1)微服务多用户商城系统(1)springboot(1)多用户商城系统源码:(1)微服务java_b2(1)多用户商城系统:分布(1)SpringClou(1)SpringClou(1)多级分销Spring(1)o2o多用户商城-服(1)多级分销Spring(1)springclou(1)b2b2c多用户商城(1)springclou(1)b2bc商城系统开源(1)Cloud构建微服务(1)springclou(1)多用户商城系统源码:(1)springboot(1)springclou(1)b2bc商城系统开源(1)(六)分布式配置中心(1)b2b2c多用户商城(1)(八)消息总线(Sp(1)springboot(1)多用户商城系统源码((1)(十二)断路器监控((1)多级分销spring(1)mybatis多租户(1)springboot(1)企业云架构commo(1)springclou(1)common-ser(1)springclou(1)springclou(1)(十)Java多用户(1)b2b2c多用户商城(1)springboot(1)SSO单点登录之OA(1)mybatis电子商(1)springclou(1)mybatis电子商(1)mybatis电子商(1)springboot(1)springboot(1)springclou(1)springclou(1)springclou(1)b2b2c多用户商城(1)springclou(1)b2bc商城系统开源(1)分布式配置中心(Sp(1)springclou(1)b2b2c多用户商城(1)b2bc商城系统开源(1)多用户商城系统源码:(1)springclou(1)springclou(1)springclou(1)多用户商城系统源码:(1)b2bc商城系统开源(1)(十三)spring(1)springboot(1)springclou(1)b2b2c多用户商城(1)多级分销Spring(1)整合企业架构的技术点(1)SpringClou(1)Cloud集成项目简(1)多级分销spring(1)mybatis多租户(1)springclou(1)企业云架构commo(1)springclou(1)common-ser(1)企业分布式微服务云S(1)(一)服务的注册与发(1)企业分布式微服务云S(1)(二)服务消费者(r(1)企业分布式微服务云S(1)服务消费者(Feig(1)企业分布式微服务云S(1)(四)断路器(Hys(1)企业分布式微服务云S(1)(五)路由网关(zu(1)企业分布式微服务云S(1)(六)分布式配置中心(1)企业分布式微服务云S(1)(八)消息总线(Sp(1)企业分布式微服务云S(1)(九)服务链路追踪((1)企业分布式微服务云S(1)(十)高可用的服务注(1)企业分布式微服务云S(1)(一)服务的注册与发(1)企业分布式微服务云S(1)(二)服务消费者(r(1)企业分布式微服务云S(1)服务消费者(Feig(1)企业分布式微服务云S(1)(四)断路器(Hys(1)企业分布式微服务云S(1)(五)路由网关(zu(1)企业分布式微服务云S(1)(六)分布式配置中心(1)企业分布式微服务云S(1)(七)高可用的分布式(1)企业分布式微服务云S(1)(八)消息总线(Sp(1)企业分布式微服务云S(1)(九)服务链路追踪((1)企业分布式微服务云S(1)(十)高可用的服务注(1)企业分布式微服务云S(1)(十一)docker(1)(三)Spring(1)企业(3)Cloud微服务架构(1)Cloud云架构一定(1)(十六)用restT(1)教程(十五)Spri(1)(十四)在sprin(1)(十三)spring(1)企业级SpringB(1)企业级SpringB(1)Restdocs创建(1)企业SpringBo(1)教程(五)sprin(1)(一)构建第一个Sp(1)(四)SpringB(1)企业SpringBo(1)教程(五)sprin(1)教程(六)sprin(1)企业分布式微服务云S(1)(一)服务的注册与发(1)企业分布式微服务云S(1)(一)服务的注册与发(1)SpringBoot(1)(七)springb(1)(九)springb(1)企业级SpringB(1)Restdocs创建(1)企业级SpringB(1)(十三)spring(1)(十四)在sprin(1)教程(十五)Spri(1)(十六)用restT(1)(二十一)sprin(1)(二十二)创建含有多(1)(二十三)异步方法(1)(二十四)sprin(1)(二十五)sprin(1)Cloud构建微服务(1)Cloud构建微服务(1)Cloud构建微服务(1)Cloud构建微服务(1)Cloud构建微服务(1)Cloud构建微服务(1)SpringClou(1)服务的注册与发现(E(1)企业分布式微服务云S(1)(一)服务的注册与发(1)企业分布式微服务云S(1)(二)服务消费者(r(1)企业分布式微服务云S(1)服务消费者(Feig(1)企业分布式微服务云S(1)(四)断路器(Hys(1)企业分布式微服务云S(1)(五)路由网关(zu(1)企业分布式微服务云S(1)(六)分布式配置中心(1)企业分布式微服务云S(1)(七)高可用的分布式(1)企业分布式微服务云S(1)(八)消息总线(Sp(1)企业分布式微服务云S(1)(九)服务链路追踪((1)Restdocs创建(1)(十一)spring(1)(十二)spring(1)(十三)spring(1)(十四)在sprin(1)(十五)Spring(1)(十六)用restT(1)

      最新提问

        站长推荐