代码下载

地址:https://github.com/13thm/study_springcloud/tree/main/days8_Hystrix

简介

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

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

Hystrix重要概念:

服务降级:服务器忙，请稍后再试，不让客户端等待并立刻返回一个友好提示，fallback
服务熔断:类比保险丝达到最大服务访问后，直接拒绝访问，拉闸限电，然后调用服务降级的方法并返回友好提示
服务限流:秒杀高并发等操作，严禁一窝蜂的过来拥挤，大家排队，一秒钟N个，有序进行

写服务

1. 新建cloud-provider-hystrix-payment8001
2. 写POM
3. 写YML
4. 写业务类,service,controller
   

测试

启动eureka7001 和 启动cloud-provider-hystrix-payment8001

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

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

高并发测试

Jmeter压测测试

1. 新建线程组
   
2. 设置频率
   
3. 保存
   然后点击http请求
   
4. 设置
   

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

5. 运行
   
6. 结果
   结果发现http://localhost:8001/payment/hystrix/ok/1 这个也需要反应时间了

写消费者端

1. cloud-consumer-feign-hystrix-order80
2. 写POM
3. 写YML
4. 写业务类,service,controller
   

测试2

http://localhost/consumer/payment/hystrix/ok/3

把之前的Jmeter压测测试打开.然后再运行会出现等待的情况.

服务降级

先修改cloud-provider-hystrix-payment8001

降级配置@HystrixCommand
8001先从自身找问题,设置自身调用超时时间的峰值，峰值内可以正常运行，超过了需要有兜底的方法处理，作服务降级fallback

1.业务类启用,修改8001的service
2. 主启动类激活 @EnableCircuitBreaker

具体看下载代码

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

修改cloud-consumer-feign-hystrix-order80

80订单微服务，也可以更好的保护自己，自己也依样画葫芦进行客户端降级保护

1. 改YML
2. 改主启动
3. 改业务类

启动服务测试

http://localhost/consumer/payment/hystrix/timeout/2

目前问题

每个业务方法对应一个兜底的方法，代码膨胀

统一和自定义的分开
修改cloud-consumer-feign-hystrix-order80的 controller

package org.example.controller;


import com.netflix.hystrix.contrib.javanica.annotation.DefaultProperties;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import lombok.extern.slf4j.Slf4j;
import org.example.service.PaymentHystrixService;
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
@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod",commandProperties = {
        @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
        })
public class PaymentHystirxController
{
    @Resource
    private PaymentHystrixService paymentHystrixService;
    //    @HystrixCommand(fallbackMethod = "paymentTimeOutFallbackMethod",commandProperties = {
//            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
//    })
    @HystrixCommand //加了@DefaultProperties属性注解，并且没有写具体方法名字，就用统一全局的
    @GetMapping("/consumer/payment/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id)
    {
        String result = paymentHystrixService.paymentInfo_OK(id);
        return result;
    }

//    @GetMapping("/consumer/payment/hystrix/timeout/{id}")
//    @HystrixCommand(fallbackMethod = "paymentTimeOutFallbackMethod",commandProperties = {
//            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
//    })
    @HystrixCommand //加了@DefaultProperties属性注解，并且没有写具体方法名字，就用统一全局的

    public String paymentInfo_TimeOut(@PathVariable("id") Integer id)
    {
        String result = paymentHystrixService.paymentInfo_TimeOut(id);
        return result;
    }
    public String paymentTimeOutFallbackMethod(@PathVariable("id") Integer id)
    {
        return "paymentTimeOutFallbackMethod,对方系统繁忙，请10秒钟后再次尝试/(ㄒoㄒ)/";
    }

    public String payment_Global_FallbackMethod()
    {
        return "Global异常处理信息，请稍后再试，/(ㄒoㄒ)/~~";
    }
}

进行测试:

http://localhost/consumer/payment/hystrix/timeout/1

方法2:

修改cloud-consumer-feign-hystrix-order80
根据cloud-consumer-feign-hystrix-order80已经有的PaymentHystrixService接口，重新新建一个类(PaymentFallbackService)实现PaymentHystrixService接口，

测试

开启三个服务

访问:
http://localhost/consumer/payment/hystrix/ok/1

成功!

然后把8001服务关闭

成功显示 实现类返回的页面!

服务熔断

熔断机制概述

熔断机制是应对雪崩效应的一种微服务链路保护机制。当扇出链路的某个微服务出错不可用或者响应时间太长时，

会进行服务的降级，进而熔断该节点微服务的调用，快速返回错误的响应信息。

当检测到该节点微服务调用响应正常后，恢复调用链路。

实操

修改cloud-provider-hystrix-payment8001

1. 修改 添加PaymentService里面的服务熔断的函数
2. 修改 添加PaymentController里面的服务熔断的函数

具体看下载代码

测试

测试多次-1 然后在测试1
(这里1 是正确访问,-1是错误访问!)

http://localhost:8001/payment/circuit/1

结果:
多次-1 访问之后,正确访问1也出错了.
要直到正确访问的次数多了才会恢复正常!

熔断类型:

1. 熔断打开:请求不再进行调用当前服务，内部设置时钟一般为MTTR（平均故障处理时间)，当打开时长达到所设时钟则进入半熔断状态
2. 熔断关闭:熔断关闭不会对服务进行熔断
3. 熔断半开:部分请求根据规则调用当前服务，如果请求成功且符合规则则认为当前服务恢复正常，关闭熔断

服务监控hystrixDashboard

除了隔离依赖服务的调用以外，Hystrix还提供了准实时的调用监控（Hystrix Dashboard），Hystrix会持续地记录所有通过Hystrix发起的请求的执行信息，并以统计报表和图形的形式展示给用户，包括每秒执行多少请求多少成功，多少失败等。Netflix通过hystrix-metrics-event-stream项目实现了对以上指标的监控。Spring Cloud也提供了Hystrix Dashboard的整合，对监控内容转化成可视化界面。

建mudlue

1. 新建cloud-consumer-hystrix-dashboard9001
2. 写POM
3. 写YML
4. 启动类
5. 所有Provider微服务提供类(8001/8002/8003)都需要监控依赖配置

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

具体看下载代码
测试:

http://localhost:9001/hystrix

断路器演示(服务监控hystrixDashboard)

cloud-consumer-hystrix-dashboard9001监控cloud-provider-hystrix-payment8001

修改cloud-provider-hystrix-payment8001

添加

/**
 *此配置是为了服务监控而配置，与服务容错本身无关，springcloud升级后的坑
 *ServletRegistrationBean因为springboot的默认路径不是"/hystrix.stream"，
 *只要在自己的项目里配置上下面的servlet就可以了
 */
@Bean
public ServletRegistrationBean getServlet() {
    HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
    ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
    registrationBean.setLoadOnStartup(1);
    registrationBean.addUrlMappings("/hystrix.stream");
    registrationBean.setName("HystrixMetricsStreamServlet");
    return registrationBean;
}

启动服务

http://localhost:9001/hystrix

http://localhost:8001/hystrix.stream

不断访问这个网址

http://localhost:8001/payment/circuit/1

监控板出现数据