SpringCloud05_Hystrix的概述案例详解服务降级服务熔断服务监控hystrixDashboard

Posted 2021-08-13 所得皆惊喜

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了SpringCloud05_Hystrix的概述案例详解服务降级服务熔断服务监控hystrixDashboard相关的知识，希望对你有一定的参考价值。

文章目录

①. 什么是Hystrix？
②. 模拟Hystrix-project8001
③. Jmeter压测测试
④. 消费者80工程搭建
⑤. 服务降级(cloud-provider-hystrix-payment8001)
⑥. 服务降级(cloud-consumer-feign-hystrix-order80)
⑦. Hystrix结合FeignClient解耦
⑧. 服务熔断是什么？
⑨. 服务熔断代码实现
⑩. 服务监控hystrixDashboard
- ①. hystrixDashboard工程9001搭建
- ②. 断路器演示(服务监控hystrixDashboard)

①. 什么是Hystrix？

①. Hystrix在英文里面的意思是豪猪,它的logo看下面的图是一头豪猪,它在微服务系统中是一款提供保护机制的组件,和eureka一样也是由netflix公司开发官网
②. 作用:Hystrix是一个延迟和容错库,用于隔离访问远程服务,防止出现级联失败
③. 服务降级:及时返回服务调用失败的结果,让线程不因为等待服务而阻塞
(程序运行异常、超时、服务熔断触发服务降级、线程池/信号量打满、服务器宕机也会导致服务降级)
④. 服务熔断:类比保险丝达到最大服务访问后,直接拒绝访问,拉闸限电,然后调用服务降级的方法并返回友好提示
⑤. 服务限流:秒杀高并发等操作,严禁一窝蜂的过来拥挤,大家排队,一秒钟N个,有序进行(这个到后期详解)

雪崩问题
微服务中,服务间调用关系错综复杂,一个请求,可能需要调用多个微服务接口才能实现,会形成非常复杂的调用链路:

②. 模拟Hystrix-project8001

①. 新建cloud-provider-hystrix-payment8001
②. pom.xml

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


        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>


        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

③. 主启动类

@SpringBootApplication
@EnableEurekaClient
public class PaymentHystrixMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentHystrixMain8001.class,args);
    }
}

④. service

@Service
public class PaymentService {
    //成功
    public String paymentInfo_OK(Integer id){
        return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_OK,id:  "+id+"\\t"+"哈哈哈"  ;
    }

    //失败
    public String paymentInfo_TimeOut(Integer id){
        try { TimeUnit.SECONDS.sleep(3); }catch (Exception e) {e.printStackTrace();}
        return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_TimeOut,id:  "+id+"\\t"+"呜呜呜"+" 耗时(秒)"+timeNumber;
    }
}

⑤. controller

@RestController
@Slf4j
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    @GetMapping("/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("/payment/hystrix/timeout/{id}")
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id){
        String result = paymentService.paymentInfo_TimeOut(id);
        log.info("*******result:"+result);
        return result;
    }
}

⑥. 测试:

在这里插入图片描述

③. Jmeter压测测试

①. 开启Jmeter,来20000个并发压死8001,20000个请求都去访问paymentInfo_TimeOut服务
②. 再来一个访问
http://localhost:8001/payment/hystrix/ok/31
http://localhost:8001/payment/hystrix/timeout/31
看演示结果:两个都在自己转圈圈
③. Jmeter压测结论
(tomcat的默认的工作线程数被打满了,没有多余的线程来分解压力和处理)
上面还是服务提供者8001自己测试,假如此时外部的消费者80也来访问,那消费者只能干等,最终导致消费端80不满意,服务端8001直接被拖死

④. 消费者80工程搭建

①. 新建cloud-consumer-feign-hystrix-order80
②. pom.xml

<dependencies>
        <!--新增hystrix-->
        <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

③. application.yml

server:
  port: 80
eureka:
  client:
    register-with-eureka: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka

④. 主启动类:

@SpringBootApplication
@EnableFeignClients
public class PaymentHystrixMain80 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentHystrixMain80.class,args);
    }
}

⑤. feign进行远程调用:

@Component
@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT")
public interface PaymentHystrixService {

    @GetMapping("/payment/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id);

    @GetMapping("/payment/hystrix/timeout/{id}")
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id);
}

⑥. 在controller中调用service去远程调用8001

@RestController
@Slf4j
//@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")
public class OrderHystrixController {
    @Resource
    private PaymentHystrixService paymentHystrixService;

    /*1>.OK*/
    @GetMapping("/consumer/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id){
        return paymentHystrixService.paymentInfo_OK(id);
    }

    /*2>.timeOut*/
    @GetMapping("/consumer/hystrix/timeout/{id}")
    /*@HystrixCommand(fallbackMethod = "paymentTimeOutFallbackMethod",commandProperties = {
            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
    })*/
    //@HystrixCommand
    //这里设置的时间是1.5s,就是说调用服务会等待1.5s,如果超过了就会走fallbackMethod方法
    //而我们在支付的微服务中,时间是3s
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id){
        return paymentHystrixService.paymentInfo_TimeOut(id);
    }

⑦. 正常测试
⑧. 高并发测试
2W个线程压8001
消费端80微服务再去访问正常的OK微服务8001地址
http://localhost/consumer/payment/hystrix/timeout/31
消费者80,有时候可以显示正常,有时候会显示错误页面

