【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记(六)Hystrix(豪猪哥)的使用

本文涉及的产品
性能测试 PTS,5000VUM额度
简介: 【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记(六)Hystrix(豪猪哥)的使用

前几章,我们讲解了Eureka注册中心、Ribbon和OpenFeign服务调用框架;今天开始讲一个分布式微服务项目中很重要的内容Hytrix服务降级框架。

尽管Hytrix官网停止更新了,但是Hytrix的设计理念和思想非常优秀,其他服务降级框架的设计都是借鉴于它,可以说它是所有分布式微服务项目中服务降级使用的基石。

1、Hystrix熔断器概述

2、HyStrix重要概念

  1. 服务降级fallback

比如当某个服务繁忙,不能让客户端的请求一直等待,应该立刻返回给客户端一个备选方案(兜底的服务)

服务器忙,请稍后再试,不让客户端等待并立刻返回一个友好提示,fallback

哪些情况会发出降级:

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

当某个服务出现问题,卡死了,不能让用户一直等待,需要关闭所有对此服务的访问,然后调用服务降级

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

就是保险丝:服务的降级->进而熔断->恢复调用链路

  1. 服务限流flowlimit

限流,比如秒杀场景,不能访问用户瞬间都访问服务器,限制一次只可以有多少请求

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

3、hystrix案例

3.1 新建模块 Cloud-provider-hystrix-payment8001
  1. 建模块 Cloud-provider-hystrix-payment8001

  1. pom文件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2023</artifactId>
        <groupId>com.tigerhhzz.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>Cloud-provider-hystrix-payment8001</artifactId>
    <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>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-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.tigerhhzz.springcloud-tigerhhzz</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>
  1. yml文件
server:
  port: 8001
spring:
  application:
    name: cloud-provider-hystrix-service
eureka:
  client:
    service-url:
      #      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
      defaultZone: http://eureka7001.com:7001/eureka/
  1. 主启动类
package com.tigerhhzz.springcloud;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
/**
 * @author tigerhhzz
 * @date 2023/4/12 9:41
 */
@SpringBootApplication
@EnableEurekaClient
@Slf4j
public class PaymentHystrixMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentHystrixMain8001.class,args);
        log.info("PaymentHystrixMain8001启动成功~~~~~~~~~~~~~~~~~~~");
    }
}
  1. 业务类
    写service:
package com.tigerhhzz.springcloud.service;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:16
 */
public interface PaymentService {
    String getPaymentInfo_OK(Integer id);
    String getPaymentInfo_Error(Integer id);
}

service实现类:

package com.tigerhhzz.springcloud.service.impl;
import com.tigerhhzz.springcloud.service.PaymentService;
import org.springframework.stereotype.Service;
import java.util.concurrent.TimeUnit;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:18
 */
@Service
public class PaymentServiceImpl implements PaymentService {
    @Override
    public String getPaymentInfo_OK(Integer id) {
        return "当前线程池名称: "+Thread.currentThread().getName()+"----getPaymentInfo_OK----,id: "+id;
    }
    @Override
    public String getPaymentInfo_Error(Integer id) {
        //System.out.println(Thread.currentThread().getName()+"-----------error----------"+id);
        int timeout = 3;
        //int age = 10/0;
        try {
            TimeUnit.SECONDS.sleep(timeout);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "当前线程池名称: "+Thread.currentThread().getName()+"-----getPaymentInfo_Error----ERROR----"+id;
    }
}

controller:

package com.tigerhhzz.springcloud.controller;
import com.tigerhhzz.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
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;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:19
 */
@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;
    @Value("${server.port}")
    private String serverPort;
    @GetMapping("/payment/hystrix/ok/{id}")
    public String getPaymentInfo_OK(@PathVariable("id") Integer id){
        String res = paymentService.getPaymentInfo_OK(id);
        return res;
    }
    @GetMapping("/payment/hystrix/error/{id}")
    public String getPaymentInfo_Error(@PathVariable("id") Integer id){
        String res = paymentService.getPaymentInfo_Error(id);
        return res;
    }
}

启动7001和8001模块,测试正常

以上述为根基平台,从正确–错误–降级熔断–恢复。

通过jmeter压力测试 20000个并发请求http://localhost:8001/payment/hystrix/error/1

  1. jmeter压力测试设置

再次压测2万并发,发现http://localhost:8001/payment/hystrix/ok/1访问也变慢了,开始转圈圈了。

此时使用压测工具,并发20000个请求,请求会延迟的那个方法,
        压测中,发现,另外一个方法并没有被压测,但是我们访问它时,却需要等待
        这就是因为被压测的方法它占用了服务器大部分资源,导致其他请求也变慢了

