关于注解FeignClient的使用规范

注解FeignClient使用规范

首先是对FeignClient里的常用属性

  • contextId:当有多个服务调用方法不想写在一个接口里,就要使用到
  • name:指定FeignClient的名称,如果项目使用了Ribbon,name属性会作为微服务的名称,用于服务发现
  • url:url一般用于调试,可以手动指定@FeignClient调用的地址
  • fallback:定义容错的处理类,当调用远程接口失败或超时时,会调用对应接口的容错逻辑,fallback指定的类必须实现@FeignClient标记的接口
  • fallbackFactory:工厂类,用于生成fallback类示例,通过这个属性我们可以实现每个接口通用的容错逻辑,减少重复的代码
  • path:定义当前FeignClient的统一前缀

使用FeignClient的原因

无非让一个微服务的接口被另一个服务访问,微服务的一个特点就是业务隔离,那就要尽量的做到数据库隔离,虽 然不是真的隔离,但是要尽量在代码上做隔离。

举例,系统有一个file-server,是系统的公共服务,附件的下载,上传,获取内容等接口实现。对应操作的表是系统附件表。

现在客户的信息里有附,正常是在客户与附件之间做连表查询,将附件信息拿到,但是在微服务里这样子做是不合规的。现在如果进行如下的引用

在controller类里定义的接口方法

//在controller类里定义的接口方法   
@RequestMapping(value = "/add" ,method = RequestMethod.GET)
public Integer add(@RequestParam Integer a, @RequestParam Integer b) {
 ServiceInstance instance = client.getLocalServiceInstance();
 Integer r = a + b;
 logger.info("/add, host:" + instance.getHost() + ", service_id:" + instance.getServiceId() + ", result:" + r);
 return r;
}

使用@FeignClient

@FeignClient("compute-service")
public interface ComputeClient {
    @RequestMapping(method = RequestMethod.GET, value = "/add")
    Integer add(@RequestParam(value = "a") Integer a, @RequestParam(value = "b") Integer b);
}

然后在另一个微服务里的controller层调用

@Autowired
ComputeClient computeClient;
@RequestMapping(value = "/add", method = RequestMethod.GET)
public Integer add() {
    return computeClient.add(10, 20);
}

只能说使用成功了,但是不规范,这是网上随处可见的错误规范,一开始我也是错误的在controll层引用,但是被技术经理叼了,反正就是不合规。

理由很简单,给前端的接口不要重复。如果你这边controller调用原来的服务,不管是哪个微服务的,前端是可以直接访问的,那这样子的意义何在。接口给你调用,是让你用来获取有用的信息来处理,然后返回给前端。

所以应该在server层调用。

规范的使用@FignClient注解

以公共服务中的文件服务和客户业务模块进行服务间的通信为例

在文件服务的api模块里写如下

