区块链技术博客
www.b2bchain.cn

八、Hystrix断路器(上)

这篇文章主要介绍了八、Hystrix断路器(上)的讲解,通过具体代码实例进行17607 讲解,并且分析了八、Hystrix断路器(上)的详细步骤与相关技巧,需要的朋友可以参考下https://www.b2bchain.cn/?p=17607

本文实例讲述了2、树莓派设置连接WiFi,开启VNC等等的讲解。分享给大家供大家参考文章查询地址https://www.b2bchain.cn/7039.html。具体如下:

文章目录

  • 1.Hystrix 理论知识
      • 分布式系统面临的问题:
      • 服务雪崩:
      • Hystrix 简介:
        • Hystrix 功能:
        • Hystrix重要概念:
  • 2.Hystrix 支付微服务构建
      • 新建 module cloud-provider-hystrix-payment8001
      • pom.xml
      • application.yml
      • 主启动类
      • 业务类
      • 测试
  • 3.降级容错解决的维度要求
  • 4.如何使用 Hystrix 服务降级
  • 针对Hystrix断路器(上)的补充
    • Hystrix重点补充

1.Hystrix 理论知识

官网资料:github

分布式系统面临的问题:

复杂分布式体系结构中的应用程序有数十个依赖关系,每个依赖关系在某个时候将不可避免的失败。
八、Hystrix断路器(上)

服务雪崩:

  1. 多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C又调用其他的微服务,这就是所谓的 “ 扇出 ” 。如果扇出的链路上某个微服务的调用响应时间过长或者不可用,对微服务A 的调用就会占用越来越多的系统资源,进而引起系统崩溃,所谓的 “ 雪崩效应 ”。
  2. 对于高流量的应用来说,单一的后端依赖可能会导致所有服务器上的所有资源都在几秒钟内饱和。比失败更糟糕的是,这些应用程序还可能导致服务之间的延迟增加,备份队列,线程和其他系统资源紧张,导致整个系统发生更多的级联故障。这些都表示需要对故障和延迟进行隔离和管理,以便单个依赖关系的失败,不能取消整个应用程序或系统。
  3. 所以,通常当你发现一个模块下的某个实例失败后,这时候这个模块依然还会接受流量,然后这个有问题的模块还调用了其他的模块,这样就会发生级联故障,或者叫 雪崩。
  4. 要避免这样的级联故障,就需要有一种链路中断的方案:
    服务降级、服务熔断

Hystrix 简介:

Hystrix是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统里,许多依赖不可避免的会调用失败,比如超时、异常等,Hystrix能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,已提高分布式系统的弹性。

“ 断路器 ” 本身是一种开关装置,当某个服务单元发送故障之后,通过断路器的故障监控(类似熔断保险丝),向调用方返回一个符合预期的、可处理的备选响应(FallBack),而不是长时间的等待或抛出调用方无法处理的异常,这样就保证了服务调用方的线程不会被长时间、不必要地占用,从而避免了故障在分布式系统中的蔓延,乃至雪崩。

Hystrix 官宣:停更进入维护阶段

八、Hystrix断路器(上)

但是它推荐使用 resilience4j 替代,但是国内用的比较少,后续会介绍 SpringCloud Alibaba Sentinel 实现熔断和断流。

Hystrix 功能:

  • 服务降级
    *服务熔断
  • 接近实时的监控
    *限流、隔离等

Hystrix重要概念:

1.服务降级:

服务器忙,请稍后再试,不让客户端等待并立刻返回一个友好提示,fallback
哪些情况会发出降级?

  • 程序运行异常
  • 超时
  • 服务熔断触发服务降级
  • 线程池 / 信号量打满也会导致服务降级

2.服务熔断

类似保险丝达到最大服务访问后,直接拒绝访问,拉闸限电,然后调用服务降级的方法并返回友好提示

3.服务限流

秒杀高并发等操作,严禁一窝蜂的过来拥挤,大家排队,一秒钟N个,有序进行

2.Hystrix 支付微服务构建

新建 module cloud-provider-hystrix-payment8001

八、Hystrix断路器(上)

pom.xml

    <dependencies>         <!--hystrix-->         <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>         </dependency>         <!--eureka client-->         <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>         </dependency> 

application.yml

server:   port: 8001  spring:   application:     name: cloud-provider-hystrix-payment  eureka:   client:     register-with-eureka: true     fetch-registry: true     service-url: 	  defaultZone: http://eureka7001.com:7001/eureka 

主启动类

package com.atguigu.springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; @SpringBootApplication @EnableEurekaClient public class PaymentHystrixMain8001 {     public static void main(String[] args) {         SpringApplication.run(PaymentHystrixMain8001.class,args);     } } 