让问题和错误更严重,建一个80消费模块去访问8001,80模块感觉很崩溃~~~~~~~~

3.2 创建带降级的order模块 Cloud-comsumer-feign-hystrix-order80
  1. 建模块

  2. 修pom
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2023</artifactId>
        <groupId>com.tigerhhzz.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>Cloud-comsumer-feign-hystrix-order80</artifactId>
    <dependencies>
        <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>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-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.tigerhhzz.springcloud-tigerhhzz</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>
  1. 改yml
server:
  port: 80
spring:
  application:
    name: cloud-comsumer-feign-hystrix-order80
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/
  1. 主启动类
package com.tigerhhzz.springcloud;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:56
 */
@SpringBootApplication
@EnableFeignClients
@Slf4j
public class OrderFeignHystrixMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderFeignHystrixMain80.class,args);
        log.info("OrderFeignHystrixMain80启动成功~~~~~~~~~~~~~~~~~~~");
    }
}
  1. 远程调用8001模块的接口
package com.tigerhhzz.springcloud.service;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:59
 *
 * 微服务接口 + @feign注解
 */
@Component
@FeignClient(value = "cloud-provider-hystrix-service")
public interface PaymentHystrixService {
    @GetMapping("/payment/hystrix/ok/{id}")
    public String getPaymentInfo_OK(@PathVariable("id") Integer id);
    @GetMapping("/payment/hystrix/error/{id}")
    public String getPaymentInfo_Error(@PathVariable("id") Integer id);
}
  1. controller
package com.tigerhhzz.springcloud.controller;
import com.tigerhhzz.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
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;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:19
 */
@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;
    @Value("${server.port}")
    private String serverPort;
    @GetMapping("/consumer/payment/hystrix/ok/{id}")
    public String getPaymentInfo_OK(@PathVariable("id") Integer id){
        String res = paymentService.getPaymentInfo_OK(id);
        return res;
    }
    @GetMapping("/consumer/payment/hystrix/error/{id}")
    public String getPaymentInfo_Error(@PathVariable("id") Integer id){
        String res = paymentService.getPaymentInfo_Error(id);
        return res;
    }
}
  1. 测试

启动80模块,访问8001,正常。

再次压测2万并发,发现80访问也变慢了

此时使用压测工具,并发20000个请求,请求会延迟的那个方法,

压测中,发现,另外一个方法并没有被压测,但是我们访问它时,却需要等待

这就是因为被压测的方法它占用了服务器大部分资源,导致其他请求也变慢了

3.3 配置服务降级:
3.3.1 服务降级 Cloud-provider-hystrix-payment8001模块

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

具体配置步骤如下:

  1. 为service的指定方法(会延迟的方法)添加@HystrixCommand注解

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

超过3秒,fallback服务降级。

package com.tigerhhzz.springcloud.service.impl;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import com.tigerhhzz.springcloud.service.PaymentService;
import org.springframework.stereotype.Service;
import java.util.concurrent.TimeUnit;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:18
 */
@Service
public class PaymentServiceImpl implements PaymentService {
    @Override
    public String getPaymentInfo_OK(Integer id) {
        return "当前线程池名称: "+Thread.currentThread().getName()+"----getPaymentInfo_OK----,id: "+id;
    }
    @Override
    @HystrixCommand(fallbackMethod = "getPaymentInfo_ErrorHandler",commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "3000")
    })
    public String getPaymentInfo_Error(Integer id) {
        //System.out.println(Thread.currentThread().getName()+"-----------error----------"+id);
        int timeout = 5;
        //int age = 10/0;
        try {
            TimeUnit.SECONDS.sleep(timeout);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "当前线程池名称: "+Thread.currentThread().getName()+"-----getPaymentInfo_Error----ERROR----"+id;
    }
    /*fallback服务降级后的兜底方法*/
    public String getPaymentInfo_ErrorHandler(Integer id) {
        return Thread.currentThread().getName()+"-----8001 allback服务降级后的兜底方法----超时或异常------getPaymentInfo_ErrorHandler----ERROR----"+id;
    }
}

getPaymentInfo_ErrorHandler服务降级后的兜底方法

  1. 主启动类上,添加激活hystrix的注解
package com.tigerhhzz.springcloud;
import lombok.extern.slf4j.Slf4j;
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;
/**
 * @author tigerhhzz
 * @date 2023/4/12 9:41
 */
