Spring Cloud Feign的自定义配置及使用

news2024/9/21 22:47:27

Feign 提供了很多的扩展机制,让用户可以更加灵活的使用,这节我们来学习 Feign 的一些自定义配置。

日志配置

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

首先定义一个配置类,代码如下所示。

  1. @Configuration
  2. public class FeignConfiguration {
  3. /**
  4. * 日志级别
  5. *
  6. * @return
  7. */
  8. @Bean
  9. Logger.Level feignLoggerLevel() {
  10. return Logger.Level.FULL;
  11. }
  12. }

通过源码可以看到日志等级有 4 种,分别是:

  • NONE:不输出日志。
  • BASIC:只输出请求方法的 URL 和响应的状态码以及接口执行的时间。
  • HEADERS:将 BASIC 信息和请求头信息输出。
  • FULL:输出完整的请求信息。

Feign 日志等级源码如下图所示:

  1. public enum Level {
  2. NONE,
  3. BASIC,
  4. HEADERS,
  5. FULL
  6. }

配置类建好后,我们需要在 Feign Client 中的 @FeignClient 注解中指定使用的配置类,代码如下所示。

  1. @FeignClient(value = "eureka-client-user-service", configuration = FeignConfiguration. class)
  2. public interface UserRemoteClient {
  3. // ...
  4. }

在配置文件中执行 Client 的日志级别才能正常输出日志,格式是“logging.level.client 类地址=级别”。

  1. logging.level.net.biancheng.feign_demo.remote.UserRemoteClient=DEBUG

最后通过 Feign 调用我们的 /user/hello 接口,就可以看到控制台输出的调用信息了,如图 1 所示。


图 1 调用信息

契约配置

Spring Cloud 在 Feign 的基础上做了扩展,可以让 Feign 支持 Spring MVC 的注解来调用。原生的 Feign 是不支持 Spring MVC 注解的,原生的使用方法我们在后面会讲解。

如果你想在 Spring Cloud 中使用原生的注解方式来定义客户端也是可以的,通过配置契约来改变这个配置,Spring Cloud 中默认的是 SpringMvcContract,代码如下所示。

  1. @Configuration
  2. public class FeignConfiguration {
  3. @Bean
  4. public Contract feignContract() {
  5. return new feign.Contract.Default();
  6. }
  7. }

当你配置使用默认的契约后,之前定义的 Client 就用不了,之前上面的注解是 Spring MVC 的注解。

Basic 认证配置

通常我们调用的接口都是有权限控制的,很多时候可能认证的值是通过参数去传递的,还有就是通过请求头去传递认证信息,比如 Basic 认证方式。在 Feign 中我们可以直接配置 Basic 认证,代码如下所示。

  1. @Configuration
  2. public class FeignConfiguration {
  3. @Bean
  4. public BasicAuthRequestInterceptor basicAuthRequestInterceptor() {
  5. return new BasicAuthRequestInterceptor("user", "password");
  6. }
  7. }

或者你可以自定义属于自己的认证方式,其实就是自定义一个请求拦截器。在请求之前做认证操作,然后往请求头中设置认证之后的信息。通过实现 RequestInterceptor 接口来自定义认证方式,代码如下所示。

  1. public class FeignBasicAuthRequestInterceptor implements RequestInterceptor {
  2. public FeignBasicAuthRequestInterceptor() {
  3. }
  4. @Override
  5. public void apply(RequestTemplate template) {
  6. // 业务逻辑
  7. }
  8. }

然后将配置改成我们自定义的就可以了,这样当 Feign 去请求接口的时候,每次请求之前都会进入 FeignBasicAuthRequestInterceptor 的 apply 方法中,在里面就可以做属于你的逻辑了,代码如下所示。

  1. @Configuration
  2. public class FeignConfiguration {
  3. @Bean
  4. public FeignBasicAuthRequestInterceptor basicAuthRequestInterceptor() {
  5. return new FeignBasicAuthRequestInterceptor();
  6. }
  7. }

超时时间配置

通过 Options 可以配置连接超时时间和读取超时时间(代码如下所示),Options 的第一个参数是连接超时时间(ms),默认值是 10×1000;第二个是取超时时间(ms),默认值是 60×1000。

  1. @Configuration
  2. public class FeignConfiguration {
  3. @Bean
  4. public Request.Options options() {
  5. return new Request.Options(5000, 10000);
  6. }
  7. }

