spring-cloud微服务openfeign

Spring Cloud openfeign对Feign进行了增强,使其支持Spring MVC注解,另外还整合了Ribbon和Nacos,从而使得Feign的使用更加方便

优势,openfeign可以做到使用HTTP请求远程服务时就像洞用本地方法一样的体验,开发者完全感知不到这是远程方法,更感知不到这是个 http请求,它像 Dubbo一样,consumer 直接洞用接口方法调用 povider,,而不需要通过常规的 Htp Client构造请求再解析返回数据。它解决了让开发者调用远程接口就跟调用本地方法一样,无需关注与远程的交互细节,更无需关注分布式环境开发

pom导入依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

在bootstrap.yml中增加OpenFeign对Sentinel的支持,增加feign.sentinel.enabled配置项

server:port: 9001
spring:application:name: consumer # 应用名cloud:nacos:discovery:server-addr: localhost:8848 # nacos服务地址sentinel:transport:port: 8719 # 启动http server,并且该服务与Sentinel仪表板进行交互,使sentinel可以控制应用,若端口占用则8719+1依次扫描dashboard: 127.0.0.1:8080 # 仪表版访问地址
feign:	# 增加对sentinel的支持sentinel:enabled: true

这里说一下如果不加feign.sentinel.enabled=true的配置,那么在@FeignClient中定的fallback属性定义的异常、限流等自定义的处理逻辑不会生效

将FeignClient抽取为独立模块,并且把接口有关的POJO(实体类)、默认的Feign配置都放到这个模块中,提供给所有消费者使用,将其做成公共模块,其他服务只需要依赖该jar包

在主启动类上加入@EnableFeignClients注解,标记为启用OpenFeign,具体如下:

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

假如是分布式项目,将openfeign抽取为一个单独的服务模块时,可能出现我openfeign中的包名和其他模块不一致,可以自己声明FeignClient组件的basePackages设置一下FeignClient的扫描路径。示例如下:

@SpringBootApplication
@EnableDiscoveryClient
//这种方式是精准打击,只拿指定的类
//@EnableFeignClients(clients = {UserDemo.class})
//这种方式会将指定包下的所有东西都拿过来
@EnableFeignClients(basePackages = "com.alibaba.provider.feigns")
public class OrderNacosApplication{public static void main(String[] args) {SpringApplication.run(OrderNacosApplication.class, args);}
}

OpenFeign的超时配置

Ps:OpenFeign早期版本(例如 2020版本以前 )要求服务提供方在1秒内处理业务逻辑并返回响应。如果超过1秒没有返回,OpenFeign会直接报错,不会等待服务执行。随着版本的更新,OpenFeign已经对此做出了调整或优化(例如 2021.0.1)

方法一:修改超时时间:在远程调用方的 application.yml 中配置,指定某个服务提供方的调用超时时间

feign:client:config:product-service: # 服务名connect-timeout: 5000 # 配置指定服务连接超时时间read-timeout: 5000 # 配置指定服务等待超时时间stock-nacos: # 服务名connect-timeout: 5000 # 配置指定服务连接超时时间read-timeout: 5000 # 配置指定服务等待超时时间

在远程调用方的 application.yml 中配置,指定所有服务提供方的调用超时时间

feign:client:config:default: # 所有服务connect-timeout: 5000 # 配置指定服务连接超时时间read-timeout: 5000 # 配置指定服务等待超时时间

方法二;配置类

package com.test.order.config;import feign.Request;
import org.springframework.context.annotation.Bean;/*** @Description:* @Author: xu* @Data: 2024-2024/4/10-21* @Version: V1.0*///@Configuration
//注意: 此处配置@configuration注解就会全局生效,如果想指定对应微服务生效,就不能配置
public class FeignTimeOutConfig {@Beanpublic Request.Options options() {return new Request.Options(5000, 10800);}
}

OpenFeign日志有以下几个级别

  • NONE:无记录,默认的
  • BASIC:只记录请求方法和url及响应状态代码和执行时间
  • HEADERS:只记录基本信息及请求和响应头
  • FULL:记录请求和响应的头文件,正文和元数据,信息最全

