springcloud-fegin 组件调用

一、Feign 概述

Feign是Netflix开发的声明式、模板化的HTTP客户端, Feign可以帮助我们更快捷、优雅地调用HTTP API。

在Spring Cloud中,使用Feign非常简单——创建一个接口,并在接口上添加一些注解,代码就完成了。Feign支持多种注解,例如Feign自带的注解或者JAX-RS注解等。

Spring Cloud对Feign进行了增强,使Feign支持了Spring MVC注解,并整合了Ribbon和Eureka,从而让Feign的使用更加方便。

Spring Cloud Feign是基于Netflix feign实现,整合了Spring Cloud Ribbon和Spring Cloud Hystrix,除了提供这两者的强大功能外,还提供了一种声明式的Web服务客户端定义的方式。

Spring Cloud Feign帮助我们定义和实现依赖服务接口的定义。在Spring Cloud feign的实现下,只需要创建一个接口并用注解方式配置它,即可完成服务提供方的接口绑定,简化了在使用Spring Cloud Ribbon时自行封装服务调用客户端的开发量。

1.1 Fegin 常用注解

OpenFeign 常用注解OpenFeign 声明式服务调用和负载均衡组件,因此它的核心是使用注解 + 接口的方式实现服务调用,所以了解 OpenFeign 的注解就至关重要了。 对于 Feign 框架来说,它只支持 Feign 注解和 JAX-RS 注解,但 OpenFeign 在 Feign 的基础上还增加了对 Spring MVC 注解的支持,例如 @RequestMapping、@GetMapping 和 @PostMapping 等注解。 OpenFeign 常用注解有以下几个:

  • @EnableFeignClients:该注解用于开启 OpenFeign 功能,当 Spring Cloud 应用启动时,OpenFeign 会扫描标有 @FeignClient 注解的接口,生成代理并注册到 Spring 容器中。
  • @FeignClient:该注解用于通知 OpenFeign 组件对 @RequestMapping 注解下的接口进行解析,并通过动态代理的方式产生实现类,实现负载均衡和服务调用。
  • @RequestMapping:向服务提供者发起 Request 请求(默认为 GET 方式请求),这里需要注意@RequestMapping/@GetMapping/@PostMapping 和 Spring MVC 中的同名注解的含义是完全不同的。
  • @GetMapping:向服务提供者发起 GET 请求。
  • @PostMapping:向服务提供者发起 POST 请求。

1.2 Feign调用过程

OpenFeign 是用在服务消费端的,有消费端就得有服务提供端,它们的关系如下图所示:
在这里插入图片描述
所以我们先要创建一个服务提供者 Provider;提供者fegin在调用时没有什么特别注意的,提供者没有什么需要注意的,只需要把提供者注入到注册中心,消费者就会从注册中心获取提供者。消费搭建搭建如下

二、组件引入搭建

1.在服务消费者端引入fegin 依赖包

在服务消费者端引入jar包

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

如果配合注册中心使用的话还需要引入注册中心的客户端包

      <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-config</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

2. 在启动类中启动fegin 功能

在启动类上加 @EnableFeignClients 注解,如果你的 Feign 接口定义跟你的启动类不在同一个包名下,还需要制定扫描的包名 @EnableFeignClients(basePackages=“com.fangjia.api.client”)


@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients(basePackages = {"api.config.env.client"})
public class AmasterWorkServerApplication {public static void main(String[] args) {SpringApplication.run(AmasterWorkServerApplication.class, args);}}