客户端组件配置

Feign 中默认使用 JDK 原生的 URLConnection 发送 HTTP 请求,我们可以集成别的组件来替换掉 URLConnection,比如 Apache HttpClient,OkHttp。

配置 OkHttp 只需要加入 OkHttp 的依赖,代码如下所示。

  1. <dependency>
  2. <groupId>io.github.openfeign</groupId>
  3. <artifactId>feign-okhttp</artifactId>
  4. </dependency>

然后修改配置,将 Feign 的 HttpClient 禁用,启用 OkHttp,配置如下:

  1. #feign 使用 okhttp
  2. feign.httpclient.enabled=false
  3. feign.okhttp.enabled=true

关于配置可参考源码 org.springframework.cloud.openfeign.FeignAutoConfiguration。
HttpClient 自动配置源码如下所示:

  1. @Configuration
  2. @ConditionalOnClass(ApacheHttpClient.class)
  3. @ConditionalOnMissingClass("com.netflix.loadbalancer.ILoadBalancer")
  4. @ConditionalOnProperty(value = "feign.httpclient.enabled", matchIfMissing = true)
  5. protected static class HttpClientFeignConfiguration {
  6. @Autowired(required = false)
  7. private HttpClient httpClient;
  8. @Bean
  9. @ConditionalOnMissingBean(Client.class)
  10. public Client feignClient() {
  11. if (this.httpClient != null) {
  12. return new ApacheHttpClient(this.httpClient);
  13. }
  14. return new ApacheHttpClient();
  15. }
  16. }

OkHttp 自动配置源码如下所示:

  1. @Configuration
  2. @ConditionalOnClass(OkHttpClient.class)
  3. @ConditionalOnMissingClass("com.netflix.loadbalancer.ILoadBalancer")
  4. @ConditionalOnProperty(value = "feign.okhttp.enabled", matchIfMissing = true)
  5. protected static class OkHttpFeignConfiguration {
  6. @Autowired(required = false)
  7. private okhttp3.OkHttpClient okHttpClient;
  8. @Bean
  9. @ConditionalOnMissingBean(Client.class)
  10. public Client feignClient() {
  11. if (this.okHttpClient != null) {
  12. return new OkHttpClient(this.okHttpClient);
  13. }
  14. return new OkHttpClient();
  15. }
  16. }

上面所示两段代码分别是配置 HttpClient 和 OkHttp 的方法。其通过 @ConditionalOnProperty 中的值来决定启用哪种客户端(HttpClient 和 OkHttp),@ConditionalOnClass 表示对应的类在 classpath 目录下存在时,才会去解析对应的配置文件。

GZIP 压缩配置

开启压缩可以有效节约网络资源,提升接口性能,我们可以配置 GZIP 来压缩数据:

  1. feign.compression.request.enabled=true
  2. feign.compression.response.enabled=true

还可以配置压缩的类型、最小压缩值的标准:

  1. feign.compression.request.mime-types=text/xml,application/xml,application/json
  2. feign.compression.request.min-request-size=2048

只有当 Feign 的 Http Client 不是 okhttp3 的时候,压缩才会生效,配置源码在 org.spring-framework.cloud.openfeign.encoding.FeignAcceptGzipEncodingAutoConfiguration,代码如下所示。

  1. @Configuration
  2. @EnableConfigurationProperties(FeignClientEncodingProperties.class)
  3. @ConditionalOnClass(Feign.class)
  4. @ConditionalOnBean(Client.class)
  5. @ConditionalOnProperty(value = "feign.compression.response.enabled", matchIfMissing = false)
  6. @ConditionalOnMissingBean(type = "okhttp3.OkHttpClient")
  7. @AutoConfigureAfter(FeignAutoConfiguration.class)
  8. public class FeignAcceptGzipEncodingAutoConfiguration {
  9. @Bean
  10. public FeignAcceptGzipEncodingInterceptor feignAcceptGzipEncodingInterceptor(
  11. FeignClientEncodingProperties properties) {
  12. return new FeignAcceptGzipEncodingInterceptor(properties);
  13. }
  14. }

核心代码就是 @ConditionalOnMissingBean(type=”okhttp3.OkHttpClient”),表示 Spring BeanFactory 中不包含指定的 bean 时条件匹配,也就是没有启用 okhttp3 时才会进行压缩配置。