方法一:配置文件方式设置OpenFeign日志(要查看openfeign日记设置开启openfeign日记和设置feign配置日记级别缺一不可)(推荐)

#开启 openfeign 日志
logging:level:com.test.order.feign: debug  #这样打印的就只有openfeign的debug日记#全局生效
feign:client:config:default: # 所有服务生效logger-level: FULL
#局部生效
feign:client:config:product-service:  #服务名logger-level: basicstock-nacos:      #服务名logger-level: full

如果配置类设置,配置文件也设置,谁设置全局就是日记级别

方法二:java代码方式设置OpenFeign日志

package com.test.order.config;import feign.Logger;
import org.springframework.context.annotation.Bean;/*** @Description:* @Author: xu* @Data: 2024-2024/4/10-17* @Version: V1.0*/
//@Configuration
//注意: 此处配置@configuration注解就会全局生效,如果想指定对应微服务生效,就不能配置
public class FeignClientConfiguration {@Beanpublic Logger.Level feignLogLevel(){return Logger.Level.FULL;  //一般使用 BASIC 级别,因为太多的日志信息影响效率}
}

在这里插入图片描述

全局设置OpenFeign日志级别(如果FeignClientConfiguration类加了注解@Configuration就无需设置以下的defaultConfiguration 属性)

@EnableFeignClients(defaultConfiguration = FeignClientConfiguration.class) 

指定服务,设置OpenFeign日志级别(如果FeignClientConfiguration类加了注解@Configuration就无需设置以下的configuration 属性)

@FeignClient(value = "stock-nacos",path = "/stock",configuration = {FeignClientConfiguration.class})
public interface StockFeignService {@RequestMapping("/reduce")String reduce();}

Feign 的性能优化:

Feign 的底层客户端实现:

  • URLConnection:默认实现,不支持连接池
  • Apache HttpClient :支持连接池
  • OKHttp:支持连接池

因此优化Feign的性能主要包括:

  • 使用连接池代替默认的URLConnection
  • 日志级别,最好用basic或none
  • 因此使用 HttpClient 或 OKHttp 代替 URLConnection

引入依赖

<!--httpClient的依赖 -->
<dependency><groupId>io.github.openfeign</groupId><artifactId>feign-httpclient</artifactId>
</dependency>

配置连接池

feign:client:config:default: # default全局的配置loggerLevel: BASIC # 日志级别,BASIC就是基本的请求和响应信息 httpclient:enabled: true # 开启feign对HttpClient的支持max-connections: 200 # 最大的连接数max-connections-per-route: 50 # 每个路径的最大连接数

实现负载均衡,OpenFeign也具有负载均衡的功能,多个服务端时,采用对应的算法寻找一个服务端进行请求

具体的添加@LoadBalancerClient注解:在调用服务的Service类上添加@LoadBalancerClient注解,并指定服务名。这样,负载均衡器将根据配置的属性来选择合适的服务实例进行调用。例如

/**
* name:指定调用rest接口所对应的服务名
* path 指定调用rest接口所在的stockController指定的eRequestMapping
* 类上无需添加@Component注解
*/
@FeignClient(value = "stock-nacos", path = "/stock") 
public interface StockFeignService{  @RequestMapping("/reduce")String reduce();
}
package com.test.order.config;import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.RandomLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;public class CustomLoadBalancerConfiguration {@BeanReactorLoadBalancer<ServiceInstance> randomLoadBalancer(Environment environment,LoadBalancerClientFactory loadBalancerClientFactory) {String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);return new RandomLoadBalancer(loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class),name);}}

在你提供的代码示例中,CustomLoadBalancerConfiguration 类并没有标记 @Configuration 注解,但它仍然可以作为一个配置类,并且被 @LoadBalancerClients 注解指定的负载均衡客户端所引用。这是因为 Spring Cloud 在处理 @LoadBalancerClients 注解时会扫描指定的配置类,并且将其中的 @Bean 方法注册为 bean。因此,虽然 CustomLoadBalancerConfiguration 类没有标记 @Configuration 注解,但它仍然被识别为一个配置类,并且其中的 @Bean 方法会被注册为 bean。这样做的好处是,你可以将负载均衡的配置与负载均衡客户端的注册分开,使得代码更加清晰和模块化。

