[Spring Cloud] Hystrix通过配置文件统一设置参数/与OpenFeign结合使用

✨✨个人主页:沫洺的主页

📚📚系列专栏: 📖 JavaWeb专栏📖 JavaSE专栏 📖 Java基础专栏📖vue3专栏

📖MyBatis专栏📖Spring专栏📖SpringMVC专栏📖SpringBoot专栏

📖Docker专栏📖Reids专栏📖MQ专栏📖SpringCloud专栏

💖💖如果文章对你有所帮助请留下三连✨✨

衔接上篇: [Spring Cloud] Hystrix三大特性--降级,熔断,隔离_沫洺的博客-CSDN博客

🍁配置文件统一设置参数

🌿全局默认配置


#统计的时间窗口，默认为10s，一般不需要更改
hystrix.command.default.metrics.rollingStats.timeInMilliseconds=3000
#是否开启降级
hystrix.command.default.fallback.enabled=true
#是否开启断路器
hystrix.command.default.circuitBreaker.enabled=true
#失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到60，则触发断路，断路器开启，链路中断
hystrix.command.default.circuitBreaker.errorThresholdPercentage=60
#请求最小触发次数
hystrix.command.default.circuitBreaker.requestVolumeThreshold=3
#断路后休眠状态的时长，默认为5s，断路8s后断路器进入半开状态
hystrix.command.default.circuitBreaker.sleepWindowInMilliseconds=10000
#开启超时机制
hystrix.command.default.execution.timeout.enabled=true
#取消是否中断
hystrix.command.default.execution.isolation.thread.interruptOnFutureCancel=true
#超时是否中断
hystrix.command.default.execution.isolation.thread.interruptOnTimeout=true
#超时阈值，单位是毫秒
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=3000

通过配置文件设置参加,就不需要在@HystrixCommand注解中配置参数commandProperties

🌾私有配置

要想针对某个方法进行配置


hystrix.command.commandKey.metrics.rollingStats.timeInMilliseconds=30000
hystrix.command.commandKey.fallback.enabled=true
hystrix.command.commandKey.circuitBreaker.enabled=true
hystrix.command.commandKey.circuitBreaker.errorThresholdPercentage=50
hystrix.command.commandKey.circuitBreaker.requestVolumeThreshold=3
hystrix.command.commandKey.circuitBreaker.sleepWindowInMilliseconds=80000
hystrix.command.commandKey.execution.isolation.thread.interruptOnFutureCancel=true
hystrix.command.commandKey.execution.isolation.thread.interruptOnTimeout=true
hystrix.command.commandKey.execution.isolation.thread.timeoutInMilliseconds=3000
hystrix.command.commandKey.execution.timeout.enabled=true

定义test2方法,指定commandKey="hello2"


@RestController
public class Test {
    @GetMapping("/test")
    //@HystrixCommand(fallbackMethod = "hello_fallback",commandProperties =
    //        {
    //                @HystrixProperty(name = "circuitBreaker.enabled",value = "true"), //开启熔断器
    //                @HystrixProperty(name = "metrics.rollingStats.timeInMilliseconds",value ="30000"), //统计时间窗
    //                @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "3"),      //统计时间窗内最小请求次数阈值
    //                @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"), //休眠时间窗口期
    //                @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "30"), //时间窗内失败阈值百分比
    //                //执行隔离线程超时
    //                @HystrixProperty(name = HystrixPropertiesManager.EXECUTION_ISOLATION_THREAD_TIMEOUT_IN_MILLISECONDS,value = "3000")
    //
    //        })
    @HystrixCommand(fallbackMethod = "hello_fallback")
    public String hello(@RequestParam Integer time){
        ThreadUtil.sleep(time*1000);
        return "原方法";
    }
    @GetMapping("/test2")
    @HystrixCommand(fallbackMethod = "hello_fallback",commandKey = "hello2")
    public String hello2(@RequestParam Integer time){
        ThreadUtil.sleep(time*1000);
        return "原方法";
    }
    public String hello_fallback(Integer time){
        return "兜底方法";
    }
}

将配置中的commandKey替换成hello2,如下


hystrix.command.hello2.metrics.rollingStats.timeInMilliseconds=30000
hystrix.command.hello2.fallback.enabled=true
hystrix.command.hello2.circuitBreaker.enabled=true
hystrix.command.hello2.circuitBreaker.errorThresholdPercentage=30
hystrix.command.hello2.circuitBreaker.requestVolumeThreshold=3
hystrix.command.hello2.circuitBreaker.sleepWindowInMilliseconds=10000
hystrix.command.hello2.execution.isolation.thread.interruptOnFutureCancel=true
hystrix.command.hello2.execution.isolation.thread.interruptOnTimeout=true
hystrix.command.hello2.execution.isolation.thread.timeoutInMilliseconds=3000
hystrix.command.hello2.execution.timeout.enabled=true

🍂Hystrix与OpenFeign结合使用

Feign内部是支持Hystrix的

模拟hystrix-app服务调用nacos-a服务