FeignClient(contextId = "fileService", value = ServicellaneConstants.FTLE_SERNVTCE,fallbackFactory=RenoteFileFallbackFactory.class)
public interface RemoteFileservice {
/**
*上传文件*
* aparam file 文件信息*areturn结果
*/
@PostMapping(value = "/upload",consumes = MediaType.WULTIPART_FORN_DATA_VALUE)
public RcLong uplocad(CRequestParan("module ) String nodole ,ORequestParan("sunceId ) String souneId, OlequestFart(value = "file ") liltigartFile file);

此时在客户业务板块,即客户需要和附件进行相关信息的1对多查询,不能连表查询,那就调用上面的RemoteFileservice ,一开始我在客户模块里写了一个FileController,然后写接口,接口里调用,直接NO。

应该在业务层里调用就好了,用注解@Autowired,将你需要处理的数据获取到并处理好。

接下来看看fallbackFactory,主要是为降级处理就是出错了应该返回什么。

代码仅供参考,可能还会有其它 的写法

//注意FallbackFactory<你注解对应的接口类名>
@component
public class RemoteFileFallbackFactory implements FallbackFactory<RemoteFileService>
private static final Logger log = LoggerFactory.getLogger(RemoteFileFallbackFactory.class);
0verride
public RemoteFileservice create(Throwable throwable){
//打印出错日志
log.error("文件朋务调用失败:{}", throwable.getHessage());return new RemoteFileserviceo
{
Override
public R<Long> upload(String module,String sourceId,MultipartFile file){
return R.fail("上传失败:" + throwable.getMessage(o);
}
0verride
public byte[ ] getFileBytes(Long fileId) { return new byte[0];}
@0verride
public R getURL(Long[] ids) { return R.fail("获取文件URL失败:" + throwable.getHessage());}
@0verride
public R<List<SysFileApivo>> getURL(List<Long> ids) {
return R.fail("获取文件URL失败:" + throwable.getMessage());
}
};

想要怎么用,就动手实践吧

@FeignClient注解使用的常见问题

Feign 是一个声明式的 Web 服务,通过定义一个添加相应注解的接口,即可完成一个 Web 服务的接口。SpringCloud 对 Feign 进行了封装以后,其开始能够支持 Spring MVC 标准注解,同时在 SpringCloud 架构上结合 Eureka 和 Ribbon,还能够支持负载均衡。

既然是一个 Web 服务,必然服务端模块与客户端模块都加入 Feign 依赖以及对接的 api 接口,这是 Feign 服务的基本前提。因此双方引入的 Feign 接口都要保持一致,包括服务地址、入参定义、返回值等。

基本配置

要启用 @FeignClient 接口,首先需要引入 Feign 依赖:

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

在父 pom.xml 里还需要引入 SpringCloud 依赖,这样使用 FeignClient 才有意义。

在启动类上添加启动注解 @EnableFeignClients:

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
 
@SpringBootApplication
@EnableFeignClients
public class FeignDemoApp {
    public static void main(String[] args) {
        SpringApplication.run(FeignDemoApp.class, args);
    }
}

然后定义 Feign 客户端提供的服务接口,示例代码如下:

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
 
import com.demo.feign.model.request.FeignDemoDetailRequest;
import com.demo.feign.model.response.FeignDemoDetailResponse;
import com.demo.feign.model.response.FeignDemoListResponse;
@FeignClient("spring-boot-feign-demo")
public interface FeignDemoClient {
 
    @RequestMapping(value="/demo/list", method=RequestMethod.GET)
    public FeignDemoListResponse queryListByCode(@PathVariable("code") String code);
     
    @RequestMapping(value="/demo/detail", method=RequestMethod.POST)
    public FeignDemoDetailResponse queryDetail(@RequestBody FeignDemoDetailRequest request);
}

这里定义的 FeignDemoDetailRequest,FeignDemoDetailResponse 和 FeignDemoListResponse 是定义的实体类,具体就不展示了。

常见问题

Feign 的 maven 依赖报红,或者主启动类上@EnableFeignClients不识别,一直报红,或者 feign 接口注入到控制器报红。

可能的原因及处理方案:

  • maven 包没有成功导入,或者 maven 包下载不完整,可以从仓库删掉依赖包后重新下载导入;
  • 版本冲突,或者无法获取适当版本,此时可以在 maven 包导入时指定版本号,尝试其他可用的版本。

项目 Application 启动时,使用 @Autowired 自动注入的 FeignClient 接口被告知对应的 Bean 无法寻获

***************************
APPLICATION FAILED TO START
***************************
 
Description:
Field feignDemoClient in com.xxx.xxx.service.impl.DemoServiceImpl required a bean of type 'com.xxx.xxx.feign.FeignDemoClient' that could not be found.
The injection point has the following annotations:
    - @org.springframework.beans.factory.annotation.Autowired(required=true)
 
Action:
Consider defining a bean of type 'com.xxx.xxx.feign.FeignDemoClient' in your configuration.
Disconnected from the target VM, address: '127.0.0.1:51645', transport: 'socket'
Process finished with exit code 1

可能的原因及处理方案:

  • 服务所在模块没有在 pom.xml 引入 spring-cloud-starter-openfeign 这个 maven 依赖,补上这个依赖重新构建项目即可。
  • 项目启动没有扫描 FeignClient 接口所在的包。项目通过启动类启动时默认会扫描同目录及同目录下级目录的类文件。所以,Spring注入第三方包或者其他模块的包,需要扫描需要注入的包。这种情况,只需要在启动类的注解中指定需要扫描的包路径即可,如:
// 开启Feign客户端,指定扫描 FeignClient 接口类所在的包
@EnableFeignClients("com.xxx.xxx.feign")
@SpringBootApplication

正确添加 Feign 依赖,启动类扫描 api 接口所有包路径,但注入接口仍然报红

这种情况现在比较少见,但是在一段时间以前出现比较频繁,主要是在 SpringBoot 2.0 版本后优化了相关逻辑。在 SpringBoot 2.0 之前,如果你的 Feign 接口使用 GetMapping 注解,那么注入该接口都会报红,无法注入。相应的,修改成 RequestMapping 或者 PostMapping 就能注入了。

处理方案:

1、采用合适的注解形式定义 Feign 接口。目前可行的定义方式基本有以下几种:

@FeignClient("spring-boot-feign-demo")
public interface FeignDemoClient {
    
    // 使用RequestMapping指定Get方法,入参单个传入
    @RequestMapping(value="/demo/list", method=RequestMethod.GET)
    public FeignDemoListResponse queryListByCode(@PathVariable("code") String code);
     
    // 使用RequestMapping指定Post方法,传入实体使用注解@RequestBody
    @RequestMapping(value="/demo/detail", method=RequestMethod.POST)
    public FeignDemoDetailResponse queryDetail(@RequestBody FeignDemoDetailRequest request);
    
    // 使用PostMapping,传入实体使用注解@RequestBody
    @PostMapping("/demo/seq")
    public FeignDemoSeqResponse querySeq(@RequestBody FeignDemoSeqRequest request);
}

通过 FeignClient 发起 Get 请求报 405 错误

通过在服务端断点捕获异常可以发现,报 405 错误的直接原因,其实是因为定义为 Get 的 Feign 接口,接收到 Post 方法的调用。但是在调用方调用时大多数也是采用 Get 方法,那么到底是什么原因呢?

暂且预设 Feign 接口的定义如下:

@FeignClient("spring-boot-feign-demo")
public interface FeignDemoClient {
    // 服务方接收到的请求是Post方法,而不是Get方法
    @GetMapping(value="/demo/list")
    public Response queryList(Request request);

实际上,通过断点跟踪接口调用时的调用路径,就会发现 FeignClient 最后是通过 HttpURLConnection 发起的网络连接,在发起的过程中,Connection 会判断自身请求的 body 是否为空。如果 body 不为空,则将 Get 方法转换成 Post 方法。因为 body 形式的数据只能方法 RequestBody 内以流的形式进行传输,而根据 Http 协议 param 形式的数据可以直接放在 URL 上进行传输和获取。

之所以 FeignClient 在网络请求时会出现这种转换,这跟它的初始化规则有关。在项目启动过程中,@FeignClient 直接的类会被初始化一个动态代理的类,并通过一个 RequestTemplate.Factory 的工厂类生成请求模板,具体规则如下:

  • 如果基本类型参数有 @RequestParam 注解,则会将参数作为 key 放入 RequestTemplate.Factory 中,通过 urlIndex 记录数组索引。在进行解析时,通过 key 从数组中获取具体的参数值,拼接在 url 后面。
  • 如果参数没有任何注解,或者有 @RequestBody 注解,那么初始化时会使用 bodyIndex 维护参数索引,并通过 bodyType 记录参数的具体类型。

需要注意的是,@RequestParam 只能用于对单个基本类型参数的注解,不能用来注解一个实体类。使用实体类作为入参出参时,建议还是使用 Post 方法进行请求。

如果在开发中觉得维护以上的对应关系不方便的话,还有另外一种修改方法可供使用,基本原理就是使用 Apache 的 HTTP Client 替换 Feign 原生的 Http Client,替换后 Get 方法也可以用一个实体类作为请求参数而不用担心请求被转换成 Post 方法了。具体修改方式如下:

引入 http client 依赖

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId><br>    
    <version>4.5.2</version>
</dependency>
<dependency>
    <groupId>com.netflix.feign</groupId>
    <artifactId>feign-httpclient</artifactId>
    <version>8.18.0</version>
</dependency>

开启 Feign 对 httpClient 的设置

feign.httpclient.enabled=true

完成配置修改后,内部就可以使用 Apache 的 http client。Feign 接口的定义是相同的,但是由于 Get 方法支持了自定义实体类,与 Post 有类似的处理方式,因此参数的传输需要我们额外指定其类型,以确保 JSON 序列化与反序列化的正常进行。

这里给出一个示例接口定义:

@FeignClient("spring-boot-feign-demo")
public interface FeignDemoClient {
    @PostMapping(value="/demo/detail", consumes = MediaType.APPLICATION_JSON_VALUE)
    public Response<List<ResultDTO>> query(@RequestBody FeignQueryRequest request, 
                                           @PathVariable("page") Integer page, 
                                           @PathVariable("page_size") Integer pageSize);
}

JSON 反序列化失败

Error while extracting response for type [com.xxx.xxx.feign] and content type [application/json].Can not deserialize instance of java.util.ArrayList out of START_OBJECT token

翻译过来的意思大致就是,Feign 接口的返回值无法通过 application/json 的格式解析出来,也就是调用方返回值的定义就服务方不一致(结构不同)。

处理方案:

确保双方引入的接口 api 完全一致,可通过将接口所在模块打包成 jar 包,双方引用同一个 jar 等方式以保证接口定义一致。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • springboot FeignClient注解及参数

    一.FeignClient注解 FeignClient注解被@Target(ElementType.TYPE)修饰,表示FeignClient注解的作用目标在接口上 @FeignClient(name = "github-client", url = "https://api.github.com", configuration = GitHubExampleConfig.class) public interface GitHubClient { @Request

  • Spring Cloud 中@FeignClient注解中的contextId属性详解

    目录 @FeignClient注解中的contextId属性 解决方法一 解决方法二 FeignClient注解及参数问题 问题背景 解决办法 @FeignClient注解中的contextId属性 在使用@FeignClient注解前,我们需要先引入其相关依赖,版本为3.0.1 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter

  • SpringCloud之@FeignClient()注解的使用方式

    目录 @FeignClient()注解的使用 @FeignClient标签的常用属性如下 SpringCloud 服务间互相调用 @FeignClient注解 我在FEIGN-CONSUMER 在FEIGN-CONSUMER 这是项目中的Controller层 @FeignClient()注解的使用 由于SpringCloud采用分布式微服务架构,难免在各个子模块下存在模块方法互相调用的情况.比如service-admin服务要调用service-card 服务的方法. @FeignClient

  • SpringCloud引入feign失败或找不到@EnableFeignClients注解问题

    目录 引入feign失败或找不到@EnableFeignClients注解 改成下面试试 springboot版本改成 springcloud版本改成 SpringCloud的坑-@EnableFeignClients 引入feign失败或找不到@EnableFeignClients注解 改成下面试试 <dependency>     <groupId>org.springframework.cloud</groupId>     <artifactId>s

  • Spring Cloud @EnableFeignClients注解的属性字段basePacka详解

    @EnableFeignClients注解的属性字段basePacka 一般情况下,我们在启动类上面添加了@EnableFeignClients注解就是表明当前应用服务(我们称之为服务A)中有的地方想要引用其它应用服务(我们称之为服务B)中的接口. 如果服务B可以单独启动起来并且注册到注册中心,则我们仅仅在服务A的启动类中添加@EnableFeignClients注解即可:如果服务B没有单独启动起来,而是以Jar包的形式被引入到服务A中,则服务A在启动的时候是不会主动去加载服务B中标注了@Fei

  • 关于注解FeignClient的使用规范

    注解FeignClient使用规范 首先是对FeignClient里的常用属性 contextId:当有多个服务调用方法不想写在一个接口里,就要使用到 name:指定FeignClient的名称,如果项目使用了Ribbon,name属性会作为微服务的名称,用于服务发现 url:url一般用于调试,可以手动指定@FeignClient调用的地址 fallback:定义容错的处理类,当调用远程接口失败或超时时,会调用对应接口的容错逻辑,fallback指定的类必须实现@FeignClient标记的接

  • 关于@Valid注解大全以及用法规范

    目录 @Valid注解大全及用法规范 @Valid注解规范用户请求的参数 业务场景 业务出现的问题 优化的解决方案 @Valid注解大全及用法规范 注解 描述 @AssertFalse 带注解的元素必须为false,支持boolean/Boolean @AssertTrue 带注解的元素必须为true,支持boolean/Boolean @DecimalMax 带注解的元素必须是一个数字,其值必须小于等于指定的最大值 @DecimalMin 带注解的元素必须是一个数字,其值必须大于等于指定的最小

  • Spring AOP如何整合redis(注解方式)实现缓存统一管理详解

    前言 项目使用redis作为缓存数据,但面临着问题,比如,项目A,项目B都用到redis,而且用的redis都是一套集群,这样会带来一些问题. 问题:比如项目A的开发人员,要缓存一些热门数据,想到了redis,于是乎把数据放入到了redis,自定义一个缓存key:hot_data_key,数据格式是项目A自己的数据格式,项目B也遇到了同样的问题,也要缓存热门数据,也是hot_data_key,数据格式是项目B是自己的数据格式,由于用的都是同一套redis集群,这样key就是同一个key,有的数据

  • JSR303校验注解和自定义校验注解的使用

    引入validation依赖 <!--JSR303依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-validation</artifactId> </dependency> Null检查 @Null(message = "")       验证对象是否为null

  • Jax-rs规范下REST接口使用方法详解

    REST接口目前有2种方式: 一种是遵循了jax-rs规范的,使用的是@Path,@PathParam等注解.一种是Spring自有的一套,使用的是@RestController,@GetMapping等注解. 如何开发jax-rs规范的REST接口呢? 在SpringBoot项目中,可以按如下步骤进行: 1. 引入依赖: spring-boot-starter-jersey 2. 添加配置: public class JerseyConfig extends ResourceConfig{ p

  • @FeignClient注入找不到异常如何解决

    前言 Springcloud中的服务间调用是通过Feign进行调用的,在调用方服务中,我们需要定义一些带有@FeignClient注解的接口类.并且在启动类上加上@EnableFeignClients注解. 程序启动的时候,会检查是否有@EnableFeignClients注解,如果有该注解,则开启包扫描,扫描带有@FeignClient注解的接口. 这里结合之前遇到的一个问题来和大家一起学习下@EnableFeignClients启动过程. 问题描述 之前搭建一个简单demo的时候,启动之后总

  • Springboot @RequestBody注解踩坑记录

    目录 @RequestBody注解踩坑 @RequestBodyjson注入Bean属性为空 @RequestBody注解的一些注意事项 @RequestBody注解踩坑 @RequestBody json注入Bean属性为空 1.接收JSON数据注入到Bean中,必须要加RuquestBody注解 2.判断属性名称字段是否相同 3.spring 默认不为首字母大写的JavaBean进行赋值操作,若首字母大写进行赋值操作需加入@JsonProperty(value=“AlarmTime”)注解

  • 使用FeignClient进行微服务交互方式(微服务接口互相调用)

    目录 使用FeignClient进行微服务交互 先写一个公共方法 然后写一个Feign调用 被Feign调用的方法如下 @FeignClient调用微服务注意事项 FeignClient接口不能使用@GettingMapping之类的组合注解 FeignClient接口中如果使用到@PathVariable FeignClient多参数的构造 使用FeignClient进行微服务交互 先写一个公共方法   public String getSettingValue(String name) {

随机推荐