说明 :
@EnableFeignClients 需要指定 fegin的 接口feginClient 所在的接口位置 ,@EnableFeignClients(basePackages ={XXX } 属性,否在 在spring 启动的时候注入 feginClient 所在的接口注入不到spring中,启动会报注入失败异常!

3. 声明FeignClient接口

3.1 @FeignClient 注解属性说明

@FeignClient 注解:这个注解标识当前是一个 Feign 的客户端,value 属性是对应的服务名称

  • path: 服务调用的统一前缀
  • name:指定FeignClient的名称,如果项目使用了Ribbon,name属性会作为微服务的名称,用于服务发现
  • url: url一般用于调试,可以手动指定@FeignClient调用的地址
  • decode404:当发生http 404错误时,如果该字段位true,会调用decoder进行解码,否则抛出FeignException
  • configuration: Feign配置类,可以自定义Feign的Encoder、Decoder、LogLevel、Contract
  • allback: 定义容错的处理类,当调用远程接口失败或超时时,会调用对应接口的容错逻辑,fallback指定的类必须实现
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;import java.util.List;@FeignClient(name = "amaster-config-env"/*, url = "远程服务URL"*/,path = "amaster-config-env")
public interface ConfigEnvServiceClient {@RequestMapping(value="/env/get/env/all/v1",method = RequestMethod.GET)public List<String> getEnvConfig();
}

在这里插入图片描述
在FeignClient 接口中需要用@FeignClient 注解标注为Feign 客户端,还需要指定 消费这服务名,服务的容器path 路径。如果不指定 path 话,在接口调用的时候会报找不到feign报UnknownHostException:服务名解决方案 ,或者报404 找不到消费者的接口路径。再指定url属性的时候,feginClient 客户端优先使用url进行调用。

如果FeignClient接口参数少了@RequestBody或@RequestParam注解会造成调用服务提供者时出现参数为空现象。(当然无论是服务提供者还是调用者都要加上注解)

4.测试

调用消费者
GET http://localhost:9005/amaster-work-server/env/get/config/env/all/v1
会把提供者接口的结果返回

[“amaster-report-server prod hello world123”]

如果走网关调用也会输出
http://localhost:8070/amaster-work-server/env/get/config/env/all/v1

[“amaster-report-server prod hello world123”]

三. fegin的请求拦截处理

对于Fegin 调用前的拦截调用统一处理可以使用, feign的RequestInterceptor,拦截器进行拦截处理,比如在调用前可以统一给调用的header添加token等处理

class FeignRequestHeaderInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate requestTemplate) {MethodMetadata methodMetadata = requestTemplate.methodMetadata();// 这个就是当前被@FeignClient注解的feign接口类型Class<?> classDecorateByFeignClientAnnotation = methodMetadata.method().getDeclaringClass();// 获取到path之后, 向rquest header塞入一个约定的键值对, 或者基于ThreadLocal, 向下传递给我们的`LoadBalancerFeignClientEx`......}
}

feign技巧 - 同时支持基于url和服务名的调度:https://blog.csdn.net/lqzkcx3/article/details/130269543

四、Feign 的 Fallback和FallbackFactory

@FeginClient 属性中的Fallback和 FallbackFactory可以帮助我们在使用Feign去调用另一个服务时,如果出现了问题,走服务降级,返回一个错误的数据,避免功能因为一个服务出现问题,全部失效。

4.1 fallBack 方式

4.1.1 定义fallBack类

ConfigEnvServiceClientFallBack 回调实现,由spring创建使用@Component(其他的注册也可以)注解


@Component
public class ConfigEnvServiceClientFallBack implements ConfigEnvServiceClient {@Overridepublic List<String> getEnvConfig() {return Arrays.asList("Fallback response");}
}

在这里插入图片描述
fallBack 类要实现feginCleint 的接口,并且需要声明为一个bean组件,这样当熔断发生的时候 hystris 就会从spring容器中拿到这个接口的兜底fallVBack方法;
注意fallBack 类的实现类也需要被ComponentScan 也要扫描到你的fallback及包 扫描到

HystrixTargeter.targetWithFallback方法实现了@FeignClient.fallback处理逻辑,通过源码可以知道UserFeignFallback回调类是从Spring容器中获取的,所以ConfigEnvServiceClientFallBack 由spring创建。

4.1.2 在FeignClient 的快速失败策略(fallback 、fallBackFactory)上定义快速失败的实现类

@FeignClient(name = "amaster-config-env"
/*, url = "远程服务URL"*/,path = "amaster-config-env",fallback = ConfigEnvServiceClientFallBack.class/*fallbackFactory = ""*/)
public interface ConfigEnvServiceClient {@RequestMapping(value="/env/get/env/all/v1",method = RequestMethod.GET)public List<String> getEnvConfig();
}

在这里插入图片描述

4.1.3 测试

当服务提供者接口500或者异常时候则,消费者的口的fallBack就会执行快速失败策略
当服务调用成功的时候输出

["amaster-report-server prod hello world123"]

当消费服务异常或者接口异常的时候返回

