# 从浅入深 学习 SpringCloud 微服务架构（七）Hystrix（1）

从浅入深 学习 SpringCloud 微服务架构（七）Hystrix（1）

一、Hystrix：基于 RestTemplate 的熔断配置

1、Hystrix 介绍：

1）Hystrix 是由 Netflix 开源的一个延迟和容错库，
用于隔离访问远程系统、服务或者第三方库，防止级联失败，从而提升系统的可用性与容错性。

2）Hystrix 主要通过以下几点实现延迟和容错。

包裹请求:
使用HystrixCommand包裹对依赖的调用逻辑，每个命令在独立线程中执行。
这使用了设计模式中的“命令模式”。

跳闸机制:
当某服务的错误率超过一定的阈值时，Hystrix可以自动或手动跳闸，停止请求该服务一段时间。

资源隔离:
Hystrix为每个依赖都维护了一个小型的线程池(或者信号量)。
如果该线程池已满发往该依赖的请求就被立即拒绝，而不是排队等待，从而加速失败判定。

监控:
Hystrix可以近乎实时地监控运行指标和配置的变化，例如成功、失败、超时、以及被拒绝的请求等。

回退机制:
当请求失败、超时、被拒绝，或当断路器打开时，执行回退逻辑。
回退逻辑由开发人员截图(Alt + A)自行提供，例如返回一个缺省值。

自我修复:
断路器打开一段时间后，会自动进入“半开“状态。

2、Hystrix 组件 对 RestTemplate 的支持，分4步：

1）引入 hystrix 的依赖。
2）在启动类中激活 hystrix
3）配置熔断触发的降级逻辑。
4）在需要收到保护的接口上使用 @HystrixCommand 配置。

二、Hystrix：基于 RestTemplate 的熔断配置，Hystrix 组件 对 RestTemplate 的支持，搭建案例：准备工作–创建 mysql 数据库，数据表，插入测试数据。

1、准备 mysql 数据库表。

— 创建数据库：
create database shop;

— 使用数据库：
use shop;