package com.test.order;import com.test.order.config.CustomLoadBalancerConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClient;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClients;
import org.springframework.cloud.openfeign.EnableFeignClients;/*** @Description:* @Author: xu* @Data: 2024-2024/3/29-16* @Version: V1.0*/
@SpringBootApplication
@EnableFeignClients
@LoadBalancerClients({@LoadBalancerClient(value = "stock-nacos", configuration = {CustomLoadBalancerConfiguration.class})})
public class OrderOpenFeignApplication {public static void main(String[] args) {SpringApplication.run(OrderOpenFeignApplication.class, args);}
}

修改契约配置,支持Feign原生的注解(注意:修改契约配置后,OrderFeignService 不再支持springmvc的注解,需要使用Feign原生的注解)

package com.test.order.config;import feign.Contract;
import org.springframework.context.annotation.Bean;/*** @Description:* @Author: xu* @Data: 2024-2024/4/10-21* @Version: V1.0*/@Component不要使用该注解,会变成全局
public class ContractConfig {@Beanpublic Contract feigncontract() {return new Contract.Default();}
}

方法一:局部配置那个服务使用锲约


@FeignClient(value = "stock-nacos", path = "/stock" ,configuration = {ContractConfig.class})
public interface StockFeignService {@RequestLine("GET /reduce")String reduce();}

方法二:配置文件设置指定服务使用锲约

#局部生效
feign:client:config:product-service:logger-level: basicstock-nacos:logger-level: fullcontract: feign.Contract.Default  #指定Feign原生注解契约配置

openfeign拦截器

定义openfeign拦截器继承RequestInterceptor 接口

package com.test.order.interceptor;import feign.RequestInterceptor;
import feign.RequestTemplate;/*** @Description:* @Author: xu* @Data: 2024-2024/4/10-21* @Version: V1.0*/
public class CustomFeignAuthRequestInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate requestTemplate) {System.out.println("openfeign拦截器执行了");requestTemplate.header("token","888");}
}

方法一:使用配置类实现openfeign的拦截器

package com.test.order.config;import com.test.order.interceptor.CustomFeignAuthRequestInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @Description:* @Author: xu* @Data: 2024-2024/4/10-21* @Version: V1.0*/
//@Configuration
//注意: 此处配置@configuration注解就会全局生效,如果想指定对应微服务生效,就不能配置
public class FeignInterceptorConfig {@Beanpublic CustomFeignAuthRequestInterceptor feignAuthRequestInterceptor(){return new CustomFeignAuthRequestInterceptor();}
}

全局设置OpenFeign拦截器(如果FeignClientConfiguration类加了注解@Configuration就无需设置以下的defaultConfiguration 属性)

@EnableFeignClients(defaultConfiguration = FeignInterceptorConfig .class) 

指定服务,设置OpenFeign拦截器(如果FeignInterceptorConfig 类加了注解@Configuration就无需设置以下的configuration 属性)

@FeignClient(value = "stock-nacos",path = "/stock",configuration = {FeignInterceptorConfig .class})
public interface StockFeignService {@RequestMapping("/reduce")String reduce();}

方法二:配置文件的yml实现openfeign的拦截器

feign:client:config:stock-nacos:request-interceptors:- com.test.order.interceptor.CustomFeignAuthRequestInterceptor

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

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

相关文章

自己动手封装axios通用方法并上传至私有npm仓库:详细步骤与实现指南

文章目录 一、构建方法1、api/request.js2、api/requestHandler.js3、api/index.js 二、测试方法1、api/axios.js2、main.js3、app.vue4、vue.config.js5、index.html 三、打包1、配置package.json2、生成库包3、配置发布信息4、发布 四、使用1、安装2、使用 五、维护1、维护和…

