当前位置： 首页 > news >正文

四、搭建springCloudAlibaba2021.1版本分布式微服务-加入openFeign远程调用和sentinel流量控制

news 2025/7/28 5:41:33

OpenFeign远程调用

1、OpenFeign

OpenFeign是一种声明式、模板化的HTTP客户端。在Spring Cloud中使用OpenFeign，可以做到使用HTTP请求访问远程服务，就像调用本地方法一样的，开发者完全感知不到这是在调用远程方法，更感知不到在访问HTTP请求。

2、Feign与OpenFeign的区别

Feign是Spring Cloud组件中一个轻量级RESTful的HTTP服务客户端，Feign内置了Ribbon，用来做客户端负载均衡，去调用服务注册中心的服务。Feign的使用方式是：使用Feign的注解定义接口，调用接口，就可以调用服务注册中心的服务。

OpenFeign是Spring Cloud在Feign的基础上支持了SpringMVC的注解，如@RequestMapping等等。OpenFeign的@FeignClient可以解析SpringMVC的@RequestMapping注解下的接口，并通过动态代理的方式产生实现类，实现类中做负载均衡并调用其他服务。

说明：springcloud F 及F版本以上 springboot 2.0 以上基本上使用openfeign，openfeign 如果从框架结构上看就是2019年feign停更后出现版本，也可以说大多数新项目都用openfeign ，2018年以前的项目在使用 feign。

Sentinel流量控制

1、Sentinel简介

Sentinel是阿里开源的项目，提供了流量控制、熔断降级、系统负载保护等多个维度来保障服务之间的稳定性。

官网：https://github.com/alibaba/Sentinel/wiki

Sentinel主要特性：

2、Sentinel与Hystrix的区别


关于Sentinel与Hystrix的区别见：https://yq.aliyun.com/articles/633786/

总体来说：

Hystrix常用的线程池隔离会造成线程上下切换的overhead比较大；Hystrix使用的信号量隔离对某个资源调用的并发数进行控制，效果不错，但是无法对慢调用进行自动降级；Sentinel通过并发线程数的流量控制提供信号量隔离的功能；

此外，Sentinel支持的熔断降级维度更多，可对多种指标进行流控、熔断，且提供了实时监控和控制面板，功能更为强大。

Sentinel 的所有规则都可以在内存态中动态地查询及修改，修改之后立即生效。同时 Sentinel 也提供相关 API，供您来定制自己的规则策略。

Sentinel 支持以下几种规则：流量控制规则、熔断降级规则、系统保护规则、来源访问控制规则 和 热点参数规则。

openFeign整合Sentinel

第一个项目 spring-cloud-alibaba-2021-user（调用者）

创建项目名为 spring-cloud-alibaba-2021-user

<?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-alibaba-2021</artifactId><groupId>org.example</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>spring-cloud-alibaba-2021-user</artifactId><dependencies><!-- springweb 启动依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- nacos 服务注册发现（客户端）依赖 --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- nacos-config 配置中心依赖 --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency><!--spring-cloud-dependencies 2020.0.0 版本不在默认加载bootstrap.yml 文件，如果需要加载bootstrap 文件需要手动添加依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId></dependency><!--openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!--loadbalancer ，负载均衡，用来替代ribbon的组件 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><!-- sentinel流量控制，必须加上后降级和限流才会生效--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency></dependencies>
</project>

application.yml 内容如下

server:port: 8089
spring:# 后面的bean会覆盖前面相同名称的beanmain:allow-bean-definition-overriding: true# 激活Sentinel对Feign的支持，默认为false。必须设为true后sentinel降级才会生效
feign:sentinel:enabled: true

bootstrap.yml 内容如下，bootstrap.yml 文件比 application.yml 先加载，主要用于存放一些不会改变的配置，application.yml 存放一些经常需要改动的配置；

spring:application:name: user-demoprofiles:active: yexindong_activecloud:nacos:discovery:server-addr: chn520.cn:8848 # 服务注册中心地址namespace: public # 注册到nacos的名称空间，默认为publicconfig:prefix: yexindong_nacos_prefixfile-extension: yaml  # 指定yaml格式的配置, 必须要放到bootstrao.yml 才会生效，放到application下不会生效server-addr: chn520.cn:8848 #配置中心地址group: DEFAULT_GROUP

父项目的 pom.xml 文件加入modules

   <modules><module>spring-cloud-alibaba-2021-user</module></modules>

新建启动类 UserApp.java

package com.alibaba.cloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients  // // 开启feign远程调用
public class UserApp {public static void main(String[] args) {SpringApplication.run(UserApp.class, args);}
}

新建controller层 UserController.java

package com.alibaba.cloud.controller;import com.alibaba.cloud.feign.OrderClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RefreshScope // 不重启即可刷新 nacos配置
@RequestMapping("/user")
public class UserController {// 调用order远程服务@RequestMapping("/getOrder")public String getOrder(){return orderClient.getOrderById();}
}

远程调用接口 OrderClient.java