在这里插入图片描述

⑤. 服务降级(cloud-provider-hystrix-payment8001)

①. 在主启动类上添加注解:@EnableCircuitBreaker(开启服务降级)
②. 在service中添加服务降级的方法
(我们设置了3s之内是正常的,如果超过了3s就有兜底的方法)

  @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",commandProperties = {
            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="5000")
    })
    public String paymentInfo_TimeOut(Integer id){
        int timeNumber =3 ;
        //int age=10/0;
        try { TimeUnit.SECONDS.sleep(timeNumber); }catch (Exception e) {e.printStackTrace();}
        return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_TimeOut,id:  "+id+"\\t"+"呜呜呜"+" 耗时(秒)"+timeNumber;
    }

    public String paymentInfo_TimeOutHandler(Integer id){
        return "线程池:"+Thread.currentThread().getName()+"   paymentInfo_TimeOutHandler,id:  "+id+"\\t"+"O(∩_∩)O"  ;
    }

③. 一旦调用服务方法失败并抛出了错误信息后,会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法

在这里插入图片描述

⑥. 服务降级(cloud-consumer-feign-hystrix-order80)

①. 80订单微服务,也可以更好的保护自己,自己也依样画葫芦进行客户端降级保护
(我们自己配置过的热部署方式对java代码的改动明显,但对@HystrixCommand内属性的修改建议重启微服务)
②. yaml

feign:
  hystrix:
    enabled: true #如果处理自身的容错就开启。开启方式与生产端不一样。

③. 主启动类上添加 @EnableHystrix
④. 在controller中添加如下方法进行兜底处理

 @GetMapping("/consumer/hystrix/timeout/{id}")
 @HystrixCommand(fallbackMethod = "paymentTimeOutFallbackMethod",commandProperties = {
         @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
 })
 //@HystrixCommand
 //这里设置的时间是1.5s,就是说调用服务会等待1.5s,如果超过了就会走fallbackMethod方法
 //而我们在支付的微服务中,时间是3s
 public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
     return paymentHystrixService.paymentInfo_TimeOut(id);
 }

 public String paymentTimeOutFallbackMethod(@PathVariable Integer id) {
     return "我是消费者80,对方支付系统繁忙请10分钟后再试或者自己运行出错请检查自己！";
 }

⑤. 我们在8001端进行了3s的延迟处理,这里80端去调用8001端的时候,如果超过了1.5s就会走兜底的方法
⑦. 目前的问题
每个业务方法对应一个兜底的方法,代码膨胀
统一和自定义的分开
⑧. 解决办法在controller类中添加上@DefaultProperties(defaultFallback=" “)
每个方法配置一个服务降级方法,技术上可以,实际上不合理
除了个别重要核心业务有专属,其他普通的可以通过@DefaultProperties(defaultFallback=”")统一跳转

在这里插入图片描述

@RestController
@Slf4j
@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")
public class OrderHystrixController {
    @Resource
    private PaymentHystrixService paymentHystrixService;

    /*1>.OK*/
    @GetMapping("/consumer/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id) {
        return paymentHystrixService.paymentInfo_OK(id);
    }

    /*2>.timeOut*/
    @GetMapping("/consumer/hystrix/timeout/{id}")
//    @HystrixCommand(fallbackMethod = "paymentTimeOutFallbackMethod",commandProperties = {
//            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
//    })
    @HystrixCommand //
    //这里设置的时间是1.5s,就是说调用服务会等待1.5s,如果超过了就会走fallbackMethod方法
    //而我们在支付的微服务中,时间是3s
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
        return paymentHystrixService.paymentInfo_TimeOut(id);
    }

    public String paymentTimeOutFallbackMethod(@PathVariable Integer id) {
        return "我是消费者80,对方支付系统繁忙请10分钟后再试或者自己运行出错请检查自己！";
    }

    //globol fallback

    //下面是全局fallback方法
    public String payment_Global_FallbackMethod() {
        return "Global异常处理信息,请稍后再试！！";
    }
}

在这里插入图片描述

⑦. Hystrix结合FeignClient解耦

①. 问题引入:
②. 未来我们要面对的异常(运行时异常、超时、服务器宕机)
③. 修改cloud-consumer-feign-hystrix-order80
(根据cloud-consumer-feign-hystrix-order80已经有的PaymentHystrixService接口,重新新建一个类(PaymentFallbackService)实现该接口,统一为接口里面的方法进行异常处理)

@Component
@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT",fallback = PaymentFallbackService.class)
public interface PaymentHystrixService {

    @GetMapping("/payment/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id);

    @GetMapping("/payment/hystrix/timeout/{id}")
    public String 以上是关于SpringCloud05_Hystrix的概述案例详解服务降级服务熔断服务监控hystrixDashboard的主要内容，如果未能解决你的问题，请参考以下文章 
 SpringCloud-2.0：（10. 服务降级 - Hystrix - 引出问题）
 SpringCloud05-Hystrix（服务熔断等）
 SpringCloud  --- 服务降级 ( Hystrix熔断器 )
 SpringCloud  --- 服务降级 ( Hystrix熔断器 )
 SpringCloud- 第六篇 Hystrix参数配置
 SpringCloud——Eureka Feign Ribbon Hystrix Zuul等关键组件的学习与记录