【SpringCloud系列】@FeignClient微服务轻舞者

💝💝💝欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。
img

  • 推荐:kwan 的首页,持续学习,不断总结,共同进步,活到老学到老
  • 导航
    • 檀越剑指大厂系列:全面总结 java 核心技术点,如集合,jvm,并发编程 redis,kafka,Spring,微服务,Netty 等
    • 常用开发工具系列:罗列常用的开发工具,如 IDEA,Mac,Alfred,electerm,Git,typora,apifox 等
    • 数据库系列:详细总结了常用数据库 mysql 技术点,以及工作中遇到的 mysql 问题等
    • 懒人运维系列:总结好用的命令,解放双手不香吗?能用一个命令完成绝不用两个操作
    • 数据结构与算法系列:总结数据结构和算法,不同类型针对性训练,提升编程思维,剑指大厂

非常期待和您一起在这个小小的网络世界里共同探索、学习和成长。💝💝💝 ✨✨ 欢迎订阅本专栏 ✨✨

博客目录

    • 一.简单介绍
      • 1.什么是 FeignClient?
      • 2.FeignClient 优点?
    • 二.基本使用
      • 1.引入依赖
      • 2.获取 token 接口
      • 3.RequestParam
      • 4.Interceptor
      • 5.配置文件类
      • 6.业务接口
      • 7.yaml 配置文件
      • 8.使用总结
    • 三.原理解析
      • 1.value/name
      • 2.url
      • 3.path
      • 4.configuration
      • 5.fallback
      • 6.fallbackFactory
      • 7.decode404

一.简单介绍

1.什么是 FeignClient?

@FeignClient 是 Spring Cloud 中的一个注解,用于创建基于接口的声明式服务客户端。它是在微服务架构中用于进行服务之间通信的一种方式。通过 @FeignClient,您可以定义一个接口,该接口包含要调用的远程服务的方法,而 Feign 将自动处理底层的 HTTP 请求和负载均衡。

2.FeignClient 优点?

@FeignClient 在微服务架构中的使用具有多个优点和特点,这使得它成为一个方便且强大的工具:

  1. 声明式 REST 客户端: @FeignClient 允许您使用声明式的方式定义服务间的 HTTP 调用。通过简单地定义一个接口,而不需要手动编写 HTTP 请求,您可以将服务调用抽象为接口的方法。

  2. 集成了 Ribbon 负载均衡: @FeignClient 集成了 Netflix 的 Ribbon 负载均衡器,自动处理了服务的负载均衡。这使得微服务之间的调用更加健壮和可靠。

  3. 支持服务发现: 默认情况下,@FeignClient 集成了 Eureka 服务发现,允许您使用服务的逻辑名称而不是直接的 IP 地址进行服务调用。这增加了服务调用的灵活性。

  4. 支持多种注解: 除了 @FeignClient,Feign 还支持一系列其他的注解,如 @RequestMapping@RequestParam 等,使得您可以在接口上使用这些注解定义 HTTP 请求的各个方面。

  5. 集成了 Hystrix 进行服务降级: @FeignClient 支持集成 Hystrix,可以通过设置 fallbackfallbackFactory 属性,定义服务降级的逻辑。当远程服务不可用时,可以提供备选方案,防止整个系统崩溃。

  6. 支持自定义配置: 通过 configuration 属性,您可以自定义 Feign 客户端的配置,包括连接超时、读取超时、重试策略等。这使得您可以根据实际需求进行灵活的配置。

  7. 集成了 Spring Cloud Contract: Spring Cloud Contract 可以通过测试契约来确保服务之间的契约一致性。@FeignClient 集成了 Spring Cloud Contract,使得可以通过契约来测试和验证服务之间的通信。

  8. 简化代码: 使用 @FeignClient 可以大大简化微服务之间的通信代码。由于 Feign 处理了底层的 HTTP 请求和负载均衡,开发者只需要关注业务逻辑,使得代码更加清晰简洁。

@FeignClient 是一个强大的工具,它简化了微服务之间的通信,提高了开发效率,同时集成了一系列的微服务治理功能,使得服务调用更加可靠和灵活。

二.基本使用

1.引入依赖

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

2.获取 token 接口

使用 FeignClient 封装获取 token 的接口

@FeignClient(url = "${xxx.open-api.host}",value = "xxx-open-api",contextId = "oauth",path = "/cas/oauth"
)
public interface AuthOpenApi {@Log("xxx-open-api,获取token")@GetMapping("/token")TokenResponse getToken(@SpringQueryMap GetTokenRequest request);
}

3.RequestParam