@SpringBootApplication
@EnableEurekaClient
@EnableCircuitBreaker
@Slf4j
public class PaymentHystrixMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentHystrixMain8001.class,args);
        log.info("PaymentHystrixMain8001启动成功~~~~~~~~~~~~~~~~~~~");
    }
}

先测试8001的自身加固,有没有效果?

访问:http://localhost:8001/payment/hystrix/error/1

结论:

上面故意制造两个异常:

1,int timeout = 5;

2,我们能接受3秒钟,它运行5秒钟,超时异常

当前服务不可用了,做服务降级,兜底的方案都是方法 getPaymentInfo_ErrorHandler。

这是8001对自己做的保护,遇到异常做服务降级,进入兜底方法。

3.3.2 服务降级Cloud-comsumer-feign-hystrix-order80模块

首先80模块也要有个服务自我保护的机制,也需要服务降级保护

然后,80通过feign调用8001时

  1. 修改80的yml配置

添加在feign中开启hystrix的配置

server:
  port: 80
spring:
  application:
    name: cloud-comsumer-feign-hystrix-order80
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/
feign:
  hystrix:
    enabled: true  #在feign中开启hystrix
  1. 改80启动类

在启动类中加上注解@EnableHystrix

package com.tigerhhzz.springcloud;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:56
 */
@SpringBootApplication
@EnableFeignClients
@EnableHystrix
@Slf4j
public class OrderFeignHystrixMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderFeignHystrixMain80.class,args);
        log.info("OrderFeignHystrixMain80启动成功~~~~~~~~~~~~~~~~~~~");
    }
}
  1. 业务类

主要意思是:80模块中的paymentInfo_ERROR接口也自身做个hystrix服务降级兜底方法。并设置超时时间峰值是1500毫秒。

@GetMapping("/consumer/payment/hystrix/error/{id}")
    @HystrixCommand(fallbackMethod = "paymentInfo_ERROR_Handler",commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "1500")
    })
    public String paymentInfo_ERROR(@PathVariable("id") Integer id){
        //int age= 10/0;
        return paymentHystrixService.getPaymentInfo_Error(id);
    }
    public String paymentInfo_ERROR_Handler(@PathVariable("id") Integer id){
        return "80____paymentInfo_ERROR_Handler___异常返回,请检查自己";
    }

测试,访问地址:http://localhost/consumer/payment/hystrix/error/1

上面有三个时间,需要注意一下。

第一个时间是:8001模块getPaymentInfo_Error接口的峰值时间5000毫秒(8001自我保护的服务降级峰值时间)

第二个时间是:8001模块getPaymentInfo_Error中的假设业务超时时间3000毫秒,允许3秒内不进行服务降级

第三个时间是:80模块的自我保护服务降级峰值时间1500毫秒。

3.3.3 Hystrix全局服务降级DefaultProperties

上述案例中,我们发现每个方法都需要服务降级的兜底方法,这样代码显得很膨胀,业务重复的问题。

统一与自定义的分开。

案例是在80模块的controller中设置如下:

package com.tigerhhzz.springcloud.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 com.tigerhhzz.springcloud.service.PaymentHystrixService;
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;
/**
 * @author tigerhhzz
 * @date 2022/6/15 10:03
 */
@RestController
@Slf4j
@DefaultProperties(defaultFallback = "Payment_Global_Fallback_Handler")
public class OrderHystrixController {
    @Resource
    private PaymentHystrixService paymentHystrixService;
    @GetMapping("/consumer/payment/hystrix/ok/{id}")
    public String getPaymentInfo_OK(@PathVariable("id") Integer id) {
        return paymentHystrixService.getPaymentInfo_OK(id);
    }
    @GetMapping("/consumer/payment/hystrix/error/{id}")
    @HystrixCommand(fallbackMethod = "paymentInfo_ERROR_Handler",commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "1500")
    })
    public String paymentInfo_ERROR(@PathVariable("id") Integer id){
        //int age= 10/0;
        return paymentHystrixService.getPaymentInfo_Error(id);
    }
    public String paymentInfo_ERROR_Handler(@PathVariable("id") Integer id){
        return "80____paymentInfo_ERROR_Handler___异常返回,请检查自己";
    }
    /*全局fallback方法  注意 这个全局兜底方法不能携带参数  这是我遇到的坑*/
    public String Payment_Global_Fallback_Handler(){
        return "80____Payment_Global_Fallback_Handler___异常返回";
    }
}

这里我新加了一个接口方法:

@GetMapping("/consumer/payment/hystrix/error1/{id}")
    @HystrixCommand
    public String paymentInfo_ERROR1(@PathVariable("id") Integer id){
        int age= 10/0;
        return paymentHystrixService.getPaymentInfo_Error(id);
    }