M1 Flutter SDK的安装和环境配置

前言 作为iOS 开发&#xff0c;观望了许久的Flutter &#xff0c;还是对它下手了&#xff0c;不是故意要卷&#xff0c;没办法工作需要&#xff01;既然要学Flutter&#xff0c;首先就得配置Flutter的相关环境&#xff0c;由于我的是M1 芯片的电脑&#xff0c;记录下来配置过程…

spring boot 集成 flyway依赖 做数据库迁移,让部署没烦恼

flyway 是一个敏捷工具&#xff0c;用于数据库的移植。采用 Java 开发&#xff0c;支持所有兼容 JDBC 的数据库。 主要用于在你的应用版本不断升级的同时&#xff0c;升级你的数据库结构和里面的数据。 还是直接上代码 第一步&#xff1a; <!-- Flyway 数据库迁移 依赖 他…

python爬虫-------JsonPath(第十九天)

&#x1f388;&#x1f388;作者主页&#xff1a; 喔的嘛呀&#x1f388;&#x1f388; &#x1f388;&#x1f388;所属专栏&#xff1a;python爬虫学习&#x1f388;&#x1f388; ✨✨谢谢大家捧场&#xff0c;祝屏幕前的小伙伴们每天都有好运相伴左右&#xff0c;一定要天天…

【一学就会】(一)C++编译工具链——基于VSCode的CMake、make与g++简单理解与应用示例

目录 一、CMake、make与g 1、名词辨析 2、孰优孰劣 二、应用示例 1、工具类安装与配置 1&#xff09;VSCode安装与配置 2&#xff09;CMake下载与安装 3&#xff09;MinGW-W64下载与安装 A、科学上网法 B、无需科学上网法 4&#xff09;VSCode推荐插件 A、c/c编译环…

Linux/Ubuntu/Debian中与进程和系统资源有关的命令top/ps

top命令是Linux系统中非常实用的一个工具&#xff0c;其主要功能是展示当前系统中资源使用情况最高的进程列表。通过这个命令&#xff0c;我们可以一目了然地看到哪些进程正在消耗大量的CPU、内存等资源。top命令默认每3秒更新一次数据&#xff0c;提供了实时的系统资源状态&am…

【Qt 学习笔记】QWidget的geometry属性及window frame的影响

博客主页&#xff1a;Duck Bro 博客主页系列专栏&#xff1a;Qt 专栏关注博主&#xff0c;后期持续更新系列文章如果有错误感谢请大家批评指出&#xff0c;及时修改感谢大家点赞&#x1f44d;收藏⭐评论✍ QWidget的geometry属性 文章编号&#xff1a;Qt 学习笔记 / 16 文章目…

BK-SDM读图片逻辑-评估结果FID逻辑

以inherit为例 这是借助bksdm的代码用于我的A-sdm的生成 bksdm中2个关键路径是 src/genetate.py script/eval_scores.sh 一 以generate.py文件进行生成 借助ms-coco的csv文件里面的30K个提示词和图片名字&#xff0c;来生成图片&#xff0c;并保存 share/huanggao/zjc/code_i2…

【智能算法】省时方便,智能算法统计指标——一键运行~

目录 1.常用统计指标2.参数统计检验3.结果展示4.自定义修改测试框架 1.常用统计指标 测试智能算法性能时&#xff0c;常常会用到以下5种常用指标&#xff0c;简单不赘述&#xff1a; 最优值、最差值、均值、中位数、标准差 2.参数统计检验 单纯依靠常用统计指标说服力不足&…

07 Php学习:运算符

PHP 算术运算符 在 PHP 中&#xff0c;算术运算符用于执行基本的数学运算&#xff0c;包括加法、减法、乘法、除法、取余数&#xff0c;负数运算、取反和并置运算。以下是这些运算符的详细解释和示例&#xff1a; 加法运算符 &#xff1a;用于将两个数值相加。 $a 5; $b 3;…

初识--数据结构