package com.alibaba.cloud.feign;import com.alibaba.cloud.feign.fallback.OrderFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;/*** value : 其他远程服务的名称，对应配置文件的 spring.application.name 值* name： 和value功能一样* path ： url前缀，和 @RequestMapping 注解功能类似* fallback ： 降级回调的实现类，当被调服务不可用、发生异常或者超时会直接走降级逻辑，返回友好提示*/
@FeignClient(value="order-demo",path = "order",fallback = OrderFallback.class)
public interface OrderClient {@GetMapping("/getOrderById")String getOrderById();
}

添加降级回调类 OrderFallback.java

package com.alibaba.cloud.feign.fallback;import com.alibaba.cloud.feign.OrderClient;
import org.springframework.stereotype.Component;/*** 降级回调类*/
@Component
public class OrderFallback implements OrderClient {public String getOrderById() {return "order服务暂时不可用！！！";}
}

此时 项目结构如下

创建第二个项目 spring-cloud-alibaba-2021-order （被调者）

新建工程，起名为 spring-cloud-alibaba-2021-order

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-alibaba-2021</artifactId><groupId>org.example</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>spring-cloud-alibaba-2021-order</artifactId><dependencies><!-- springweb 启动依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- nacos 服务注册发现（客户端）依赖 --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- nacos-config 配置中心依赖 --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency><!--spring-cloud-dependencies 2020.0.0 版本不在默认加载bootstrap.yml 文件，如果需要加载bootstrap 文件需要手动添加依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId></dependency><!--openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!--loadbalancer ，负载均衡，用来替代ribbon的组件 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency></dependencies>
</project>

application.yml 内容如下

server:port: 8088
spring:# 后面的bean会覆盖前面相同名称的beanmain:allow-bean-definition-overriding: true

bootstrap.yml 内容如下

spring:application:name: order-demoprofiles:active: yexindong_activecloud:nacos:discovery:server-addr: chn520.cn:8848 # 服务注册中心地址namespace: public # 注册到nacos的名称空间，默认为publicconfig:prefix: yexindong_nacos_prefixfile-extension: yaml  # 指定yaml格式的配置, 必须要放到bootstrao.yml 才会生效，放到application下不会生效server-addr: chn520.cn:8848 #配置中心地址group: DEFAULT_GROUP

启动类 OrderApp.java 内容如下

package com.alibaba.cloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients  // // 开启feign远程调用
public class OrderApp {public static void main(String[] args) {SpringApplication.run(OrderApp.class, args);}
}

controller层 OrderController.java 内容如下

package com.alibaba.cloud.controller;import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RefreshScope // 不重启即可刷新 nacos配置
@RequestMapping("/order")
public class OrderController {@Value("${cache:default}")private String cache;@RequestMapping("/getOrderById")public String getOrderById(){return "yexindong order" + cache;}
}

此时项目结构如下