请求参数类

@Data
public class GetTokenRequest {private String scope = "xxx";private String grant_type = "xxx";private String client_id;private String client_secret;public GetTokenRequest() {this.client_id = SpringContextHolder.getBean(OpenApiProperties.class).getClientId();this.client_secret = SpringContextHolder.getBean(OpenApiProperties.class).getSecret();}
}

4.Interceptor

拦截器,用于给 FeignClient 添加自定义拦截器

@Slf4j
public class OpenApiRequestInterceptor implements RequestInterceptor {@Autowiredprivate JedisClient JedisClient;@Autowiredprivate AuthOpenApi AuthOpenApi;@Autowiredprivate OpenApiProperties OpenApiProperties;@Overridepublic void apply(RequestTemplate requestTemplate) {String accessToken = JedisClient.get(CommonConstant.REDIS__KEY_PREFIX + "accessToken");if (StringUtils.isEmpty(accessToken)) {TokenResponse response = AuthOpenApi.getToken(new GetTokenRequest());if (response.getCode() != 200) {throw new ApplicationException("获取 accessToken失败");}accessToken = response.getData().getAccessToken();final int expiresIn = response.getData().getExpiresIn();log.info("apply() called with: expiresIn = [" + expiresIn + "]");JedisClient.set(CommonConstant.REDIS__KEY_PREFIX + "accessToken", accessToken, Math.max(expiresIn - 10, 1));}long timestamp = System.currentTimeMillis();String requestId = UUID.randomUUID().toString();String str = OpenApiProperties.getClientId() + timestamp + requestId + accessToken + this.OpenApiProperties.getSecret();String signature = DigestUtils.md5Hex(str).toUpperCase();requestTemplate.header("clientId", this.OpenApiProperties.getClientId());requestTemplate.header("timestamp", timestamp + "");requestTemplate.header("requestId", requestId);requestTemplate.header("signatureMethod", "MD5");requestTemplate.header("accessToken", accessToken);requestTemplate.header("signature", signature);}
}

5.配置文件类

鉴权需要的参数配置信息

@Configuration
@ConfigurationProperties(prefix = "open-api")
@Data
public class OpenApiProperties {private String url;private String clientId;private String secret;private String aesKey;private String aesIv;
}

开启 FeignClients 的功能

@EnableFeignClients
@Configuration
public class OpenFeignConfig {
}

6.业务接口

获取图片的权限

@FeignClient(url = "${open-api.host}",value = "open-api",configuration = {OpenApiRequestInterceptor.class},contextId = "picAuth",path = "/permission-portal/picture/auth"
)
public interface PicOpenApi {@Log("open-api,图片授权模块")@GetMappingPicResultDto auth(@RequestParam(value = "userNo") String userNo);
}

7.yaml 配置文件

open-api:host: xxxxxclientId: insightsecret: xxxxaesKey: xxxxaesIv: xxxx

8.使用总结

首先用@FeignClient 定义了 2 个接口,一个是获取 token 的接口,一个是获取图片权限的接口,在获取图片权限的接口中添加了 configuration 属性,该属性指向 OpenApiRequestInterceptor 类,在请求获取图片接口的时候,会前置处理拦截器中的逻辑,在拦截器中我们调用的是获取 token 的接口,并解析返回结果,放入到了 http 的请求头中,非常方便的给获取图片的接口添加了 header 鉴权信息。

三.原理解析

1.value/name

value/name: 用于指定目标服务的名称。valuename 都可以用来设置服务的名称,它们是互换的。这是 @FeignClient 唯一需要指定的参数。

@FeignClient(value = "example-service")
public interface ExampleFeignClient {// ...
}

2.url

url: 如果不想使用服务发现,可以使用 url 参数指定目标服务的 URL。这个 URL 可以是完整的服务地址。

@FeignClient(url = "http://example.com")
public interface ExampleFeignClient {// ...
}

3.path

path: 用于为 Feign 客户端的所有请求添加一个基本路径。

@FeignClient(value = "example-service", path = "/api")
public interface ExampleFeignClient {// ...
}

4.configuration

configuration: 用于指定 Feign 客户端的配置类,可以配置连接超时、重试策略、拦截器等。可以指定一个,也可以指定多个,非常给力的功能参数。

@FeignClient(value = "example-service", configuration = MyFeignConfig.class)
public interface ExampleFeignClient {// ...
}

5.fallback

fallback: 用于指定一个降级处理的类,当调用失败时会执行该类的方法。

@FeignClient(value = "example-service", fallback = ExampleFallback.class)
public interface ExampleFeignClient {// ...
}