— 创建数据表：

	CREATE TABLE `tb_product` (`id` int NOT NULL AUTO_INCREMENT,`product_name` varchar(40) DEFAULT NULL COMMENT '名称',`status` int DEFAULT NULL COMMENT '状态',`price` decimal(10,2) DEFAULT NULL COMMENT '单价',`product_desc` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '描述',`caption` varchar(255) DEFAULT NULL COMMENT '标题',`inventory` int DEFAULT NULL COMMENT '库存',PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb3

2、向 mysql 数据表中插入数据：

insert into `tb_product` (`id`, `product_name`, `status`, `price`, `product_desc`, `caption`, `inventory`) values('1','iPhone 15 Pro','1','7999.00','iPhone 15 Pro 6.7 英寸或 6.1 英寸, 超视网膜 XDR 显示屏,ProMotion 自适应刷新率技术,钛金属搭配亚光质感玻璃背板, 灵动岛功能, A17 Pro 芯片,配备 6 核图形处理器, Pro 级摄像头系统,主摄 4800 万像素 | 超广角 | 长焦, 10 倍, 支持 USB 3, 视频播放最长可达 29 小时。 ','iPhone 15 Pro 巅峰之作','99');

三、Hystrix：基于 RestTemplate 的熔断配置，Hystrix 组件 对 RestTemplate 的支持，搭建案例：创建 Maven 父工程，导入相关依赖坐标。

1、打开 idea 创建父工程

创建 artifactId 名为 spring_cloud_consul_demo 的 maven 工程。

	--> idea --> File --> New --> Project --> Maven Project SDK: ( 1.8(java version "1.8.0_131" ) --> Next --> Groupld : ( djh.it )Artifactld : ( spring_cloud_consul_demo )Version : 1.0-SNAPSHOT--> Name: ( spring_cloud_consul_demo )Location: ( D:\java_test\Intesij_idea\spring_cloud_consul_demo )	--> Finish

2、在父工程 spring_cloud_consul_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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>djh.it</groupId><artifactId>spring_cloud_consul_demo</artifactId><packaging>pom</packaging><version>1.0-SNAPSHOT</version><modules><module>product_service</module><module>order_service</module><module>eureka_service</module><module>import_eurekaserver_test</module></modules><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.6.RELEASE</version></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-logging</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.4</version><scope>provided</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Greenwich.RELEASE</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><repositories><repository><id>spring-snapshots</id><name>Spring Snapshots</name><url>http://repo.spring.io/libs-snapshot-local</url><snapshots><enabled>true</enabled></snapshots></repository><repository><id>spring-milestones</id><name>Spring Milestones</name><url>http://repo.spring.io/libs-milestone-local</url><snapshots><enabled>false</enabled></snapshots></repository><repository><id>spring-releases</id><name>Spring Releases</name><url>http://repo.spring.io/libs-release-local</url><snapshots><enabled>false</enabled></snapshots></repository></repositories><pluginRepositories><pluginRepository><id>spring-snapshots</id><name>Spring Snapshots</name><url>http://repo.spring.io/libs-snapshot-local</url><snapshots><enabled>true</enabled></snapshots></pluginRepository><pluginRepository><id>spring-milestones</id><name>Spring Milestones</name><url>http://repo.spring.io/libs-milestone-local</url><snapshots><enabled>false</enabled></snapshots></pluginRepository></pluginRepositories><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project><!-- spring_cloud_consul_demo\pom.xml -->

3、由于父工程中，我们不准备写代码，所以可以删除 src 目录。

四、Hystrix：基于 RestTemplate 的熔断配置，Hystrix 组件 对 RestTemplate 的支持，搭建案例：在父工程 spring_cloud_consul_demo 下，创建子工程 eureka_service（子模块）。搭建 EurekaServer 注册中心。

1、搭建 EurekaServer 注册中心，使用 Eureka 的步骤：

1）搭建 EurekaServer， 创建工程，导入依赖坐标，配置 application.yml 文件，配置启动类。

2）将服务提供者注册到 EurekaServer

3）服务消费者通过注册中心获取服务列表，并调用。

2、在父工程 spring_cloud_consul_demo 下，创建子工程（子模块）eureka_service

--> 右键 spring_cloud_demo 父工程--> Modules --> Maven --> Groupld : ( djh.it )Artifactld : ( eureka_service )Version : 1.0-SNAPSHOT--> Next --> Module name: ( eureka_service )Content root : ( spring_cloud_demo\eureka_service )Module file location: ( spring_cloud_demo\eureka_service )--> Finish

3、在注册中心子工程 eureka_service 的 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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>spring_cloud_consul_demo</artifactId><groupId>djh.it</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>eureka_service</artifactId><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency></dependencies></project>
<!-- spring_cloud_sonsul_demo\eureka_service\pom.xml -->

4、在注册中心子工程 eureka_service 子模块中，创建配置文件 application.yml


##  spring_cloud_sonsul_demo\eureka_service\src\main\resources\application.yml# 如果演示 eureka 高可用，可以模拟两个 EurekaServer, 一个端口 9000，一个端口 8000，两个需要相互注册。server:port: 9000  # 启动端口 命令行注入。spring:application:name: service-eureka  #spring应用名, # 注意 FeignClient 不支持名字带下划线eureka: # 配置 eureka_server
#  instance:
#    hostname: localhostclient:register-with-eureka: false  # 是否将自己注册到注册中心，不配置时，默认 true。 配置高可用时，须注销此行，或配置为 truefetch-registry: false  # 是否从 Eureka 中获取注册信息，不配置时，默认 true。 配置高可用时，须注销此行，或配置为 trueservice-url: # 配置暴露给 EurekaClient 的请求地址
#      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/defaultZone: http://127.0.0.1:9000/eureka/  # 配置高可用时，须配置为另一个 EurekaServerApplication 的端口号，如：8000server:enable-self-preservation: false  # 关闭自我保护机制eviction-interval-timer-in-ms: 4000  # 设置剔除服务间隔时间为 4000 毫秒（4秒）。此参数默认为 true。

5、在注册中心子工程 eureka_service 子模块中，创建 启动类 EurekaServerApplication.java


/***   spring_cloud_sonsul_demo\eureka_service\src\main\java\djh\it\eureka\EurekaServerApplication.java**   2024-4-27  eureka 注册中心，启动类 EurekaServerApplication.java*/package djh.it.eureka;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {public static void main(String[] args) {SpringApplication.run(EurekaServerApplication.class, args);}
}

6、在注册中心子工程 eureka_service 子模块中，运行启动类，进行测试

浏览器地址栏输入：http://localhost:9000 输出界面如下：

在这里插入图片描述

五、Hystrix：基于 RestTemplate 的熔断配置，Hystrix 组件 对 RestTemplate 的支持，

搭建案例：在父工程 spring_cloud_consul_demo 下，创建子工程 product_service（子模块）。

1、在父工程 spring_cloud_consul_demo 下，创建服务提供者 子工程（子模块）product_service。

	--> 右键 spring_cloud_consul_demo 父工程--> Modules --> Maven --> Groupld : ( djh.it )Artifactld : ( product_service )Version : 1.0-SNAPSHOT--> Next --> Module name: ( product_service )Content root : ( D:\java_test\Intesij_idea\spring_cloud_consul_demo\product_service )Module file location: ( D:\java_test\Intesij_idea\spring_cloud_consul_demo\product_service )--> Finish

2、在服务提供者子工程 product_service 模块中的 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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>spring_cloud_consul_demo</artifactId><groupId>djh.it</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>product_service</artifactId><dependencies><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><!--            <version>5.1.32</version>--><version>8.0.26</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><!-- 导入 eureka 注册中心 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!--        &lt;!&ndash; springcloud 提供的对基于 consul 的服务发现 &ndash;&gt;-->
<!--        <dependency>-->
<!--            <groupId>org.springframework.cloud</groupId>-->
<!--            <artifactId>spring-cloud-starter-consul-discovery</artifactId>-->
<!--        </dependency>-->
<!--        &lt;!&ndash; actuator 健康检查 &ndash;&gt;-->
<!--        <dependency>-->
<!--            <groupId>org.springframework.boot</groupId>-->
<!--            <artifactId>spring-boot-starter-actuator</artifactId>-->
<!--        </dependency>--></dependencies></project><!-- spring_cloud_consul_demo\product_service\pom.xml -->

3、在服务提供者子工程 product_service 模块中，创建 商品实体类 Product.java

/***  spring_cloud_consul_demo\product_service\src\main\java\djh\it\product\domain\Product.java**  2024-4-27 商品实体类 Product.java*/
package djh.it.product.domain;import lombok.Data;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.math.BigDecimal;@Data
@Entity
@Table(name="tb_product")  //对应数据库中的数据表
public class Product {@Idprivate Long id;private String productName;private Integer status;private BigDecimal price;private String productDesc;private String caption;private Integer inventory;
}

4、在服务提供者子工程 product_service 模块中，创建 dao 持久层接口类 ProductDao.java


/***   spring_cloud_consul_demo\product_service\src\main\java\djh\it\product\dao\ProductDao.java**  2024-4-27  dao 持久层接口 ProductDao.java*/
package djh.it.product.dao;import djh.it.product.domain.Product;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;public interface ProductDaoextends JpaRepository<Product, Long>, JpaSpecificationExecutor<Product> {}

5、在服务提供者子工程 product_service 模块中，创建 service 服务层 接口类 ProductService.java

/***   spring_cloud_consul_demo\product_service\src\main\java\djh\it\product\service\ProductService.java**  2024-4-27  service 服务层 接口 ProductService.java*/
package djh.it.product.service;import djh.it.product.domain.Product;public interface ProductService {//根据id查询Product findById(Long id);//保存void save(Product product);//更新void update(Product product);//删除void delete(Long id);
}

6、在服务提供者子工程 product_service 模块中，创建 service 服务层 实现类 ProductServiceImpl.java

/***  spring_cloud_consul_demo\product_service\src\main\java\djh\it\product\service\Impl\ProductServiceImpl.java**  2024-4-27  service 服务层 实现类*/
package djh.it.product.service.Impl;import djh.it.product.domain.Product;
import djh.it.product.dao.ProductDao;
import djh.it.product.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class ProductServiceImpl implements ProductService {@Autowiredprivate ProductDao productDao;@Overridepublic Product findById(Long id) {return productDao.findById(id).get();}@Overridepublic void save(Product product) {productDao.save(product);}@Overridepublic void update(Product product) {productDao.save(product);}@Overridepublic void delete(Long id) {productDao.deleteById(id);}
}

7、在服务提供者子工程 product_service 模块中，创建 商品的 controller 类 ProductController.java


/***   spring_cloud_consul_demo\product_service\src\main\java\djh\it\product\controller\ProductController.java**  2024-4-27 商品的 controller 类 ProductController.java*/
package djh.it.product.controller;import djh.it.product.domain.Product;
import djh.it.product.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/product")
public class ProductController {@Autowiredprivate ProductService productService;//获取服务器端口号@Value("${server.port}")private String port;//获取服务器IP地址@Value("${spring.cloud.client.ip-address}")   //springcloud 自动获取当前应用的IP地址private String ip;@RequestMapping(value = "/{id}", method = RequestMethod.GET)public Product findById(@PathVariable Long id){try {Thread.sleep(2000l);     //延迟2秒} catch (InterruptedException e) {e.printStackTrace();}Product product = productService.findById(id);product.setProductName("访问的服务地址："+ip+":"+port);return product;}@RequestMapping(value = "", method = RequestMethod.POST)public String save (@RequestBody Product product){productService.save(product);return "保存成功";}
}

8、在服务提供者子工程 product_service 模块中，创建配置文件 application.yml


##  spring_cloud_consul_demo\product_service\src\main\resources\application.ymlserver:port: 9001  # 启动端口 命令行注入。
#  port: ${port:9001}  # 启动端口设置为动态传参，如果未传参数，默认端口为 9001spring:application:name: service-product  #spring应用名, # 注意 FeignClient 不支持名字带下划线
#  main:
#    allow-bean-definition-overriding: true # SpringBoot2.1 需要设定。datasource:driver-class-name: com.mysql.jdbc.Driver  # mysql 驱动
#    url: jdbc:mysql://localhost:3306/shop?useUnicode=true&characterEncoding=utf8url: jdbc:mysql://localhost:3306/shop?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghaiusername: rootpassword: 12311jpa:database: MySQLshow-sql: trueopen-in-view: trueeureka:  # 配置 Eurekaclient:service-url:defaultZone: http://localhost:9000/eureka/  # 多个 eurekaserver 用 , 隔开。instance:prefer-ip-address: true  # 使用 ip 地址注册#  # 配置 consul 的服务注册
#  cloud:
#    consul:
#      host: 127.0.0.1  # consul 服务器的主机地址
#      port: 8500  # consul 端口
#      discovery:
#        register: true  # 是否需要注册，默认是 false
#        instance-id: ${spring.application.name}-1  # 注册的实例 ID（唯一标志）
#        service-name: ${spring.application.name}  # 服务的名称
#        port: ${server.port}  # 服务的请求端口
#        prefer-ip-address: true  # 指定开启 IP 地址注册
#        ip-address: ${spring.cloud.client.ip-address}  # 当前服务的请求 IP

9、在服务提供者子工程 product_service 模块中，创建 启动类 ProductApplication.java


/***   spring_cloud_consul_demo\product_service\src\main\java\djh\it\product\ProductApplication.java**   2024-4-27  启动类 ProductApplication.java*/
package djh.it.product;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication
@EntityScan("djh.it.product.domain")
@EnableEurekaClient  //激活 EurekaClient 同 @EnableDiscoveryClient 注解
public class ProductApplication {public static void main(String[] args) {SpringApplication.run(ProductApplication.class, args);}
}

10、在服务提供者子工程 product_service 模块中，运行启动类，进行测试

浏览器地址栏输入：http://localhost:9000

发现多了 service-product 服务，端口号为 9001.

在这里插入图片描述
浏览器地址栏输入：http://localhost:9001/product/1
输出一条 mysql 数据。
在这里插入图片描述

六、Hystrix：基于 RestTemplate 的熔断配置，Hystrix 组件 对 RestTemplate 的支持，搭建案例：在父工程 spring_cloud_consul_demo 下，创建子工程 order_service（子模块）。

1、在父工程 spring_cloud_consul_demo 下，创建 服务消费者 子工程（子模块）order_service

--> 右键 spring_cloud_consul_demo 父工程
--> Modules 
--> Maven 
--> Groupld : ( djh.it )Artifactld : ( order_service )Version : 1.0-SNAPSHOT
--> Next 
--> Module name: ( order_service )Content root : ( spring_cloud_consul_demo\order_service )Module file location: ( spring_cloud_consul_demo\order_service )
--> Finish

2、在服务消费者 order_service 子工程（子模块） 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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>spring_cloud_consul_demo</artifactId><groupId>djh.it</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>order_service</artifactId><dependencies><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><!--            <version>5.1.32</version>--><version>8.0.26</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><!-- 导入 eureka 注册中心 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!-- springcloud 提供的对基于 consul 的服务发现 -->
<!--        <dependency>-->
<!--            <groupId>org.springframework.cloud</groupId>-->
<!--            <artifactId>spring-cloud-starter-consul-discovery</artifactId>-->
<!--        </dependency>-->
<!--        &lt;!&ndash; actuator 健康检查 &ndash;&gt;-->
<!--        <dependency>-->
<!--            <groupId>org.springframework.boot</groupId>-->
<!--            <artifactId>spring-boot-starter-actuator</artifactId>-->
<!--        </dependency>--><!-- springcloud 整合 openFeign --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!-- Hystrix 组件 对 RestTemplate 的支持4步：1）引入 Hystrix 依赖坐标 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency></dependencies>
</project>
<!--  spring_cloud_consul_demo\order_service\pom.xml -->

3、在服务消费者 order_service 子工程（子模块）中，创建配置文件 application.yml


##  spring_cloud_consul_demo\order_service\src\main\resources\application.ymlserver:port: 9002  # 启动端口 命令行注入。
#  port: ${port:9002}  # 启动端口设置为动态传参，如果未传参数，默认端口为 9002spring:application:name: service-order  #spring应用名, # 注意 FeignClient 不支持名字带下划线
#  main:
#    allow-bean-definition-overriding: true # SpringBoot2.1 需要设定。datasource:driver-class-name: com.mysql.jdbc.Driver  # mysql 驱动
#    url: jdbc:mysql://localhost:3306/shop?useUnicode=true&characterEncoding=utf8url: jdbc:mysql://localhost:3306/shop?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghaiusername: rootpassword: 12311jpa:database: MySQLshow-sql: trueopen-in-view: trueeureka:  # 配置 Eurekaclient:service-url:defaultZone: http://localhost:9000/eureka/  # 多个 eurekaserver 用 , 隔开。instance:prefer-ip-address: true  # 使用 ip 地址注册hystrix:  # 配置 hystrix 熔断command:default:execution:isolation:thread:timeoutInMilliseconds: 3000  # 默认的连接超时时间为1秒，若1秒没有返回数据，会自动触发降级逻辑。#  # 配置 consul 的服务注册
#  cloud:
#    consul:
#      host: 127.0.0.1  # consul 服务器的主机地址
#      port: 8500  # consul 端口
#      discovery:
#        register: false  # 是否需要注册，默认是 false
#        instance-id: ${spring.application.name}-1  # 注册的实例 ID（唯一标志）
#        service-name: ${spring.application.name}  # 服务的名称
#        port: ${server.port}  # 服务的请求端口
#        prefer-ip-address: true  # 指定开启 IP 地址注册
#        ip-address: ${spring.cloud.client.ip-address}  # 当前服务的请求 IP

4、在服务消费者 order_service 子工程（子模块）中，创建 商品实体类 Product.java


/***   spring_cloud_demo\order_service\src\main\java\djh\it\order\domain\Product.java**  2024-4-27  商品实体类 Product.java*/
package djh.it.order.domain;import lombok.Data;
import java.math.BigDecimal;@Data
public class Product {private Long id;private String productName;private Integer status;private BigDecimal price;private String productDesc;private String caption;private Integer inventory;
}

5、在服务消费者 order_service 子工程（子模块）中，创建 controller 类 OrderController.java


/***   spring_cloud_consul_demo\order_service\src\main\java\djh\it\order\controller\OrderController.java**  2024-4-27 订单的 controller 类 OrderController.java*/
package djh.it.order.controller;import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import djh.it.order.domain.Product;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;@RestController
@RequestMapping("/order")
public class OrderController {@Autowired  // 注入 restTemplate 对象private RestTemplate restTemplate;/***  Hystrix 组件 对 RestTemplate 的支持4步：4）使用注解配置熔断保护*      fallbackmethod : 配置熔断之后的降级方法* @param id* @return*/@HystrixCommand(fallbackMethod = "orderFallBack")@RequestMapping(value = "/buy/{id}", method = RequestMethod.GET)public Product findById(@PathVariable Long id){Product product = null;//product = restTemplate.getForObject("http://127.0.0.1:9001/product/1", Product.class);product = restTemplate.getForObject("http://service-product/product/1", Product.class);return product;}/***  Hystrix 组件 对 RestTemplate 的支持4步：3）降级方法*   例如：如果访问的 service-product 服务器宕机，就会触发此降级方法* @param id* @return*/public Product orderFallBack(Long id){Product product = new Product();product.setProductName("触发降级方法");return product;}}

6、在服务消费者 order_service 子工程（子模块）中，创建 启动类 OrderApplication.java

/***    spring_cloud_demo\order_service\src\main\java\djh\it\order\OrderApplication.java**   2024-4-27  启动类 OrderApplication.java*/
package djh.it.order;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;@SpringBootApplication
@EntityScan("djh.it.order.domain")
@EnableEurekaClient  //激活 EurekaClient,同 @EnableDiscoveryClient 注解相同。
//@EnableFeignClients  //激活 Feign
@EnableCircuitBreaker  // Hystrix 组件 对 RestTemplate 的支持4步：2）激活 hystrix
public class OrderApplication {@LoadBalanced@Beanpublic RestTemplate restTemplate(){return new RestTemplate();}public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}
}

7、在服务消费者 order_service 子工程（子模块）中，运行启动类，product_service 模块中，运行启动类，eureka_service 模块中，运行启动类，进行测试

1）浏览器地址栏输入：http://127.0.0.1:9000

发现 两个 服务，点击 此服务，端口号分别是 9001.9002。
在这里插入图片描述

2）浏览器地址栏输入：http://127.0.0.1:9001/product/1

正常输出 mysql 数据库的第一条记录：

在这里插入图片描述

3）浏览器地址栏输入：http://127.0.0.1:9002/order/buy/1

正常输出 mysql 数据库的第一条记录。

在这里插入图片描述

4）例如：如果访问的 service-product 服务器宕机，service-order 模块中，就会触发此降级方法。
把 服务提供者 product_service 模块中，启动类停止，再次访问测试，发现触发了降级方法。
浏览器地址栏输入：http://127.0.0.1:9002/order/buy/1
在这里插入图片描述

在这里插入图片描述

上一节链掊请点击：
# 从浅入深 学习 SpringCloud 微服务架构（六）Feign（3）

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/5336.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

kubernetes 之 一键安装prometheus

kubernetes 之 一键安装prometheus

kubernetes上安装prometheus prometheus官网&#xff1a; https://github.com/prometheus-operator/kube-prometheus 按照官网下载对应版本 相对稳定一些 这里我们k8s 是1.28 版本的 相对应的下载 0.13 版本 rootmaster2:~# git clone https://github.com/prometheus-operato…
阅读更多...
《21天学通C++》（第十二章）运算符类型与运算符重载

《21天学通C++》（第十二章）运算符类型与运算符重载

1.为什么要重载运算符&#xff1f; 通过重载运算符&#xff0c;可以将复杂的操作封装成简单的运算符形式&#xff0c;简化代码&#xff0c;提高可读性下面举一个简单的例子 计算两个点的坐标之和。 1.不重载运算符 #include <iostream> using namespace std; class P…
阅读更多...
【重识python day4】

【重识python day4】

列表得方法 list&#xff0c;列表类型&#xff0c;用于存储一些数据的容器&#xff08;有序 & 可修改&#xff09;、 tuple&#xff0c;元组类型&#xff0c;用于存储一些数据的容器&#xff08;有序 & 不可修改&#xff09; 不可变类型&#xff1a;字符串、布尔、整…
阅读更多...
如何编辑K8s中的configmap信息

如何编辑K8s中的configmap信息

1.将k8s中configmap信息映射到本地yaml文件 语法: kubectl get configmap <configmap-name> -n <namespace-name> -o yaml > configmap.yaml 实例&#xff1a; kubectl get configmap kuboard-v3-config -n kuboard -o yaml > configmap.yaml 2.编辑yam…
阅读更多...
消息队列相关汇总

消息队列相关汇总

目录 一、什么是消息队列 二、Kafka怎么避免重复消费 三、RabbitMQ 的消息如何实现路由 四、如何保证RabbitMQ的消息可靠传输 五、如何进⾏消息队列选型 一、什么是消息队列 消息队列 Message Queue&#xff0c;简称 MQ。是一种应用间的通信方式&#xff0c;主要由三个部分…
阅读更多...
GCB | 陆地生态系统C:N:P化学计量对降水变化的响应

GCB | 陆地生态系统C:N:P化学计量对降水变化的响应

西北农林科技大学水保学院上官周平研究员团队在陆地生态系统C:N:P化学计量对降水变化的响应方面取得新进展&#xff0c;并以“C:N:P stoichiometry of plants, soils, and microorganisms: Response to altered precipitation”为题发表在国际生态环境领域著名期刊Global Chang…
阅读更多...
AI发展势头强劲，或许会催生这些职业！

AI发展势头强劲，或许会催生这些职业！

AI&#xff08;人工智能&#xff09;的发展正在并将继续催生多种新的职业&#xff0c;这些职业通常与AI的设计、开发、测试、部署、监管、维护以及与其互动和应用相关。 按照现在AI发展的趋势来看&#xff0c;可预测的一些新兴职业大概有下面这些&#xff1a; 当然以上只是一些…
阅读更多...
初识Electron，创建桌面应用

初识Electron，创建桌面应用

历史小剧场 呜呼&#xff01;古有匈奴犯汉&#xff0c;晋室不纲&#xff0c;铁木夺宋&#xff0c;虏清入关&#xff0c;神舟陆沉二百年有余&#xff0c;中国之见灭于满清初非满人能灭之&#xff0c;能有之也因有汉奸以作虎怅&#xff0c;残同胞媚异种&#xff0c;始有吴三桂洪承…
阅读更多...
中职数字化校园网络建设

中职数字化校园网络建设

中职&#xff08;职校&#xff09;数字化校园的校园网建设立足于职业教育、职业学校的特点&#xff0c;充分注意到信息技术的飞速发展、通信成本的迅速降低的特点。在规划和建设校园网时&#xff0c;遵循以下原则&#xff1a; 采用通用和成熟的技术&#xff1a;采用通用的、成熟…
阅读更多...
Android面试题(持续更新中)

Android面试题(持续更新中)

一、抽象类与接口的区别&#xff1f; 1、抽象类可以提供成员方法的实现细节&#xff0c;而接口中只能存在 public 抽象方法&#xff1b; 2、抽象类中的成员变量可以是各种类型的&#xff0c;而接口中的成员变量只能是 public static final 类型的&#xff1b; 3、接口中不能含有…
阅读更多...
【国产NI替代】NI-9235 10 kS/s/ch，120 Ω四分之一桥应变计，8通道C系列应变/桥输入模块

【国产NI替代】NI-9235 10 kS/s/ch，120 Ω四分之一桥应变计，8通道C系列应变/桥输入模块

10 kS/s/ch&#xff0c;120 Ω四分之一桥应变计&#xff0c;8通道C系列应变/桥输入模块 NI‑9235可同步测量所有通道的动态应变&#xff0c;从而实现了高速同步测量。 该功能对于需要在特定时刻对多个通道进行比较的应用&#xff08;例如冲击测试&#xff09;非常重要。\n\nNI…
阅读更多...
Windows Server 2019/2022 开启

Windows Server 2019/2022 开启

我的环境是Windows Serve 2022 Datacenter, 21H2, 需要使用Hyper-V 与 VMWare Workstation共存&#xff0c;但是在服务器管理器中找不到Windows Hypervisor Platform安装选项。在Win10中是启动关闭Windows功能中&#xff0c;而server中找不到。 解决方法&#xff1a; 以管理员…
阅读更多...
算法入门ABC

算法入门ABC

前言 初学算法时真的觉得这东西晦涩难懂&#xff0c;貌似毫无用处&#xff01;后来的后来&#xff0c;终于渐渐明白搞懂算法背后的核心思想&#xff0c;能让你写出更加优雅的代码。就像一首歌唱的那样&#xff1a;后来&#xff0c;我总算学会了如何去爱&#xff0c;可惜你早已远…
阅读更多...
【漏洞复现】若依druid 未授权访问漏洞

【漏洞复现】若依druid 未授权访问漏洞

0x01 产品简介 若依&#xff08;Ruoyi&#xff09;框架是一款基于Spring Boot、Spring Cloud、OAuth2与JWT鉴权等核心技术的快速开发平台。它支持多种安全框架和持久化框架&#xff0c;并采用前后端分离的模式进行开发&#xff0c;具备高度的灵活性和可扩展性。若依框架提供了…
阅读更多...
C语言指针和数组的一些笔试题

C语言指针和数组的一些笔试题

文章目录 前言一、一维数组二、字符数组-1三、字符数组-2总结 前言 C语言指针和数组的一些笔试题 一、一维数组 #include <stdio.h> int main() {int a[] { 1,2,3,4 };printf("%d\n", sizeof(a));printf("%d\n", sizeof(a 0));printf("%d\n…
阅读更多...
经典网络解读——Efficientnet

经典网络解读——Efficientnet

论文&#xff1a;EfficientNet: Rethinking Model Scaling for Convolutional Neural Networks&#xff08;2019.5&#xff09; 作者&#xff1a;Mingxing Tan, Quoc V. Le 链接&#xff1a;https://arxiv.org/abs/1905.11946 代码&#xff1a;https://github.com/tensorflow/t…
阅读更多...
【笔试训练】day15

【笔试训练】day15

1.平方数 水题直接看代码 代码&#xff1a; #define _CRT_SECURE_NO_WARNINGS 1 #include <iostream> #include<math.h> #include<algorithm> using namespace std; typedef long long ll; int main() {ll x;cin >> x;ll a sqrt(x);if (abs(a * a -…
阅读更多...
git 配置相关

git 配置相关

问题一&#xff1a;ssh-keygen -t ed25519 -C "Gitee SSH Key" 这个命令中的 ed25519 字符是什么意思&#xff1f; ssh-keygen 是一个用于生成SSH密钥的工具&#xff0c;SSH&#xff08;Secure Shell&#xff09;是一种网络协议&#xff0c;用于加密方式远程登录和其…
阅读更多...
Laravel11 路由

Laravel11 路由

基本路由 use Illuminate\Support\Facades\Route;Route::get(/greeting, function () {return Hello World; }); 项目初始自带分组&#xff0c;routes文件夹里有api、auth、console、web四个文件。 api项目是php artisan install:api&#xff0c;routes里没有api.php可以执行…
阅读更多...
2024抖音AI图文带货班：在这个赛道上 乘风破浪 拿到好效果

2024抖音AI图文带货班：在这个赛道上 乘风破浪 拿到好效果

课程目录 1-1.1 AI图文学习指南 1.mp4 2-1.2 图文带货的新机会 1.mp4 3-1.3 2024年优质图文新标准 1.mp4 4-1.4 图文如何避免违规 1.mp4 5-1.5 优质图文模板解析 1.mp4 6-2.1 老号重启 快速破局 1.mp4 7-2.2 新号起号 不走弯路 1.mp4 8-2.3 找准对标 弯道超车 1.mp4 9…
阅读更多...
最新文章

Copyright @ 2022~2023