测试访问地址:http://localhost/consumer/payment/hystrix/error1/1

进入全局服务降级的兜底方法。

3.3.3 Hystrix通配服务降级FeignFallback

微服务中,只要通过feign调用的接口上都有@FeignClient注解,换句话说:标有@FeignClient注解的接口中的所有方法做个统一的服务降级类,就可以实现接口服务的统一服务降级。

具体步骤:

  1. 新建一个类PaymentFallbackService实现 标注有@FeignClient注解的接口
    统一为接口里面的方法进行异常处理。
package com.tigerhhzz.springcloud.service;
import org.springframework.stereotype.Component;
/**
 * @author tigerhhzz
 * @date 2022/6/15 19:16
 */
@Component
public class PaymentFallbackService implements PaymentHystrixService{
    @Override
    public String getPaymentInfo_OK(Integer id) {
        return "80---PaymentFallbackService----payment/hystrix/ok";
    }
    @Override
    public String getPaymentInfo_Error(Integer id) {
        return "80----PaymentFallbackService---payment/hystrix/error";
    }
}
  1. 修改80中的feign接口PaymentHystrixService

添加@FeignClient(value = “cloud-provider-hystrix-service”,fallback = PaymentFallbackService.class)

package com.tigerhhzz.springcloud.service;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
/**
 * @author tigerhhzz
 * @date 2022/6/15 9:59
 *
 * 微服务接口 + @feign注解
 */
@Component
@FeignClient(value = "cloud-provider-hystrix-service",fallback = PaymentFallbackService.class)
public interface PaymentHystrixService {
    @GetMapping("/payment/hystrix/ok/{id}")
    public String getPaymentInfo_OK(@PathVariable("id") Integer id);
    @GetMapping("/payment/hystrix/error/{id}")
    public String getPaymentInfo_Error(@PathVariable("id") Integer id);
}
  1. 测试访问:
    首先访问http://localhost/consumer/payment/hystrix/ok/1

然后,关闭8001服务

再次访问上述地址

此时服务端已经宕机了,但是我们做了服务降级处理,让客户端在服务端不可用时也会获得提示信息而不会挂起耗死服务器。

3.4 服务熔断CircuitBreaker

熔断机制是应对雪崩效应的一种微服务链路保护机制。

保险丝

在springcloud框架中,熔断机制通过Hystrix实现,Hystrix会健康微服务间调用的状况

当失败的调用到一定阈值,缺省是5秒内20次调用的失败,就会启动熔断机制。熔断机制的注解是@HystrixCommand。

4.4.1 服务熔断理论

三个状态 closed、open、halfopen(开、关、半开)

4.4.2 服务熔断案例

修改Cloud-provider-hystrix-payment8001模块

  1. PaymentServiceImpl:
//---服务的熔断
    @Override
    @HystrixCommand(
            fallbackMethod = "paymentCircuitBreaker_fallback",commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled",value = "true"), //是否开启断路器
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"), //请求次数
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"), //时间窗口期
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"),//失败率达到多少后跳闸
    }
    )
    public String paymentCircuitBreaker(@PathVariable("id") Integer id) {
        if (id<0) {
            throw new RuntimeException("******id不能为负数");
        }
        String simpleUUID = IdUtil.simpleUUID();
        return Thread.currentThread().getName()+"\t" + "成功调用,流水号是:" + simpleUUID;
    }
    public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id) {
        return "id不能为负数,请稍后再试............"+id;
    }
  1. PaymentController
//服务熔断
    @GetMapping("info/circuit/{id}")
    public String paymentCircuitBreaker(@PathVariable("id") Integer id){
        String res = paymentService.paymentCircuitBreaker(id);
        log.info("-----res:" +res);
        return res;
    }
  1. 测试
    自测Cloud-provider-hystrix-payment8001 启动

正确 http://localhost:8001/info/circuit/1

错误 http://localhost:8001/info/circuit/-1

一次正确一次错误,远远没有达到访问10次失败率6次以上的设置

此时,连续访问-1 20多次,然后再访问1时,发现刚开始调用链路还没有恢复,等几秒钟后才访问正常。

多次错误,然后慢慢正确,发现刚开始不满足条件,随着错误率下降后,才恢复正常。

服务的降级------进而熔断----恢复调用链路

4.4.3 服务熔断总结

当断路器开启后:

熔断的整体流程:

请求进来,首先查询缓存,如果缓存有,直接返回
如果缓存没有,--->2
查看断路器是否开启,如果开启的,Hystrix直接将请求转发到降级返回,然后返回
如果断路器是关闭的,
判断线程池等资源是否已经满了,如果已经满了
也会走降级方法
如果资源没有满,判断我们使用的什么类型的Hystrix,决定调用构造方法还是run方法
然后处理请求
然后Hystrix将本次请求的结果信息汇报给断路器,因为断路器此时可能是开启的
(因为断路器开启也是可以接收请求的)
断路器收到信息,判断是否符合开启或关闭断路器的条件,
如果本次请求处理失败,又会进入降级方法
如果处理成功,判断处理是否超时,如果超时了,也进入降级方法
最后,没有超时,则本次请求处理成功,将结果返回给controller

其他参数

相关实践学习
通过性能测试PTS对云服务器ECS进行规格选择与性能压测
本文为您介绍如何利用性能测试PTS对云服务器ECS进行规格选择与性能压测。
目录
相关文章
|
3月前
|
Cloud Native Java 对象存储
面向未来的架构设计:Spring Cloud和Netflix OSS在云原生环境下的发展趋势
展望未来,随着5G、边缘计算等新技术的兴起,微服务架构的设计理念将会更加深入人心,Spring Cloud和Netflix OSS也将继续引领技术潮流,为企业带来更为高效、灵活且强大的解决方案。无论是对于初创公司还是大型企业而言,掌握这些前沿技术都将是在激烈市场竞争中脱颖而出的关键所在。
66 0
|
3月前
|
Java 对象存储 开发者
解析Spring Cloud与Netflix OSS:微服务架构中的左右手如何协同作战
Spring Cloud与Netflix OSS不仅是现代微服务架构中不可或缺的一部分,它们还通过不断的技术创新和社区贡献推动了整个行业的发展。无论是对于初创企业还是大型组织来说,掌握并合理运用这两套工具,都能极大地提升软件系统的灵活性、可扩展性以及整体性能。随着云计算和容器化技术的进一步普及,Spring Cloud与Netflix OSS将继续引领微服务技术的发展潮流。
62 0
|
2月前
|
Java Spring
Spring底层架构源码解析(三)
Spring底层架构源码解析(三)
120 5
|
2月前
|
XML Java 数据格式
Spring底层架构源码解析(二)
Spring底层架构源码解析(二)
|
2月前
|
JSON 前端开发 Java
Spring Boot框架中的响应与分层解耦架构
在Spring Boot框架中,响应与分层解耦架构是两个核心概念,它们共同促进了应用程序的高效性、可维护性和可扩展性。
55 3
|
2月前
|
Cloud Native Java 对象存储
面向未来的架构设计:Spring Cloud和Netflix OSS在云原生环境下的发展趋势
面向未来的架构设计:Spring Cloud和Netflix OSS在云原生环境下的发展趋势
49 1
|
3月前
|
存储 Java 数据库
Spring Boot 优雅实现多租户架构
本文详细介绍如何使用Spring Boot和Spring Cloud实现多租户架构。多租户架构允许多个租户共用一个应用,各自拥有独立资源和数据。其优势包括满足个性化需求、降低成本、复用代码以及增强可扩展性。文中探讨了架构选型、数据库设计、应用部署及租户管理等内容,并提供了具体实现步骤和技术细节。适用于SaaS应用和多租户云服务等场景。
|
3月前
|
Cloud Native Java 对象存储
揭秘微服务架构之争:Spring Cloud与Netflix OSS巅峰对决,谁将称霸弹性云原生时代?
近年来,微服务架构成为企业应用的主流设计模式。本文对比了两大热门框架Spring Cloud和Netflix OSS,探讨其在构建弹性微服务方面的表现。Spring Cloud依托Spring Boot,提供全面的微服务解决方案,包括服务注册、配置管理和负载均衡等。Netflix OSS则由一系列可独立或组合使用的组件构成,如Eureka、Hystrix等。两者相比,Spring Cloud更易集成且功能完善,而Netflix OSS则需自行整合组件,但灵活性更高。实际上,两者也可结合使用以发挥各自优势。通过对两者的对比分析,希望为企业在微服务架构选型上提供参考。
61 0
|
3月前
|
SpringCloudAlibaba API 开发者
新版-SpringCloud+SpringCloud Alibaba
新版-SpringCloud+SpringCloud Alibaba
|
4月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要,常用于异步数据处理、自动化运维等场景。在单体应用中,利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而,进入微服务架构后,任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块,提供轻量级、高可用的分布式定时任务解决方案,支持防重复执行、分片运行等功能,并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案(如ShedLock)
131 1