6.fallbackFactory

fallbackFactory: 与 fallback 类似,用于指定一个降级处理的工厂类,可以在工厂类中对异常进行更详细的处理。

@FeignClient(value = "example-service", fallbackFactory = ExampleFallbackFactory.class)
public interface ExampleFeignClient {// ...
}

7.decode404

decode404: 默认情况下,Feign 不会解码 404 响应。通过设置 decode404 = true,可以让 Feign 解码 404 响应。

@FeignClient(value = "example-service", decode404 = true)
public interface ExampleFeignClient {// ...
}

@FeignClient 注解的参数,提供了灵活性和配置选项,以适应不同的微服务调用场景。Feign 会根据这些参数配置底层的 HTTP 请求,实现服务之间的通信。

觉得有用的话点个赞 👍🏻 呗。
❤️❤️❤️本人水平有限,如有纰漏,欢迎各位大佬评论批评指正!😄😄😄

💘💘💘如果觉得这篇文对你有帮助的话,也请给个点赞、收藏下吧,非常感谢!👍 👍 👍

🔥🔥🔥Stay Hungry Stay Foolish 道阻且长,行则将至,让我们一起加油吧!🌙🌙🌙

img

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

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

相关文章

RocketMQ-核心编程模型

RocketMQ的消息模型 深入理解RocketMQ的消息模型 RocketMQ客户端基本流程 RocketMQ基于Maven提供了客户端的核心依赖&#xff1a; <dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version&…

unity学习笔记19

一、角色动画的使用练习 从资源商店导入的动画资源&#xff08;Character Pack: Free Sample&#xff09;中将资源中的角色创建在场景里&#xff0c;现在场景里存在的角色并没有任何动画。 在资源中找到Animations文件夹&#xff0c;在这个文件有很多模型文件&#xff08;.FBX…

什么牌子的开放式耳机好?开放式耳机选购指南来了!

在当今音频科技不断演进的时代&#xff0c;开放式耳机作为一种受欢迎的音频设备&#xff0c;吸引着越来越多的消费者&#xff0c;与封闭式耳机相比&#xff0c;开放式耳机在音质表现和舒适度上都具有独特的优势&#xff0c;在众多品牌和型号中选择一款满足个人需求的开放式耳机…

【UGUI】Unity为下拉菜单添加选项(DropDown)

要想控制谁就把谁拿到代码里-获取组件-修改组件参数&#xff08;变量或者方法&#xff09; 代码示例&#xff1a; using System.Collections; using System.Collections.Generic; using UnityEngine; using UnityEngine.UI; using TMPro;public class UIcontrol : MonoBehavi…

Leetcod面试经典150题刷题记录——数组 / 字符串篇

数组 / 字符串篇 1. 合并两个有序数组Python3排序法双指针法 2. 移除元素Python3 3. 删除有序数组中的重复元素Python3 7. 买卖股票的最佳时机Python3 8. 买卖股票的最佳时机ⅡPython3贪心法动态规划法 11. H 指数Python3排序法计数排序法二分查找 有个技巧&#xff0c;若想熟悉…

linux磁盘挂载

一、磁盘查看与分区挂载 查看未挂载的磁盘 sudo fdisk -l对上述未挂载的磁盘进行分区和格式化 sudo fdisk /dev/sdd输入g生成分区表&#xff0c; mklabel gpt (创建分区表) #与上一步重复了&#xff0c;可以省略 mkpart primary 1 -1 p (输出结果) q (离开菜单)分好区之后可…

MySQL-视图

一、&#xff1f;看一个需求 emp表的列信息很多&#xff0c;有些信息是个人重要信息(比如 sal,comm,mgr,hiredate),如果我们希望某个用户只能查询emp表的(empno、ename,job和deptno)信息,有什么办法? 》视图 二、基本概念 视图 视图是一个虚拟表&#xff0c;其内容由查…

网络安全缓冲区溢出实验

实验要求实验步骤函数 f00()函数 f01()函数 f02() 实验要求 C 程序 homework08.c 的主函数如下&#xff1a; int main(int argc, char * argv[]) { init_buf(Lbuffer, LEN);switch(argc) {case 1: f00(); break;case 2: f01(); break;case 3: f02(); break; default: f00(); …

CompletableFuture异步执行

CompletableFuture异步执行 概念 Java 8引入了一个强大的类:CompletableFuture,它在java.util.concurrent包中。CompletableFuture是Future的增强版本,主要用于实现异步编程。 首先,我们要理解什么是Future。Future是Java5引入的一个接口,代表一个异步计算的结果。你可…