子模块spring-cloud-hystrix添加依赖


        <dependency>
            <groupId>com.alibaba.cloudgroupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
            
        dependency>
        <dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-openfeignartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-netflix-ribbonartifactId>
        dependency>

pom.xml


"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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0modelVersion>
    <parent>
        <groupId>com.mominggroupId>
        <artifactId>spring-cloud-rootartifactId>
        <version>0.0.1-SNAPSHOTversion>
        <relativePath>../pom.xmlrelativePath>
    parent>
 
    <artifactId>spring-cloud-hystrixartifactId>
 
    <dependencies>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-webartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-netflix-hystrixartifactId>
        dependency>
        <dependency>
            <groupId>com.alibaba.cloudgroupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
            
        dependency>
        <dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-openfeignartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-netflix-ribbonartifactId>
        dependency>
 
 
        <dependency>
            <groupId>cn.hutoolgroupId>
            <artifactId>hutool-allartifactId>
        dependency>
        <dependency>
            <groupId>org.projectlombokgroupId>
            <artifactId>lombokartifactId>
            <optional>trueoptional>
        dependency>
        <dependency>
            <groupId>com.mominggroupId>
            <artifactId>user-apiartifactId>
            <version>0.0.1-SNAPSHOTversion>
            <scope>compilescope>
        dependency>
 
    dependencies>
 
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.bootgroupId>
                <artifactId>spring-boot-maven-pluginartifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombokgroupId>
                            <artifactId>lombokartifactId>
                        exclude>
                    excludes>
                configuration>
            plugin>
        plugins>
    build>
 
project>

相关配置信息


#nacos相关配置
spring.application.name=hystrix-app
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
#新版SpringBoot已不再需要@EnableDiscoveryClient,只需要在pom文件中加入服务发现实现类的maven坐标即可。
#默认true,开启服务自动发现
spring.cloud.discovery.enabled=true
 
#配置feign开启hystrix所有功能
feign.hystrix.enabled=true
 
#Ribbon相关配置
##建立连接的超时时间
ribbon.ConnectionTimeout=5000
##连接成功后,读取资源数据时的超时配置
ribbon.ReadTimeout = 3000

启动类添加注解


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

创建Feign客户端调用a服务,当调用失败时,降级回退到AServerClientFallBack兜底类,执行兜底方法

@FeignClient指定参数fallback=AServerClientFallBack.class


@FeignClient(name = "nacos-a",fallback = AServerClientFallBack.class)
public interface AServerClient extends IUserService {
//##特殊配置key规则为：#(,...)
    //AServerClient#getSleep(Integer)
    //public String getSleep(Integer time) ;
}

全局熔断配置同上

对回退兜底类的某个方法设置熔断配置

配置key规则为：

#(,...)


#OpenFeign自定义配置
hystrix.command.AServerClient#getSleep(Integer).metrics.rollingStats.timeInMilliseconds=30000
hystrix.command.AServerClient#getSleep(Integer).fallback.enabled=true
hystrix.command.AServerClient#getSleep(Integer).circuitBreaker.enabled=true
hystrix.command.AServerClient#getSleep(Integer).circuitBreaker.errorThresholdPercentage=50
hystrix.command.AServerClient#getSleep(Integer).circuitBreaker.requestVolumeThreshold=3
hystrix.command.AServerClient#getSleep(Integer).circuitBreaker.sleepWindowInMilliseconds=10000
hystrix.command.AServerClient#getSleep(Integer).execution.isolation.thread.interruptOnFutureCancel=true
hystrix.command.AServerClient#getSleep(Integer).execution.isolation.thread.interruptOnTimeout=true
hystrix.command.AServerClient#getSleep(Integer).execution.isolation.thread.timeoutInMilliseconds=3000
hystrix.command.AServerClient#getSleep(Integer).execution.timeout.enabled=true

AServerClientFallBack


@Component
public class AServerClientFallBack implements AServerClient{
    @Override
    public String getName(Integer id) {
        return null;
    }
 
    @Override
    public Integer getAmount(Integer id) {
        return null;
    }
 
    @Override
    public String getSleep(Integer time) {
        return "sleep兜底方法";
    }
}

创建测试接口


@RestController
public class FeignController {
    @Autowired
    private AServerClient aServerClient;
 
    @GetMapping("/feign/test")
    public String test(@RequestParam Integer time){
        return aServerClient.getSleep(time);
    }
}

访问,模拟熔断

相关阅读:
EN 16034门窗及配件—CE认证
 anroid html5 拍照扫码
 SpringMVC log4j1升级log4j2
【算法刷题日记之本手篇】星际密码与数根
 How to install mongodb 7.0 to Ubuntu 22.04
mybatis实现CRUD及相关配置
 计算机毕业设计springboot家具销售系统tj2lo源码+系统+程序+lw文档+部署
 零基础Linux_6(开发工具_下)函数库链接+Makefile+实现进度条+Git
字节跳动开源Linux 内核网络抓包工具 netcap
【DL论文精读笔记】Image Segmentation Using Deep Learning: A Survey 图像分割综述
原文地址：https://blog.csdn.net/HeyVIrBbox/article/details/127979646