编码器解码器配置

Feign 中提供了自定义的编码解码器设置,同时也提供了多种编码器的实现,比如 Gson、Jaxb、Jackson。我们可以用不同的编码解码器来处理数据的传输。如果你想传输 XML 格式的数据,可以自定义 XML 编码解码器来实现获取使用官方提供的 Jaxb。

配置编码解码器只需要在 Feign 的配置类中注册 Decoder 和 Encoder 这两个类即可,代码如下所示。

  1. @Bean
  2. public Decoder decoder() {
  3. return new MyDecoder();
  4. }
  5. @Bean
  6. public Encoder encoder() {
  7. return new MyEncoder();
  8. }

使用配置自定义 Feign 的配置

除了使用代码的方式来对 Feign 进行配置,我们还可以通过配置文件的方式来指定 Feign 的配置。

  1. # 链接超时时间
  2. feign.client.config.feignName.connectTimeout=5000
  3. # 读取超时时间
  4. feign.client.config.feignName.readTimeout=5000
  5. # 日志等级
  6. feign.client.config.feignName.loggerLevel=full
  7. # 重试
  8. feign.client.config.feignName.retryer=com.example.SimpleRetryer
  9. # 拦截器
  10. feign.client.config.feignName.requestInterceptors[0]=com.example.FooRequestInterceptor
  11. feign.client.config.feignName.requestInterceptors[1]=com.example.BarRequestInterceptor
  12. # 编码器
  13. feign.client.config.feignName.encoder=com.example.SimpleEncoder
  14. # 解码器
  15. feign.client.config.feignName.decoder=com.example.SimpleDecoder
  16. # 契约
  17. feign.client.config.feignName.contract=com.example.SimpleContract

继承特性

Feign 的继承特性可以让服务的接口定义单独抽出来,作为公共的依赖,以方便使用。

创建一个 Maven 项目 feign-inherit-api,用于存放 API 接口的定义,增加 Feign 的依赖,代码如下所示。

  1. <dependency>
  2. <groupId>org.springframework.cloud</groupId>
  3. <artifactId>spring-cloud-starter-openfeign</artifactId>
  4. </dependency>

定义接口,指定服务名称,代码如下所示。

  1. @FeignClient("feign-inherit-provide")
  2. public interface UserRemoteClient {
  3. @GetMapping("/user/name")
  4. String getName();
  5. }

创建一个服务提供者 feign-inherit-provide,引入 feign-inherit-api,代码如下所示。

  1. <dependency>
  2. <groupId>net.biancheng</groupId>
  3. <artifactId>feign-inherit-api</artifactId>
  4. <version>0.0.1-SNAPSHOT</version>
  5. </dependency>

实现 UserRemoteClient 接口,代码如下所示。

  1. @RestController
  2. public class DemoController implements UserRemoteClient {
  3. @Override
  4. public String getName() {
  5. return "zhangsan";
  6. }
  7. }

创建一个服务消费者 feign-inherit-consume,同样需要引入 feign-inherit-api 用于调用 feign-inherit-provide 提供的 /user/name 接口,代码如下所示。

  1. @RestController
  2. public class DemoController {
  3. @Autowired
  4. private UserRemoteClient userRemoteClient;
  5. @GetMapping("/call")
  6. public String callHello() {
  7. String result = userRemoteClient.getName();
  8. System.out.println("getName调用结果:" + result);
  9. }
  10. }

通过将接口的定义单独抽出来,服务提供方去实现接口,服务消费方直接就可以引入定义好的接口进行调用,非常方便。

多参数请求构造

多参数请求构造分为 GET 请求和 POST 请求两种方式,首先来看 GET 请求的多参数请求构造方式,代码如下所示。

  1. @GetMapping("/user/info")
  2. String getUserInfo(@RequestParam("name")String name,@RequestParam("age")int age);

另一种是通过 Map 来传递多个参数,参数数量可以动态改变,笔者在这里还是推荐大家用固定的参数方式,不要用 Map 来传递参数,Map 传递参数最大的问题是可以随意传参。代码如下所示。

  1. @GetMapping("/user/detail")
  2. String getUserDetail(@RequestParam Map<String, Object> param);

POST 请求多参数就定义一个参数类,通过 @RequestBody 注解的方式来实现,代码如下所示。

  1. @PostMapping("/user/add")
  2. String addUser(@RequestBody User user);