业务类

 public class PaymentService {      public String paymentInfo_OK(Integer id){         return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_OK,id:"+id+"t"+"O(∩_∩)O哈哈~";     }      public String paymentInfo_Timeout(Integer id){         int timeNumber = 3;         try{             TimeUnit.SECONDS.sleep(timeNumber);         }catch (InterruptedException e){             e.printStackTrace();         }         return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_Timeout,id:"+id+"t"+"O(∩_∩)O哈哈~"+"   耗时(秒):"+timeNumber;     } }   @RestController @Slf4j public class PaymentController {     @Resource     private PaymentService paymentService;     @Value("${server.port}")     private String serverPort;      @GetMapping(value = "/payment/hystrix/ok/{id}")     public String paymentInfo_OK(@PathVariable("id") Integer id){         String result = paymentService.paymentInfo_OK(id);         log.info("*****result:"+result);         return result;     }      @GetMapping(value = "/payment/hystrix/timeout/{id}")     public String paymentInfo_TimeOut(@PathVariable("id") Integer id){         String result = paymentService.paymentInfo_Timeout(id);         log.info("*****result:"+result);         return result;     } } 

测试

启动7001,启动8001,测试

http://localhost:8001/payment/hystrix/ok/31

八、Hystrix断路器(上)

http://localhost:8001/payment/hystrix/timeout/31

八、Hystrix断路器(上)

OK是正常访问的,TimeOut 超过3秒才返回数据

3.降级容错解决的维度要求

  1. 超时导致服务器变慢 (转圈)
 超时不再等待 
  1. 出错(宕机或程序运行出错)
 出错要有兜底 
  1. 解决
 对方服务(8001)超时了,调用者(80)不能一直卡死等待,必须有服务降级   对方服务(8001)宕机了,调用者(80)不能一直卡死等待,必须有服务降级    对方服务(8001)OK,调用者(80)自己出故障或有自我要求(自己的等待时间小于服务提供者),自己处理降级 

4.如何使用 Hystrix 服务降级

设置自身调用超时时间的峰值,峰值内可以正常运行,超过了需要有兜底的方法处理,作服务降级fallback

服务降级 fallback 既可以放在服务端,也可以放在客户端,但是我们一般放在客户端,这里两种都演示一下。

(1) 服务提供者服务降级

//业务类启用 @HystrixCommand package com.atguigu.springcloud.service; import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand; import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty; import org.springframework.stereotype.Service; import java.util.concurrent.TimeUnit;  @Service public class PaymentService {     /**      * 正常访问      * @param id      * @return      */     public String paymentInfo_OK(Integer id){         return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_OK,id:"+id+"t"+"O(∩_∩)O哈哈~";     }      /**      * http://localhost:8001/payment/hystrix/timeout/31      * @HystrixCommand报异常后如何处理:      * 一旦调用服务方法失败并抛出了错误信息后,      * 会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法      *      * @param id      * @return      */     @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",commandProperties = {             //设置这个线程的超时时间是3s,3s内是正常的业务逻辑,超过3s调用fallbackMethod指定的方法进行处理             @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")     })     public String paymentInfo_Timeout(Integer id){         int timeNumber = 5;         //int age = 10/0;         try{             TimeUnit.SECONDS.sleep(timeNumber);         }catch (InterruptedException e){             e.printStackTrace();         }         return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_Timeout,id:"+id+"t"+"O(∩_∩)O哈哈~"+"   耗时(秒):"+timeNumber;     }      public String paymentInfo_TimeOutHandler(Integer id){         return "线程池:"+Thread.currentThread().getName()+"   系统繁忙,请稍后再试,id:"+id+"t"+"o(╥﹏╥)o";     } } //主启动类** @EnableCircuitBreaker package com.atguigu.springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker; import org.springframework.cloud.netflix.eureka.EnableEurekaClient;  @SpringBootApplication @EnableEurekaClient @EnableCircuitBreaker public class PaymentHystrixMain8001 {     public static void main(String[] args) {         SpringApplication.run(PaymentHystrixMain8001.class,args);     } } 

启动测试,没有报错,而是执行了fallbackMethod指定的方法

八、Hystrix断路器(上)

再来测试一下计算错误,也是会调用 fallbackMethod 指定的方法

八、Hystrix断路器(上)

八、Hystrix断路器(上)

总结:

八、Hystrix断路器(上)

如果我们故意制造两个异常:

  1. int age = 10/0; 运行时异常
  2. 我们能接受3秒钟,它运行5秒钟,超时异常。
    当前服务不可用了,做服务降级,兜底的方案都是paymentInfo_TimeOutHandler

(1) 消费者服务降级

#yml添加配置,开启 hystrix

 feign:  hystrix:    enabled: true  
