• 简单的Hystrix熔断


    SpringCloud进行接口调用的时候,会经过以下几步:

    Feign --->Hystrix ---Ribbon --->Http Client

    (1)接口化请求调用当调用被@FeignClient注解修饰的接口时,在框架内部,将请求转换成Feign的请求实例feign.Request,交由Feign框架处理。

    (2)Feign :转化请求Feign是一个http请求调用的轻量级框架,可以以Java接口注解的方式调用Http请求,封装了Http调用流程。

    (3)Hystrix:熔断处理机制 Feign的调用关系,会被Hystrix代理拦截,对每一个Feign调用请求,Hystrix都会将其包装成HystrixCommand,参与Hystrix的流控和熔断规则。如果请求判断需要熔断,则Hystrix直接熔断,抛出异常或者使用FallbackFactory返回熔断Fallback结果;如果通过,则将调用请求传递给Ribbon组件。

    (4)Ribbon:服务地址选择 当请求传递到Ribbon之后,Ribbon会根据自身维护的服务列表,根据服务的服务质量,如平均响应时间,Load等,结合特定的规则,从列表中挑选合适的服务实例,选择好机器之后,然后将机器实例的信息请求传递给Http Client客户端,HttpClient客户端来执行真正的Http接口调用;

    (5)HttpClient :Http客户端,真正执行Http调用根据上层Ribbon传递过来的请求,已经指定了服务地址,则HttpClient开始执行真正的Http请求

    Hystrix:

    Hystrix 是一个供分布式系统使用,提供延迟和容错功能,保证复杂的分布系统在面临不可避免的失败时,仍能有其弹性。

    比如系统中有很多服务,当某些服务不稳定的时候,使用这些服务的用户线程将会阻塞,如果没有隔离机制,系统随时就有可能会挂掉,从而带来很大的风险。SpringCloud使用Hystrix组件提供断路器、资源隔离与自我修复功能。

    应用场景:

    比如我有一个教学服务,平时教学视频是存在阿里云上的。现在需要删除课程,就需要删除视频。课程服务和视频服务是不同的模块。

    课程服务引入以下依赖:

    1. <dependency>
    2. <groupId>org.springframework.cloud</groupId>
    3. <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    4. </dependency>
    5. <!--hystrix依赖,主要是用 @HystrixCommand -->
    6. <dependency>
    7. <groupId>org.springframework.cloud</groupId>
    8. <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    9. </dependency>
    10. <!--服务注册-->
    11. <dependency>
    12. <groupId>org.springframework.cloud</groupId>
    13. <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    14. </dependency>
    15. <!--服务调用-->
    16. <dependency>
    17. <groupId>org.springframework.cloud</groupId>
    18. <artifactId>spring-cloud-starter-openfeign</artifactId>
    19. </dependency>

    配置文件中加入:

    1. #开启熔断机制
    2. feign.hystrix.enabled=true
    3. # 设置hystrix超时时间,默认1000ms
    4. hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=6000

    加入熔断器的实现类:

    1. @Component
    2. public class VodFileDegradeFeignClient implements VodClient {
    3. @Override
    4. public R removeVideo(String videoId) {
    5. return R.error().message("time out");
    6. }
    7. @Override
    8. public R removeVideoList(List videoIdList) {
    9. return R.error().message("time out");
    10. }
    11. }

    feign接口:

    1. @FeignClient(name = "service-vod", fallback = VodFileDegradeFeignClient.class)
    2. @Component
    3. public interface VodClient {
    4. @DeleteMapping(value = "/eduvod/vod/{videoId}")
    5. public R removeVideo(@PathVariable("videoId") String videoId);
    6. @DeleteMapping(value = "/eduvod/vod/delete-batch")
    7. public R removeVideoList(@RequestParam("videoIdList") List videoIdList);
    8. }

    可以看到,注解中加入了个fallback,指向了实现类,一旦视频服务异常,就会转调这个类里的内容

  • 相关阅读:
    要单片机执行一个程序,必须把程序按顺序预先装入ROM的某个区域
    基于java的购物中心商铺管理系统的设计与实现/商铺管理系统
    关于单片机CPU如何控制相关引脚
    基于SpringBoot的音乐网站
    教你自己制作一个ALU
    Oracle数据库经纬度坐标查询优化与结果错误原因分析、SQL中WKT超长文本字符串处理
    对中纠偏系统比例伺服阀放大器
    在OCP集群中安装NSX ALB AKO
    golang_iota
    自学Python 61 使用select模块实现多路I/O复用
  • 原文地址:https://blog.csdn.net/xushuai2333333/article/details/128060187