实现类中也需要加上 @RequestBody 注解,代码如下所示。

  1. @RestController
  2. public class DemoController implements UserRemoteClient {
  3. @Override
  4. public String addUser(@RequestBody User user) {
  5. return user.getName();
  6. }
  7. }

注意:使用继承特性的时候实现类也需要加上 @RequestBody 注解。

 

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

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

相关文章

遥感影像(tif,img)概览/金字塔(overviews)的创建与清除

使用python环境下的gdal进行遥感影像&#xff08;tif&#xff0c;img格式&#xff09;概览&#xff08;overviews&#xff09;的创建与清除&#xff0c;前边是测试过程&#xff0c;结论在最后 过程 问题起因是拿到一批img格式的影像需要转cog&#xff0c;程序运行中报了个错 …

ESXi8.0安装,实体机安装,IPMI远程安装实战笔记

目录 1.前言 2.连接主板IMPI 3.硬件兼容及BIOS设置 4.从U盘安装ESXi ESXi8.0安装包下载&#xff1a; 链接&#xff1a;https://pan.baidu.com/s/1-a3ka1TAScFPtAc29jcxzQ 提取码&#xff1a;qwhg 1.前言 ESXi系列的虚拟机直接以操作系统的形态出现&#xff0c;与基于Li…

【Linux静态库和动态库】

Linux静态库和动态库1. 编译与ELF格式2. 库的基本概念3.静态库的制作&#xff1a;&#xff08;假设要将a.c、b.c制作成静态库&#xff09;4.静态库的常见操作5.静态库的使用6. 多个库的相互依赖举例1.(库文件制作、错误处理)7.静态库和动态库的关系和区别8.动态库的制作软链接 …

ADI Blackfin DSP处理器-BF533的开发详解25:USB接口设计(含源代码)

硬件准备 ADSP-EDU-BF533&#xff1a;BF533开发板 AD-HP530ICE&#xff1a;ADI DSP仿真器 软件准备 Visual DSP软件 硬件链接 硬件设计原理图 功能介绍 跟网口一样&#xff0c;USB这个设计很勉强&#xff0c;因为BF533并不带USB口&#xff0c;当时是给一个大厂做MP4的方案…

猿如意中的【UltraEdit】开发工具详情介绍

目录 一、工具名称 二、下载安装渠道 2.1 什么是猿如意&#xff1f; 2.2 如何下载猿如意&#xff1f; 2.3 如何在猿如意中下载UltraEdit&#xff1f; 三、UltraEdit介绍 四、软件安装过程 五、软件界面 六、UltraEdit功能特点介绍 七、UltraEdit使用/体验感受…

Python测试进阶(二)

文章目录简介selenium等待Web控件交互表单操作多窗口frame多浏览器处理用 js 操作文件上传弹窗pageObject复用浏览器简介 这部分主要介绍 web 自动化测试 selenium 专门测试 web 的工具&#xff0c;根据测试用例&#xff0c;直接在浏览器上执行对应动作还是在 pytest 框架中…

牛客网SQL入门复健小练

SQL3&#xff1a;distinct 查询结果去重&#xff0c;返回所有不同的university 方法一&#xff1a;distinct关键字。&#xff08;注意&#xff1a;这个关键字实际上是 select distinct&#xff0c;如果是多列&#xff0c;多列作为一个组合然后 distinct 去重&#xff09; 方…

[oeasy]python0028_直接运行_修改py文件执行权限_设置py文件打开方式

直接运行 回忆上次内容 我们把两个程序整合起来了 可以持续输出当前时间每秒都更新但是我想在 shell 里面 只输入文件名(./sleep.py)并回车就能不断输出时间可能吗&#xff1f;&#x1f914; import time while True:print(time.asctime())time.sleep(1) 尝试执行 第 1 句 根…

EXCEL基础:数据透视表(按月或月累计统计操作)

【按月统计数据】&#xff1a; 本操作实现的是原始数据是以日为单位&#xff0c;统计使用的时候&#xff0c;需要以月份或者季度、年份的形式进行&#xff0c;可以使用数据透视表的【组合】功能来 实现&#xff0c;如下所示&#xff1a; 如下所示&#xff0c;将日期字段放在行…

免费分享一套基于VuePress开发的markdown产品文档