//主启动 package com.atguigu.springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.hystrix.EnableHystrix; import org.springframework.cloud.openfeign.EnableFeignClients; @SpringBootApplication @EnableFeignClients @EnableHystrix public class OrderHystrixMain80 {     public static void main(String[] args) {         SpringApplication.run(OrderHystrixMain80.class,args);     } } //业务类 package com.atguigu.springcloud.controller; import com.atguigu.springcloud.service.PaymentHystrixService; import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand; import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource;  @RestController @Slf4j public class OrderHystrixController {     @Resource     private PaymentHystrixService paymentHystrixService;      @GetMapping("/consumer/payment/hystrix/ok/{id}")     public String paymentInfo_OK(@PathVariable("id") Integer id){         return paymentHystrixService.paymentInfo_OK(id);     }      @GetMapping("/consumer/payment/hystrix/timeout/{id}")     @HystrixCommand(fallbackMethod = "paymentTimeOutFallBackMethod",commandProperties = {             @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "1500")     })     public String paymentInfo_TimeOut(@PathVariable("id") Integer id){         return paymentHystrixService.paymentInfo_TimeOut(id);     }      public String paymentTimeOutFallBackMethod(@PathVariable("id") Integer id){         return "我是消费者80,对方支付系统繁忙,请稍后再试,o(╥﹏╥)o";     } } 

测试,超时异常:

八、Hystrix断路器(上)

运行时异常:

八、Hystrix断路器(上)

八、Hystrix断路器(上)

PS: 我们自己配置过的热部署方式对Java代码的改动明显,但对@HystrixCommand内属性的修改建议重启微服务。

问题1:

这样如果每个业务方法都对应一个兜底的方法,100个方法就有100个服务降级,会出现代码膨胀问题,我们需要一个统一的 fallbackMethod,统一的和自定义的分开。

解决问题:

@DefaultProperties(defaultFallback = "") 

1 : 1 每个方法配置一个服务降级方法,造成代码膨胀

1 : N 除了个别重要核心业务有专属,其他普通的可以通过@DefaultProperties(defaultFallback = “”) 统一跳转到统一处理结果页面

这样通用的和独享的各自分开,避免了代码膨胀,合理减少了代码量。

八、Hystrix断路器(上)

测试

八、Hystrix断路器(上)

问题2:

现在客户端与服务端关系紧紧耦合,客户端能跑是因为接口调用了微服务的业务逻辑方法,我们如果针对客户端接口做一些处理,把它调用的所有微服务方法进行降级,就可以解决耦合问题。

解决问题:

这个案例服务降级处理是在客户端80完成的,与服务端8001没有关系,只需要为 Feign 客户端定义的接口添加一个服务降级处理的实现类即可实现解耦。

package com.atguigu.springcloud.service; @Component public class PaymentFallbackService implements PaymentHystrixService {     @Override     public String paymentInfo_OK(Integer id) {         return "-----PaymentFallbackService fall back-paymentInfo_OK ,o(╥﹏╥)o";     }      @Override     public String paymentInfo_TimeOut(Integer id) {         return "-----PaymentFallbackService fall back-paymentInfo_TimeOut ,o(╥﹏╥)o";     } } 

接口使用@FeignClient(fallback = xxx.class)指定哪个类来处理异常

八、Hystrix断路器(上)

测试

先启动服务端8001,在启动客户端80,客户端正常调用微服务

八、Hystrix断路器(上)

现在关闭8001,客户端自己进行了降级,调用处理异常的方法

八、Hystrix断路器(上)

针对Hystrix断路器(上)的补充

Hystrix重点补充

  1. 在对8001进行服务降级的时候,@HystrixCommand里面用来兜底的fallbackMethod是用的一个单独的线程池,所以与主运行类的线程池起到了一定的隔离效果。

    fallback服务降级可以放在客户端也可以放在服务端,但是一般都是放在客户端。

  2. 问题2:

    现在客户端与服务端关系紧紧耦合,客户端能跑是因为接口调用了微服务的业务逻辑方法,我们如果针对客户端接口做一些处理,把它调用的所有微服务方法进行降级,就可以解决耦合问题。

    • 新设一个类 PaymentFallbackService来继承接口PaymentHystrixService的方法,在这个类中进行统一的调度和fallback降级处理。
  3. OrderHystirxController

八、Hystrix断路器(上)

  • 这里的resource注入的是什么??
  1. 这里的@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT")代表让这里接口的方法直接调用CLOUD-PROVIDER-HYSTRIX-PAYMENT中的方法。

八、Hystrix断路器(上)

  • 所以上面注入的paymentHystrixService是调用了8001中实现类的接口。
  • 可以这么理解,接口paymentHystrixService是有实现类的,实现类在8001中实现
  • 这里fallback服务降级中,如果CLOUD-PROVIDER-HYSTRIX-PAYMENT服务端宕机,就会选用PaymentFallbackService作为兜底,这里PaymentFallbackService同样也为接口paymentHystrixService的实现类。
  • 一句话总结,第3点中注入的接口paymentHystrixService的实现类,80中接口paymentHystrixService的实现类是由@FeignClient选择服务端8001中的实现类作为自己实现类,当存在异常时,会选择fallback中的80端口写的实现类作为自己实现类

本文转自互联网,侵权联系删除八、Hystrix断路器(上)

赞(0) 打赏
部分文章转自网络,侵权联系删除b2bchain区块链学习技术社区 » 八、Hystrix断路器(上)
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

b2b链

联系我们联系我们