`
公园美丽
  • 浏览: 12950 次
社区版块
存档分类
最新评论

SpringCloud 分布式微服务:熔断器Hystrix

 
阅读更多

1. 熔断器

服务雪崩

在正常的微服务架构体系下,一个业务很少有只需要调用一个服务就可以返回数据的情况,这种比较常见的是出现在demo中,一般都是存在调用链的,比如A->B->C->D,如果D在某一个瞬间出现问题,比如网络波动,io偏高,导致卡顿,随着时间的流逝,后续的流量继续请求,会造成D的压力上升,有可能引起宕机。

你以为这就是结束么,图样图森破,这才是噩梦的开始,在同一个调用链上的ABC三个服务都会随着D的宕机而引发宕机,这还不是结束,一个服务不可能只有一个接口,当它开始卡顿宕机时,会影响到其他调用链的正常调用,最终导致所有的服务瘫痪。

如下图所示:

 

SpringCloud系列教程 | 第四篇:熔断器Hystrix
 

 

熔断器

相信大家都知道家用电闸,原来老式的电闸是使用保险丝的(现在很多都是空气开关了),当家里用电量过大的时候,保险丝经常烧断,这么做是保护家里的用电器,防止过载。

熔断器的作用和这个很像,它可以实现快速失败,如果在一段时间内服务调用失败或者异常,会强制要求当前调用失败,不在走远程调用,走服务降级操作(返回固定数据或者其他一些降级操作)。从而防止应用程序不断地尝试执行可能会失败的操作,使得应用程序继续执行而不用等待修正错误,或者浪费CPU时间去等到长时间的超时产生。熔断器也可以自动诊断错误是否已经修正,如果已经修正,应用程序会再次尝试调用操作。

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

 

SpringCloud系列教程 | 第四篇:熔断器Hystrix
 

 

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

2. 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)来隔离资源。

3. Feign Hystrix

上一篇我们使用了producer和consumers,熔断器是只作用在服务调用端,因此上一篇使用到的consumers我们可以直接拿来使用。因为,Feign中已经依赖了Hystrix所以在maven配置上不用做任何改动。

1. 配置文件application.yml新增

server:
  port: 8081
spring:
  application:
    name: spring-cloud-consumers
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
feign:
  hystrix:
    enabled: trueCOPY

其中新增了feign.hystrix.enabled = true

2. 创建fallback类,继承与HelloRemote实现回调的方法

package com.springcloud.consumers.fallback;

import com.springcloud.consumers.remote.HelloRemote;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * Created with IntelliJ IDEA.
 *
 * @User: weishiyao
 * @Date: 2019/7/2
 * @Time: 23:14
 * @email: inwsy@hotmail.com
 * Description:
 */
@Component
public class HelloRemoteFallBack implements HelloRemote {
    @Override
    public String hello(@RequestParam(value = "name") String name) {
        return "hello " + name + ", i am fallback massage";
    }
}
COPY

3. 添加fallback属性

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

package com.springcloud.consumers.remote;

import com.springcloud.consumers.fallback.HelloRemoteFallBack;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * @Author: shiyao.wei
 * @Date: 2019/7/2 11:14
 * @Version: 1.0
 * @Desc:
 */
@FeignClient(name= "SPRING-CLOUD-PRODUCER", fallback = HelloRemoteFallBack.class)
public interface HelloRemote {
    @RequestMapping(value = "/hello")
    String hello(@RequestParam(value = "name") String name);
}COPY

所有改动结束。

4. 测试

现在我们测试看下结果,老规矩,顺次启动注册中心Eureka、provider、consumer

访问上一节我们访问过的链接:http://localhost:8081/hello/spring

现在可以看到页面正常显示:hello spring,producer is ready

现在我们手动把provider停掉,再访问一下链接看一下:

现在页面已经显示我们熔断后的信息了:hello spring, i am fallback massage

现在说明我们的测试已经成功了。(企业架构源码可以加求球:三五三六二四七二五九)

分享到:
评论

相关推荐

    SpringCloud分布式开发基础工程

    熔断器Hystrix是防止雪崩效应的重要工具。当服务因过载等原因无法正常响应时,Hystrix会进行熔断操作,避免下游服务因大量请求而崩溃。它提供了降级策略,当服务不可用时,可以返回默认值或者执行备选逻辑,保证系统...

    SpringCloud总结PDF1

    Spring Cloud则是基于Spring Boot实现的服务治理框架,提供了许多开箱即用的微服务解决方案,如服务发现、配置中心、熔断器等。 总的来说,Spring Cloud为开发者提供了构建微服务架构所需的全套工具,而Spring Boot...

    SpringCloud项目源码下载.docx

    5. **Hystrix**:熔断器,用来防止服务间的依赖导致的雪崩效应,实现服务之间的隔离和容错。 6. **Zuul**:API网关,作为所有请求的入口,负责路由转发和过滤。 7. **Sleuth**:用于收集服务间的调用链路数据,便于...

    微服务架构与SpringCloud.pptx

    文档中详细介绍了spring cloud的相关组件,包含了服务发现与注册 Eureka,服务消费 Ribbon 和 Reign,链路监控 Sleuth,断路器(熔断器)Hystrix,分布式配置中心 Config,消息总线 Bus,服务网关 Zuul,Spring Boot...

    springCloud 框架,整合feign,ribbon,熔断器

    SpringCloud 是一个基于 Spring Boot 实现的云应用开发工具,它为开发者提供了在分布式系统(如配置管理、服务发现、断路器、智能路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式会话、集群状态)...

    spring cloud 2.X

    Spring Cloud 2.x 是一套基于Spring Boot 2.x版本构建的微服务框架,它提供了全面的微服务解决方案,包括服务发现、配置管理、负载均衡、熔断器、路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式会话...

    SpringCloud入门学习demo

    SpringCloud是中国IT行业中备受关注的微服务框架,它基于Spring Boot进行快速构建,为开发者提供了在分布式系统(如配置管理、服务发现、断路器、智能路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式...

    springboot+springcloud.zip

    SpringBoot简化了Spring应用的初始搭建以及开发过程,而SpringCloud则是一套完整的微服务解决方案,它基于SpringBoot进行扩展,提供了服务发现、配置中心、负载均衡、熔断器等微服务治理功能。 SpringBoot的核心...

    SpringCloud基于SpringBoot 分布式服务实现.zip

    在SpringBoot的基础上,SpringCloud进一步提供了服务发现、负载均衡、熔断器、配置中心、API网关等一系列微服务基础设施。 1. **服务发现**:SpringCloud借助Eureka实现了服务注册与发现。每个服务启动后,会向...

    SpringCloud技术文档整理.pdf

    - **Hystrix**:提供熔断器功能,防止因服务故障导致的连锁效应,增强系统的容错性。 - **Ribbon**:客户端负载均衡器,使客户端能够选择合适的服务器进行请求。 - **Feign**:声明式服务调用接口,简化服务之间...

    SpringCloud.zip

    3. **Hystrix熔断器**:Hystrix是Netflix开发的容错管理工具,它旨在防止服务间的延迟和故障导致雪崩效应。Hystrix通过隔离服务调用、添加熔断机制、降级策略等,确保了系统的健壮性。当服务调用失败或超时时,...

    手把手教你搭建Sping cloud分布式架构(图文详细)

    Spring Cloud 是一个基于 Spring Boot 实现的云应用开发工具集,它为开发者提供了在分布式系统(如配置管理、服务发现、断路器、智能路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式会话、集群状态等...

    (完整版)基于SpringCloud微服务系统设计方案.pdf

    - **熔断器**:Hystrix提供超时和错误处理,防止服务雪崩。 - **配置管理**:SpringCloud Config实现统一配置管理。 - **监控**:Hystrix Dashboard和Turbine提供服务调用的监控和聚合视图,确保系统健康。 4. *...

    SpringCloud项目

    4. **熔断器Hystrix** Hystrix是Netflix的一个容错管理工具,它通过隔离请求、降级策略、超时控制等手段,防止服务雪崩,确保系统在部分组件故障时仍能正常运行。在"renren-security"项目中,Hystrix提供了对远程...

    springcloud面试题目

    以上只是 Spring Cloud 面试题目的冰山一角,实际面试中还会涵盖更多细节,如服务版本控制、服务间通信的优化、监控与日志、熔断器的策略调整等。深入理解这些核心组件及其工作原理,结合实际项目经验,将有助于在...

    SpringCloud.rar

    SpringCloud是中国IT行业中备受关注的分布式系统开发框架,它整合了Spring Boot、Spring Cloud Netflix、Spring Cloud Config等一系列组件,为构建微服务架构提供了强大的支持。SpringCloud的核心目标是简化分布式...

    day01-SpringCloud01

    3. Hystrix:熔断器 Hystrix是Netflix的一个延迟和容错库,用于隔离服务之间的调用,防止因某个服务故障导致整个系统的雪崩。它提供了断路器模式,当服务调用失败达到一定阈值时,断路器打开,后续请求直接返回错误...

    SpringCloud基础知识和相关组件介绍

    SpringCloud 是一个用于构建微服务开发和治理的框架集合,主要涉及的组件包括服务注册与发现、负载均衡、熔断器、服务网关、服务调用等。下面将详细介绍这些组件的知识点: 服务注册与发现: * Spring Cloud ...

    使用Spring-Cloud构建微服务.pptx

    * 断路器(Hystrix):提供熔断器模式,防止服务之间的级联故障。 * 智能路由(Zuul):提供路由和过滤的功能,允许开发者快速的构建安全、可扩展的API网关。 * 客户端负载均衡(Ribbon):提供负载均衡的功能,允许...

Global site tag (gtag.js) - Google Analytics