["Fallback response"]

4.2FallbackFactory工厂方式

fallBack上面的实现方式简单,但是获取不到HTTP请求错误状态码和信息 ,这时就可以使用工厂模式来实现Fallback

同样工厂实现类也要交由spring管理,同时结合ConfigEnvServiceClientFallBack使用,这里需要注意的create方法返回值类型一定要实现Feign接口

4.2.1 定义FallBackFactory 实现类

package com.zhang.buiness.amaster.workserver.client.fallback;import com.zhang.buiness.amaster.workserver.client.fegin.ConfigEnvServiceClient;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;/**** 相比于fallBack,可以打印出 fallBack的异常信息*/
@Component
@Slf4j
public class ConfigEnvServiceClientFallBackFactory implements FallbackFactory<ConfigEnvServiceClient> {private final ConfigEnvServiceClientFallBack configEnvServiceClientFallBack;public ConfigEnvServiceClientFallBackFactory(ConfigEnvServiceClientFallBack configEnvServiceClientFallBack) {this.configEnvServiceClientFallBack = configEnvServiceClientFallBack;}@Overridepublic ConfigEnvServiceClient create(Throwable throwable) {log.error("ConfigEnvServiceClient fall Back {}",throwable.getMessage(),throwable);return configEnvServiceClientFallBack;}
}

4.2.1 在@FeginClient中使用FallBackFactory

@FeignClient(name = "amaster-config-env"/*, url = "远程服务URL"*/,path = "amaster-config-env",/*fallback = ConfigEnvServiceClientFallBack.class*/,fallbackFactory = ConfigEnvServiceClientFallBackFactory.class)
public interface ConfigEnvServiceClient {@RequestMapping(value="/env/get/env/all/v1",method = RequestMethod.GET)public List<String> getEnvConfig();
}

在这里插入图片描述

4.2.2 测试

提供者接口正常

["amaster-report-server prod hello world123"]

提供者异常

["Fallback response"]

控制台打印日志
在这里插入图片描述

4.3 fallBack 执行调用不成的排查点

以下是feign调用出现的问题检查点
1、激活
2、注解
3、fallback
4、fallback + @Component
5、激活Feign中要扫描到你的feign及包
6、ComponentScan 也要扫描到你的fallback及包
7、配置的拦截器
8、配置的拦截器中,一定一定一定要加log打印,(重中之重,有助于你排查问题,不会焦头烂额)
9、如果配置熔断优化策略,配置好超时时间(从一个请求的开始到rpc调用且包含rpc中的执行时间)
10、**检查返回类型是否序列化,即非interface

五 自定义fegin 请求 ErrorDecoder

https://blog.csdn.net/sun_shaoping/article/details/82079287

六、fegin传递参数与spring MVC 传参的不同 (待定)

Feign默认使用@RequestBody,这就是上面name参数为null的原因,@RequestBody(只能有一个)一般用于传递对象,如果参数中出现多个对象可以使用Map来传递对象

如果你传递的参数,比较复杂时,默认会采用 POST 的请求方式。
传递单个参数时,推荐使用 @PathVariable (Restful 风格),如果传递的单个参数比较多,这里也可以采用 @RequestParam ,不要省略 value 属性。
传递对象信息时,统一采用 json 的方式,添加 @RequestBody 。
Client接口必须采用 @RequestMapping 。

@FeignClient(name = "hello")  
public interface IHelloService {  @RequestMapping(value = "/hello",method = RequestMethod.GET)  String saveBook(@RequestBody Book book);  
}  

参考博客:
https://blog.csdn.net/justry_deng/article/details/80785973
https://blog.csdn.net/qq_34912478/article/details/81387422

七、 服务之间调用的几种方式比较待定(待定)

三种方式对比:

RestTemplate 方式:
String result = restTemplate.getForObject(url+“search”, String.class);
RestTemplate 整合 Ribbon方式:
String result = restTemplate.getForObject(“//SEARCH/search”, String.class);
Feign 方式:
String result = searchClient.search();
使用RestTemplet 进行服务调用时候的负载均衡处理

https://blog.csdn.net/baidu_39378193/article/details/125029430
https://blog.csdn.net/djrm11/article/details/114526346

八、OpenFeign 介绍

OpenFeign 介绍OpenFeign 的全称是 Spring Cloud OpenFeign,它是 Spring 官方推出的一种声明式服务调用和负载均衡组件。它的出现就是为了替代已经进入停更维护状态的 Feign(Netflix Feign)的。也就是说 OpenFeign(Spring Cloud OpenFeign)是 Feign 的升级版,它们的关系如下图所示

在这里插入图片描述
因为 Feign 停更维护了,所以 Spring 官方需要推出了一个新的新的框架来对 Feign 功能进行升级和扩展。

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

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

相关文章

llama-factory SFT系列教程 (二),大模型在自定义数据集 lora 训练与部署

文章目录 简介支持的模型列表2. 添加自定义数据集3. lora 微调4. 大模型 lora 权重&#xff0c;部署问题 参考资料 简介 文章列表&#xff1a; llama-factory SFT系列教程 (一)&#xff0c;大模型 API 部署与使用llama-factory SFT系列教程 (二)&#xff0c;大模型在自定义数…

Day01——NestJS学习之了解、安装、运行

什么是 Nest.js&#xff1f; NestJs 官方简介: Nest (NestJS) 是一个用于构建高效、可扩展的 Node.js 服务器端应用程序的开发框架。它利用 JavaScript 的渐进增强的能力&#xff0c;使用并完全支持 TypeScript &#xff08;仍然允许开发者使用纯 JavaScript 进行开发&#x…

leetcode:739.每日温度/496.下一个更大元素

单调栈的应用&#xff1a; 求解当前元素右边比该元素大的第一个元素&#xff08;左右、大小都可以&#xff09;。 单调栈的构成&#xff1a; 单调栈里存储数组的下标&#xff1b; 单调栈里的元素递增&#xff0c;求解当前元素右边比该元素大的第一个元素&#xff1b;元素递…

【Java开发指南 | 第六篇】Java成员变量(实例变量)、 类变量(静态变量)

读者可订阅专栏&#xff1a;Java开发指南 |【CSDN秋说】 文章目录 成员变量&#xff08;实例变量&#xff09;类变量&#xff08;静态变量&#xff09;定义方式静态变量的使用场景 成员变量&#xff08;实例变量&#xff09; 成员变量声明在一个类中&#xff0c;但在方法、构造…

【opencv】示例-videocapture_openni.cpp 深度数据获取和处理的示例

该代码是一个与使用OpenCV进行深度传感器捕获和处理相关的程序的一部分。主要功能包括处理Kinect或XtionPRO等深度传感器数据&#xff0c;解析命令行参数&#xff0c;打开视频捕获设备&#xff0c;以及在GUI上显示深度图&#xff0c;彩色图像&#xff0c;和红外图像等。代码中使…

linux 自定义快捷指令(docker

vi /root/.bashrc alias disdocker images alias dpsdocker ps --format "table {{.ID}}\t{{.Image}}\t{{.Ports}}\t{{.Status}}\t{{.Names}}" 保存退出后使用sourece /root/.bashrc 让其立即生效 sourece /root/.bashrc

byobu

byobu 终端多路复用器 一、byobu 安装二、byobu 使用三、其他终端多路复用器四、ssh byobu 远程协作 系统环境: linux(ubuntu,debian,kali) 一、byobu 安装 byobu 是包装过的tmux #sudo apt install tmux sudo apt install byobubyobu二、byobu 使用 创建窗口: Ctrl a c…

HashMap的扩容看这一篇足够

在Java中&#xff0c;对于HashMap这样的实现&#xff0c;put方法是用来将一个键值对插入到Map中的核心方法。以下是HashMap类中put方法的大致执行流程&#xff1a; 计算Hash值&#xff1a; 首先&#xff0c;put方法会接收一个键&#xff08;Key&#xff09;和一个值&#xff0…

攻防世界13-simple_php

13-simple_php <?php show_source(*__FILE__*);//高亮文件 include("config.php");//文件包含在内 $a$_GET[a];//获得a $b$_GET[b];//获得b if($a0 and $a){ //判断a是否满足条件echo $flag1; //满足就输出flag1 } if(is_numeric($b)){ //判断b的条件&#x…

Python | Leetcode Python题解之第26题删除有序数组中的重复项

题目&#xff1a; 题解&#xff1a; class Solution:def removeDuplicates(self, nums: List[int]) -> int:if not nums:return 0n len(nums)fast slow 1while fast < n:if nums[fast] ! nums[fast - 1]:nums[slow] nums[fast]slow 1fast 1return slow

Git可视化工具 - 推荐

概述 Git版本管理工具是我们日常开发中常用的工具&#xff0c;熟练使用它可以提高我们的工作效率。 当然老司机基本使用命令行的方式进行操作&#xff0c;新手可借助可视化工具来进行过渡&#xff0c;命令行与可视化工具结合使用来加深对Git的熟悉程度。 下面推荐两个较受欢迎…

MySQL 试图

视图功能在 5.0 以后的版本启用 视图是一张虚表。数据表确实包含了具体数据并且保存到硬盘中的实表。视图使用数据检索语句动态生 成的一张虚表。每一次数据服务重启或者系统重启之后&#xff0c;在数据库服务启动期间&#xff0c;会使用创建视图的语 句重新生成视图中的数据&…

BERT论文解读及情感分类实战

文章目录 简介BERT文章主要贡献BERT模型架构技术细节任务1 Masked LM&#xff08;MLM&#xff09;任务2 Next Sentence Prediction (NSP)模型输入 下游任务微调GLUE数据集SQuAD v1.1 和 v2.0NER 情感分类实战IMDB影评情感数据集数据集构建模型构建超参数设置训练结果注意事项 简…

学习Rust的第三天:猜谜游戏

基于Steve Klabnik的《The Rust Programming Language》一书。今天我们在rust中建立一个猜谜游戏。 Introduction 介绍 We will build a game that will pick a random number between 1 to 100 and the user has to guess the number on a correct guess the user wins. 我们将…

Nginx内存池相关源码剖析(六)外部资源释放和内存池销毁

ngx_destroy_pool函数 先执行回调函数释放所有的外部资源&#xff0c;然后free释放所有的大块内存和小块内存。 // 释放外部资源&#xff0c;销毁内存池 void ngx_destroy_pool(ngx_pool_t *pool) {ngx_pool_t *p, *n;ngx_pool_large_t *l;ngx_pool_cleanup_t *…

用海豚调度器定时调度从Kafka到HDFS的kettle任务脚本

在实际项目中&#xff0c;从Kafka到HDFS的数据是每天自动生成一个文件&#xff0c;按日期区分。而且Kafka在不断生产数据&#xff0c;因此看看kettle是不是需要时刻运行&#xff1f;能不能按照每日自动生成数据文件&#xff1f; 为了测试实际项目中的海豚定时调度从Kafka到HDF…

【计算机网络】常用编码方式+例题(曼彻斯特编码、差分曼彻斯特编码...)

常用编码方式例题 常用编码方式练习画出四种编码20221题342015题342013题34 常用编码方式 练习 画出四种编码 20221题34 这个题目的考察是差分曼彻斯特编码。 差分曼彻斯特编码在每个码元的中间时刻电平都会发生跳变。与曼彻斯特编码不同的是&#xff1a;电平的跳变仅代表时钟…

C++ ─── 操作符重载和赋值重载

目录 赋值运算符重载 运算符重载 赋值运算符重载&#xff08;赋值重载operator&#xff09; 前置和后置重载 赋值运算符重载 运算符重载 C为了增强代码的可读性引入了运算符重载 &#xff0c; 运算符重载是具有特殊函数名的函数 &#xff0c;也具有其返回值类型&#xff0c…

SQL Server 存储函数(funGetId):唯一ID

系统测试时批量生成模拟数据&#xff0c;通过存储函数生成唯一ID。 根据当前时间生成唯一ID&#xff08;17位&#xff09; --自定义函数&#xff1a;根据当前时间组合成一个唯一ID字符串:yearmonthdayhourminutesecondmillisecond drop function funGetId;go--自定义函数&…

PHP Storm 2024.1使用

本文讲的是phpstorm 2024.1最新版本激活使用教程&#xff0c;本教程适用于windows操作系统。 1.先去idea官网下载phpstorm包&#xff0c;我这里以2023.2最新版本为例 官网地址&#xff1a;https://www.jetbrains.com/zh-cn/phpstorm/ 2.下载下来后安装&#xff0c;点下一步 …