修改 nacos 配置，添加 yexindong_nacos_prefix-yexindong_active.yaml文件
此时会打开新建配置的页面，

  1. DataId 输入：yexindong_nacos_prefix-yexindong_active.yaml
  2. 配置格式 选择： YAML
  3. 配置内容 中输入：cache: hello openFeign sentinal!!! `
  4. 点击 右下角的 发布 按钮

测试

启动 OrderApp.java 和 UserApp.java 中的main方法，一会后发现这2个服务已经注册到nacos了

在浏览器输入 http://localhost:8089/user/getOrder，可以正常访问

测试熔断降级

接下来我们修改一下OrderController.java中的 getOrderById() 方法，增加一行代码，System.out.println(1/0); 让程序在运行中抛出异常，修改后的内容如下

    @RequestMapping("/getOrderById")public String getOrderById(){System.out.println(1/0);return "yexindong order" + cache;}

然后重启 orderApp ,再次访问 http://localhost:8089/user/getOrder，发现已经出发了熔断，返回了falllback 的友好提示

配置 openFeign 日志

有时候我们遇到bug，接口调用失败、参数没收到等问题，或者想看看调用性能，就需要配置OpenFeignde的日志了，以此让openFeign把请求信息输出来。

OpenFeign提供了日志打印功能，我们可以通过配置来调整日恙级别，从而了解Feign 中 Http请求的细节。

日志级别

  • NONE：默认的，不显示任何日志；
  • BASIC：仅记录请求方法、URL、响应状态码及执行时间；
  • HEADERS：除了BASIC中定义的信息之外，还有请求和响应的头信息；
  • FULL：除了HEADERS中定义的信息之外，还有请求和响应的正文及元数据；
全局配置

添加 OpenFeignConfig.java 文件，内容如下

package com.alibaba.cloud.config;
import feign.Logger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 全局配置：当使用@Configuration 会将配置作用所有的服务提供方* 局部配置：如果只想针对某一个服务进行配置，就不要加@Configuration*/
@Configuration
public class OpenFeignConfig {/*日志级别:NONE：默认的，不显示任何日志；BASIC：仅记录请求方法、URL、响应状态码及执行时间；HEADERS：除了BASIC中定义的信息之外，还有请求和响应的头信息；FULL：除了HEADERS中定义的信息之外，还有请求和响应的正文及元数据；*/@Beanpublic Logger.Level feignLoggerLevel(){return Logger.Level.FULL;}
}

application.yml加上以下配置

#  openfeign配置包下（或指定哪些业务接口）以什么日志级别监听，springboot的默认日志级别是info，openFeign的日志级别debug就不会输出，所以需要加上此配置
logging:level:com:alibaba:cloud:feign: debug

重新请求后就可以在控制台打印日志了；

局部配置：方式一

直接在接口上指定，在@FeignClient注解加上configuration = OpenFeignConfig.class属性

package com.alibaba.cloud.feign;import com.alibaba.cloud.feign.fallback.OrderFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;/*** value : 其他远程服务的名称，对应配置文件的 spring.application.name 值* name： 和value功能一样* path ： url前缀，和 @RequestMapping 注解功能类似* fallback ： 降级回调的实现类，当被调服务不可用、发生异常或者超时会直接走降级逻辑，返回友好提示*/
@FeignClient(value="order-demo",path = "order",fallback = OrderFallback.class,configuration = OpenFeignConfig.class)
public interface OrderClient {@GetMapping("/getOrderById")String getOrderById();
}

注意：这种方式需要将OpenFeignConfig.java类的@Configuration注解去掉，否则会变成全局配置

局部配置：方式二

application.yml 添加以下配置

# openfeign日志局部配置
feign:client:config:order-demo:loggerLevel: basic

超时时间配置

方式一：添加配置类

创建配置类 OpenFeignTimeOutConfig.java，内容如下

package com.alibaba.cloud.config;import feign.Request;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class OpenFeignTimeOutConfig {/*** 超时时间配置* @return*/@Beanpublic Request.Options options(){// Options 的第一个参数是连接的超时时间（ms），默认值是 2s；第二个是请求处理的超时时间（ms），默认值是 5s。return new Request.Options(5000,10000);}
}
方式二：配置文件修改

application.yml 添加配置

feign:client:config:order-demo:# 配置指定服务连接超时（单位：ms）connectTimeout: 5000# 配置指定服务等待超时（单位：ms）readTimeout: 5000default:# 配置所有服务的连接超时时间（单位：ms）connectTimeout: 5000# 配置所有服务的等待超时时间（单位：ms）readTimeout: 5000

自定义拦截器

全局配置

添加拦截器类CustomFeignInterceptor.java

package com.alibaba.cloud.interceptor;import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.springframework.context.annotation.Configuration;/*** 自定义feign拦截器*/
@Configuration
public class CustomFeignInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate requestTemplate) {System.out.println("执行openFeign自定义拦截器");}
}
局部配置

如果写在配置文件中指明了服务，则为具体的服务指定一个或者多个拦截器, 在 application.yml 加入以下内容

# 在配置文件中设置feign拦截器
feign:client:config:order-demo:# openFeign拦截器requestInterceptors[0]: com.alibaba.cloud.interceptor.CustomFeignInterceptor

再次请求http://127.0.0.1:8089/user/getOrder发现已经打印了拦截器的内容

完

http://www.lryc.cn/news/601168.html

相关文章：

  • UNet 改进(38)：融合多尺度输入与可变形卷积、门控特征融合的医学图像Unet分割网络
  • MySQL 事务和锁
  • 02人工智能中优雅草商业实战项目视频字幕翻译以及声音转译之以三方AI模型API制作方式预算-卓伊凡|莉莉
  • 车载诊断架构 ---面向售后的DTC应该怎么样填写？
  • KNN算法实战：手写数字识别详解
  • 前端基础班学习路线
  • Git+宝塔面板部署Hugo博客
  • net8.0一键创建辅助开发的个人小工具
  • 剑指offer第2版：双指针+排序+分治+滑动窗口
  • 零基础学习性能测试第五章：JVM性能分析与调优-GC垃圾分代回收机制与优化
  • 【嵌入式硬件实例】-555定时器调光电路实现
  • 工业控制系统安全之 Modbus 协议中间人攻击（MITM）分析与防范
  • DAY21-二叉树的遍历方式
  • 数据结构 堆(4)---TOP-K问题
  • Canvas实现微信小程序图片裁剪组件全攻略
  • mmap的调用层级与内核态陷入全过程
  • 六、搭建springCloudAlibaba2021.1版本分布式微服务-admin监控中心
  • 记录一次薛定谔bug
  • 基于LNMP架构的分布式个人博客搭建
  • Java大数据面试实战：Hadoop生态与分布式计算
  • 数据权属雷区：原始数据与衍生数据的法律边界如何划清？
  • AI与区块链Web3技术融合：重塑数字经济的未来格局
  • ROS2入门到精通教程（三）快速体验
  • Linux vimgrep 详解
  • VGG 改进：融合CNN与Transformer的VGG模型
  • vmware虚拟机中显示“网络电缆被拔出“的解决方法
  • 【面板数据】中国A股上市公司制造业智能制造数据集（1992-2024年）
  • 从稀疏数据（CSV）创建非常大的 GeoTIFF（和 WMS）
  • 【温度传感器】热电偶、热敏电阻、热电阻、热成像仪原理及精度解析
  • 立式加工中心X-Y轴传动机械结构设“cad【6张】三维图＋设计说明书