Spring Cloud Hystrix集成
Posted java_wxid
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Spring Cloud Hystrix集成相关的知识，希望对你有一定的参考价值。
本章会结合【java_wxid项目】【第二章】【Spring Cloud Alibaba Nacos集成】的spring-cloud-alibaba-nacos-demo项目结合使用
文章目录
创建spring-cloud-hystrix-demo项目
项目结构如下（示例）：
修改pom.xml文件
代码如下（示例）：
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.example</groupId>
<artifactId>spring-cloud-hystrix-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>spring-cloud-hystrix-demo</name>
<description>Demo project for Spring Boot</description>
<!-- 属性配置-->
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<!--引入 Spring Boot、Spring Cloud、Spring Cloud Alibaba 三者 BOM 文件，进行依赖版本的管理，防止不兼容。
在 https://dwz.cn/mcLIfNKt 文章中，Spring Cloud Alibaba 开发团队推荐了三者的依赖关系-->
<spring.boot.version>2.3.12.RELEASE</spring.boot.version>
<spring.cloud.version>Hoxton.SR12</spring.cloud.version>
<spring.cloud.alibaba.version>2.2.7.RELEASE</spring.cloud.alibaba.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- 代表web模块，在这个模块中含了许多JAR包，有spring相关的jar，内置tomcat服务器，jackson等，这些web项目中常用的的功能都会自动引入-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Alibaba Nacos 配置 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- 在SpringBoot 2.4.x的版本之后，对于bootstrap.properties/bootstrap.yaml配置文件(我们合起来成为Bootstrap配置文件)的支持，其实这个jar包里什么都没有，就只有一个标识类Marker，用来标识要开启Bootstrap配置文件的支持，由于父类用了2.5.6版本需要导入如下的依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
<version>3.1.0</version>
</dependency>
<!-- hystrix -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
</dependencies>
<!--
引入 Spring Boot、Spring Cloud、Spring Cloud Alibaba 三者 BOM 文件，进行依赖版本的管理，防止不兼容。
在 https://dwz.cn/mcLIfNKt 文章中，Spring Cloud Alibaba 开发团队推荐了三者的依赖关系
-->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>$spring.boot.version</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>$spring.cloud.version</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>$spring.cloud.alibaba.version</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>2.4</version>
<configuration>
<source>$java.version</source>
<target>$java.version</target>
<encoding>$project.build.sourceEncoding</encoding>
</configuration>
</plugin>
</plugins>
</build>
</project>
创建bootstrap.yml文件
代码如下（示例）：
#bootstrap.yml优先级比application.yml优先级高
spring:
#prefix−spring.profile.active.$file-extension
#nacos会根据当前环境去拼接配置名称查找相应配置文件，
#示例：spring.application.name-spring.profiles.active-spring.cloud.nacos.config.file-extension
#获取到值：nacos-autoconfig-service-dev.yml
profiles:
#开发环境dev，测试环境test，生产环境prod
active: dev
application:
#配置应用的名称，用于获取配置
name: hystrix-demo
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: ip:8848
config:
#nacos配置中心地址
server-addr: ip:8848
#配置中心的命名空间id
namespace: 9e50b6d9-6c3d-4e7a-b701-10f085e4b98d
#配置分组，默认没有也可以
group: DEFAULT_GROUP
#配置文件后缀，用于拼接配置配置文件名称，目前只支持yaml和properties
file-extension: yaml
#配置自动刷新
refresh-enabled: true
#配置文件的前缀，默认是application.name的值，如果配了prefix，就取prefix的值
#prefix: nacos-autoconfig-service-$spring.profile.active
# 配置编码
encode: UTF-8
username: nacos
password: nacos
修改启动类SpringCloudHystrixDemoApplication
代码如下（示例）：
package com.example.springcloudhystrixdemo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@SpringBootApplication
@EnableDiscoveryClient
// 开启断路器，开启Hystrix容错能力
@EnableCircuitBreaker
public class SpringCloudHystrixDemoApplication
public static void main(String[] args)
SpringApplication.run(SpringCloudHystrixDemoApplication.class, args);
@Bean
@LoadBalanced
public RestTemplate restTemplate()
return new RestTemplate();
创建HystrixController
代码如下（示例）：
package com.example.springcloudhystrixdemo.controller;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import com.netflix.hystrix.contrib.javanica.conf.HystrixPropertiesManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
/**
* @Author: liaozhiwei
* @Description: TODO
* @Date: Created in 15:50 2022/8/23
*/
@RestController
@RequestMapping("/hystrix")
public class HystrixController
@Autowired
private RestTemplate restTemplate;
/**
* HystrixCommand 开启Hystrix命令 当方法执行失败时，使用Hystrix逻辑处理
* fallbackMethod 当方法执行失败时,调用此方法。
*/
@GetMapping("/getNacosConfigure")
@HystrixCommand(fallbackMethod = "defaultFallbackMethod")
public String getNacosConfigure()
return restTemplate.getForObject("http://nacos-config/getNacosConfigure", String.class);
private String defaultFallbackMethod()
return "方法执行失败啦，Hystrix起作用了";
// 信号量隔离
@HystrixCommand(
commandProperties =
// 超时时间，默认1000ms
@HystrixProperty(name = HystrixPropertiesManager.
EXECUTION_ISOLATION_THREAD_TIMEOUT_IN_MILLISECONDS, value = "5000"),
// 信号量隔离
@HystrixProperty(name = HystrixPropertiesManager.
EXECUTION_ISOLATION_STRATEGY, value = "SEMAPHORE"),
// 信号量最大并发
@HystrixProperty(name = HystrixPropertiesManager.
EXECUTION_ISOLATION_SEMAPHORE_MAX_CONCURRENT_REQUESTS, value = "5")
,//回退方法
fallbackMethod = "defaultFallbackMethod"
)
@GetMapping("/semaphoreIsolation")
public String semaphoreIsolation()
return "信号量隔离" + Thread.currentThread().getName();
// 线程池隔离
@HystrixCommand(groupKey = "productService", // 服务名称，相同名称使用同一个线程池
commandKey = "selectById", // 接口名称，默认为方法名
threadPoolKey = "productServiceListPool", // 线程池名称，相同名称使用同一个线程池
commandProperties =
// 超时时间，默认1000ms
@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "5000")
,
threadPoolProperties =
// 线程池大小
@HystrixProperty(name = "coreSize", value = "5"),
// 等待队列长度（最大队列长度，默认值-1）
@HystrixProperty(name = "maxQueueSize", value = "100"),
// 线程存活时间，默认1min
@HystrixProperty(name = "keepAliveTimeMinutes", value = "2"),
// 超出等待队列阈值执行拒绝策略
@HystrixProperty(name = "queueSizeRejectionThreshold", value = "100")
,//回退方法
fallbackMethod = "defaultFallbackMethod"
)
@GetMapping("/threadPoolIsolation")
public String threadPoolIsolation()
return "线程池隔离" + Thread.currentThread().getName();
// 服务熔断
@HystrixCommand(
commandProperties =
// 请求数阈值：在快照时间窗口内，必须满足请求阈值数才有资格熔断。打开断路器的最少请求数，默认20个请求。
//意味着在时间窗口内，如果调用次数少于20次，即使所有的请求都超时或者失败，断路器都不会打开
@HystrixProperty(name = HystrixPropertiesManager.
CIRCUIT_BREAKER_REQUEST_VOLUME_THRESHOLD, value = "10"),
// 错误百分比阈值：当请求总数在快照内超过了阈值，且有一半的请求失败，这时断路器将会打开。默认50%
@HystrixProperty(name = HystrixPropertiesManager.
CIRCUIT_BREAKER_ERROR_THRESHOLD_PERCENTAGE, value = "50"),
// 快照时间窗口：断路器开启时需要统计一些请求和错误数据，统计的时间范围就是快照时间窗口，默认5秒
@HystrixProperty(name = HystrixPropertiesManager.
CIRCUIT_BREAKER_SLEEP_WINDOW_IN_MILLISECONDS, value = "5000")
,
fallbackMethod = "defaultFallbackMethod"
)
@GetMapping("/serviceFuse")
public String serviceFuse()
return "服务熔断" + Thread.currentThread().getName() +
LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_TIME);
// 服务降级
@HystrixCommand(fallbackMethod = "defaultFallbackMethod")
@GetMapping("/serviceDegradation ")
public String serviceDegradation()
return "服务降级" + Thread.currentThread().getName() +
LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_TIME);
校验Hystrix是否工作
启动spring-cloud-alibaba-nacos-demo项目、spring-cloud-hystrix-demo项目
调用接口http://localhost:8805/getNacosConfigure
如下图（示例）：
如下图（示例）：
发现可以正常工作，然后暂停spring-cloud-alibaba-nacos-demo的服务，这里可以去nacos里面把服务下线
如下图（示例）：
由于nacos是动态更新配置，过一会再次请求接口http://localhost:8805/getNacosConfigure
如下图（示例）：
可以发现Hystrix可以正常工作了
以上是关于Spring Cloud Hystrix集成的主要内容，如果未能解决你的问题，请参考以下文章