华清远见嵌入式学习——C++——作业6

作业要求&#xff1a; 代码&#xff1a; #include <iostream>using namespace std;class Animal { public:virtual void perform() 0;};class Lion:public Animal { private:string foods;string feature; public:Lion(){}Lion(string foods,string feature):foods(foo…

软件设计模式原则(三)单一职责原则

单一职责原则&#xff08;SRP&#xff09;又称单一功能原则。它规定一个类应该只有一个发生变化的原因。所谓职责是指类变化的原因。如果一个类有多于一个的动机被改变&#xff0c;那么这个类就具有多于一个的职责。而单一职责原则就是指一个类或者模块应该有且只有一个改变的原…

【MySQL】聚合函数和分组(查找)

聚合函数分组分组聚合如何显示每个部门的平均工资和最高工资显示每个部门的每种岗位的平均工资和最低工资显示平均工资低于2000的部门和它的平均工资(SMITH员工不参与)where 和 having 的区别 聚合函数 函数说明COUNT([DISTINCT] expr)返回查询到的数据的 数量SUM([DISTINCT] …

三、DVP摄像头调试笔记(图片成像质量微调整,非ISP)

说明&#xff1a;当前调试仅仅用来测试和熟悉部分摄像头寄存器模式 一、图片成像方向控制&#xff0c;基本每个摄像头都会有上下左右翻转寄存器 正向图片 反向图片 二、设置成像数据成各种颜色&#xff0c;&#xff08;黑白/原彩/黄色等等&#xff09; 在寄存器书册描述中…

【SpringCloud篇】Eureka服务的基本配置和操作

文章目录 &#x1f339;简述Eureka&#x1f6f8;搭建Eureka服务⭐操作步骤⭐服务注册⭐服务发现 &#x1f339;简述Eureka Eureka是Netflix开源的一个基于REST的服务治理框架&#xff0c;主要用于实现微服务架构中的服务注册与发现。它由Eureka服务器和Eureka客户端组成&#…

使用NimoShake将数据从AWS DynamoDB迁移至阿里云MongoDB

本文介绍从AWS DynamoDB到阿里云MongoDB的迁移框架。 它概述了以下步骤&#xff1a; 在阿里云上配置云数据库MongoDB版并应用公网终端节点在 AWS EC2 上安装 Nimoshake将AWS EC2访问阿里云MongoDB版列入白名单配置 Nimoshake 并开始迁移过程验证目标数据库上的增量数据 1. 创…

基于人工智能技术《量化投资AI系统》的集群架构设计与实现

乔总&#xff1a; 前些日子你我的共同朋友潘总&#xff0c;推荐您来聊聊将ChatGPT应用于量化投资的合作。在与您及您的团队进行了超过2个多小时的沟通后&#xff0c;恕我直言&#xff0c;不客气地说&#xff0c;感觉您的团队对人工智能技术几乎是空白。为了让您的团队对人工智…

Spring boot命令执行 (CVE-2022-22947)漏洞复现和相关利用工具

Spring boot命令执行 (CVE-2022-22947)漏洞复现和相关利用工具 名称: spring 命令执行 (CVE-2022-22947) 描述: Spring Cloud Gateway是Spring中的一个API网关。其3.1.0及3.0.6版本&#xff08;包含&#xff09;以前存在一处SpEL表达式注入漏洞&#xff0c;当攻击者可以访问A…

八、Lua数组和迭代器

一、Lua数组 数组&#xff0c;就是相同数据类型的元素按一定顺序排列的集合&#xff0c;可以是一维数组和多维数组。 在 Lua 中&#xff0c;数组不是一种特定的数据类型&#xff0c;而是一种用来存储一组值的数据结构。 实际上&#xff0c;Lua 中并没有专门的数组类型&#xf…

逢疫读史引以为鉴,防微杜渐警钟长鸣

世事变幻&#xff0c;皆有定数&#xff1b;生死福祸&#xff0c;必有因由。连日来&#xff0c;“多国又爆发大规模传染病”这个话题&#xff0c;不断地出现在网络空间&#xff0c;令人骇然。为此笔者花了很多时间和精力&#xff0c;查阅了许多相关文献、史料&#xff0c;在此仅…

vuepress-----2、初体验

2、初体验 目标 创建GitHub账号创建Github项目初体验vuepress默认主体的首页 初体验 (opens new window) --- home: true heroImage: /hero.png heroText: Hero 标题 tagline: Hero 副标题 actionText: 快速上手 → actionLink: /zh/guide/ features: - title: 简洁至上deta…