vuepress-theme-jingli 文档 | 效果 | 本仓库的gitee镜像 &#xff08;进入赞助商扫码注册可为本项目作者充电~&#xff09; 介绍 这个主题的初衷是打造一个好用的、面向程序员的知识管理工具轻松构建一个结构化的知识库&#xff0c;让你的知识海洋像一本本书一样清晰易读。…

Mac 下设置VScode 背景图片失败解法

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录前言解法一&#xff1a;直接修改VScode 的CSS解法二&#xff1a;还是想用插件总结前言 仓库推荐 C/C 每日一练小仓库&#xff0c;慢慢学习C 知识必备仓库 https://…

Java8:SPI机制

参考资料&#xff1a; 《双亲委派机制及其弊端》 《Java中SPI机制深入及源码解析》 《Java SPI思想梳理》 《深入理解 Java 中 SPI 机制》 写在开头&#xff1a;本文为学习后的总结&#xff0c;可能有不到位的地方&#xff0c;错误的地方&#xff0c;欢迎各位指正。 目录 …

MyBatis-Plus联表查询的短板,终于有一款工具补齐了

mybatis-plus作为mybatis的增强工具&#xff0c;它的出现极大的简化了开发中的数据库操作&#xff0c;但是长久以来&#xff0c;它的联表查询能力一直被大家所诟病。一旦遇到left join或right join的左右连接&#xff0c;你还是得老老实实的打开xml文件&#xff0c;手写上一大段…

10.泛型算法

文章目录*泛型算法**10.1概述**10.2初识泛型算法**10.2.1只读算法**算法和元素类型**操作两个序列的算法**10.2.2写容器元素的算法**算法不检查写操作**介绍back_inserter**拷贝算法**10.2.3重排容器元素的算法**消除重复单词**使用unique**10.3定制操作**10.3.1向算法传递函数…

【JavaSE】那些异常

目录 1. 何为异常 2. 异常的分类 2.1 运行异常 / 非受查异常 &#xff1a; 3. 异常的处理思想 4. 异常的抛出 5. 异常的捕获 5.1 异常声明 throws 5.2 try-catch 捕获异常并处理 6. finally 7. 异常的处理流程 8. 自定义异常 1. 何为异常 在Java中&#xff0c;将程序执…

LeetCode 1884. 鸡蛋掉落-两枚鸡蛋 -- 动态规划

鸡蛋掉落-两枚鸡蛋 中等 60 相关企业 给你 2 枚相同 的鸡蛋&#xff0c;和一栋从第 1 层到第 n 层共有 n 层楼的建筑。 已知存在楼层 f &#xff0c;满足 0 < f < n &#xff0c;任何从 高于 f 的楼层落下的鸡蛋都 会碎 &#xff0c;从 f 楼层或比它低 的楼层落下的鸡蛋…

Jedis解读与建议

1. Jedis是什么&#xff1f; 官网 Jedis 是官方推荐的java客户端&#xff01;SpringBoot的RedisTemplate的底层也是Jedis&#xff1b; 2. 为什么使用池化&#xff1f; 背景&#xff1a; Redis为单进程单线程模式&#xff0c;采用队列模式将并发访问变为串行访问。Redis本身没…

leetcode:合并两个有序数组

合并两个有序数组1、题目描述2、解决方案3、代码实现1、题目描述 给你两个按 非递减顺序 排列的整数数组 nums1 和 nums2&#xff0c;另有两个整数 m 和 n &#xff0c;分别表示 nums1 和 nums2 中的元素数目。 请你 合并 nums2 到 nums1 中&#xff0c;使合并后的数组同样按 非…

mutex 锁的理解和思考

并发的影响 goroutine 并发对数据做读写操作&#xff0c;如果没有锁的保护&#xff0c;得到的结果也就是不确定的。我们通过 goroutine 做累加的例子来看一下&#xff0c;下面的情况&#xff0c;我们预期进行了10次循环&#xff0c;每次加1&#xff0c;但执行的结果却不一定的…

离开外包之后,花了10000小时,最后我走进字节跳动拿到了offer

前言&#xff1a; 没有绝对的天才&#xff0c;只有持续不断的付出。对于我们每一个平凡人来说&#xff0c;改变命运只能依靠努力幸运&#xff0c;但如果你不够幸运&#xff0c;那就只能拉高努力的占比。 2020年7月&#xff0c;我有幸成为了字节跳动的一名Java后端开发&#x…