什么是数据结构&#xff1f;我们为什么要学习数据结构呢....一系列的问题就促使我们不得不了解数据结构。我们不禁要问了&#xff0c;学习C语言不就够了吗&#xff1f;为什么还要学习数据结构呢&#xff1f;这是因为&#xff1a;数据结构能够解决C语言解决不了的问题&#xff0…

【Java基础题型】矩阵的对角线求和

一、题目-矩阵 求一个33矩阵对角线元素之和。 输入格式 矩阵 输出格式 主对角线 副对角线 元素和 样例输入 1 2 3 1 1 1 3 2 1 样例输出 3 7 二、参考的知识 这里给大家送点英语单词&#xff0c;记得学习&#xff1a; p r i m a r y. adj.主要的&#xff1b;初…

软考中级之软件设计师---知识点汇总总结

软考中级之软件设计师---知识点汇总总结 软考介绍资格设置证书样本 计算机组成原理操作系统1. 进程的三态模型2. 磁盘调度算法 计算机网络1. 网络的分类2. 各层的互连设备3. 网络模型&#xff0c;协议簇4. 传输层协议TCP、UDP4.1 TCP (Transmission Control Protocol,传输控制协…

day77 JSPServlet

知识点&#xff1a; 1Web工程 2JSP是什么&#xff1f;JSP页面包含哪些内容&#xff1f;JSP页面执行原理 3JSP九大内置对象&#xff0c;及四个作用域 4什么是SERVLET&#xff1f;及servlet相关API 5MVC模型 6EL表达式及JSTL标签库的使用 7在JSP页面实现分页和多条件查询 …

【UE5 C++】访问修饰符public/protected/private继承

限制类与类之间访问级别的方法 public 在类中创建一个public的部分&#xff0c;即" public: "&#xff0c;public之下的所有内容都是公共的,可以在类之间访问 private&#xff08;最常见&#xff09; 如若没有指明修饰符&#xff0c;则默认为private 不能在类的外…

【LAMMPS学习】七、加速性能(4)加速器包

7. 加速性能 7.1.基准测试 7.2.测试性能 7.3.通用技巧 7.4.加速器包 LAMMPS 中添加了各种pair_style、fixes、compute 和其他命令的加速版本&#xff0c;其运行速度通常比标准非加速版本更快。有些需要您的系统上存在适当的硬件&#xff0c;例如GPU 或 Intel Xeon Phi 协处…

每日OJ题_BFS解决FloodFill②_力扣200. 岛屿数量

目录 力扣200. 岛屿数量 解析代码 力扣200. 岛屿数量 200. 岛屿数量 难度 中等 给你一个由 1&#xff08;陆地&#xff09;和 0&#xff08;水&#xff09;组成的的二维网格&#xff0c;请你计算网格中岛屿的数量。 岛屿总是被水包围&#xff0c;并且每座岛屿只能由水平方…

聊聊自己12岁车龄的福克斯

1. 2005年&#xff0c;国内进入了 福克斯 ( 参数 | 询价 ) 这台车&#xff0c;中间经历了两次换代&#xff0c;而我自己的这台车则是第一批进入国内的福克斯&#xff0c;它的到来颠覆了大家当时对汽车设计的印象&#xff0c;在十年前家用车都是捷达、桑塔纳等那些古板油腻的车…

全球变暖蓝桥杯2018省赛真题

全球变暖蓝桥杯2018省赛真题 DFS大法 全球变暖 #include <bits/stdc.h> using namespace std; #define int long long bool flag; char a[1010][1010]; int cnt,n,ans0,pre_ans0,d[4][2] {1,0,-1,0,0,1,0,-1}; void dfs(int x,int y){if(x>n||x<0||y>n||y<…

德勤:《中国AI智算产业2024年四大趋势》

2023年《数字中国建设整体布局规划》的发布&#xff0c;明确了数字中国是构建数字时代竞争优势的关键支撑&#xff0c;是继移动互联网时代以来经济增长新引擎。当我们谈论数字中国的构建&#xff0c;不仅仅是在讨论一个国家级的技术升级&#xff0c;而是关乎如何利用数字技术来…