信息发布→ 登录 注册 退出

spring cloud服务间调用之feign

发布时间:2025-07-13

点击量:

在微服务架构盛行的时代,我们将一个大型系统拆分成多个服务。为了完成一个业务逻辑,可能需要调用不同的服务。例如,订单服务需要调用会员服务。我们可以使用jdk自带的urlconnection或apache的httpclient来进行调用,但使用feign则是最优雅的选择。

Feign让我们在调用远程服务时,感觉就像在调用本地方法一样,完全察觉不到这是一个远程方法调用,也感觉不到这是一个HTTP请求。

Feign结合了Ribbon的负载均衡功能,同时与Hystrix结合可以实现熔断和降级。此外,Feign还支持GZIP压缩。

Feign的工作原理是在程序启动时自动扫描带有@FeignClients注解的类,并将其注入到Spring IOC容器中。当调用定义的Feign接口方法时,会使用JDK的动态代理生成RequestTemplate。生成代理时,会为每个接口方法创建一个RequestTemplate对象,该对象封装了HTTP请求所需的信息,如参数和请求方法等。

RequestTemplate生成request对象后,将request交给client处理。默认的client是JDK原生的URLConnection或Apache的HttpClient,当然也可以使用OKhttp。之后,client会被封装成LoadBalanceClient,这个类结合Ribbon提供负载均衡来发起服务间的调用。

Feign入门案例

  1. 引入依赖

    org.springframework.cloud
    spring-cloud-starter-openfeign
  1. 启动类通过注解开启
/** 
 * 会员服务 
 */
@SpringBootApplication(scanBasePackages = { "com.ding" })
@EnableDiscoveryClient
@EnableFeignClients
public class MemberApplication {
    public static void main(String[] args) {
        SpringApplication.run(MemberApplication.class, args);
    }
}

其中,@EnableFeignClients注解表示在项目启动时,会自动扫描带有@FeignClient注解的类并进行处理。

  1. 编写接口
package com.ding.member.api;

import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import com.ding.core.Result; import com.ding.member.dto.MemberDto; import com.ding.member.hystrix.MemberQueryFeignHystrix;

@FeignClient(value ="cloud-member",fallback=MemberQueryFeignHystrix.class) public interface MemberQueryFeignApi { @RequestMapping(value = "/memberQueryFeign/getMemberById",method=RequestMethod.GET) Result getMemberById(@RequestParam(value = "memberId")Long memberId); }

Feign超时设置

Feign超时分为两种:Ribbon超时和Hystrix超时。在高版本中,Hystrix默认是关闭的。

Feign默认client的替换

Feign默认使用JDK原生的URLConnection发送HTTP请求,没有连接池,但对每个地址保持一个长连接。我们可以通过Apache的HttpClient来替换,通过设置连接池和超时时间等来优化。

使用Apache的HttpClient替换

  1. 引入依赖

  1. 修改配置文件

使用OkHttp替换

  1. 引入依赖

  1. 修改配置文件

使用POST和GET传递实体参数

在实际开发中,我们经常将多个参数封装成一个POJO用于参数接收。在Spring MVC中,GET请求可以直接绑定POJO,但在Feign中,GET请求不能这样做。POST请求可以通过addUser(User user)来解决。

解决方案包括:

  1. 将参数拆成独立的属性,放在方法参数列表中,如addUser(Integer age, String name)
  2. 将参数变成一个Map进行传递和接收。
  3. 使用GET请求传递@RequestBody,但这违反了RESTful规范,如addUser(@RequestBody User user)
  4. 使用Feign的拦截器,通过实现Feign的RequestInterceptor的apply方法,统一拦截使用GET方法并通过body传递参数。

第一次请求失败

当Feign结合了Ribbon和Hystrix后,可能会出现首次调用超时失败。原因是Hystrix默认超时时间为1秒,如果在这个时间内没有响应,就会进入fallback方法进行熔断。而Spring的懒加载机制,bean的加载和装配是在使用时才执行,因此Feign首次请求会比较慢,从而出现这个问题。解决方案是延长熔断时间。

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=

全局配置

全局配置非常简单,可以直接使用ribbon.key=value的方式设置Ribbon的各项默认参数。例如:

# 以下配置全局有效
ribbon.eureka.enabled=true

建立连接超时时间,原1000

ribbon.ConnectTimeout=60000

请求处理的超时时间,5分钟

ribbon.ReadTimeout=60000

所有操作都重试

ribbon.OkToRetryOnAllOperations=true

重试发生,更换节点数最大值

ribbon.MaxAutoRetriesNextServer=10

单个节点重试最大值

ribbon.MaxAutoRetries=1

在许多情况下,我们需要个性化设置,比如为每个服务设置不同的配置:

# 以下配置对服务cloud-member有效
cloud-member.ribbon.eureka.enabled=true

建立连接超时时间,原1000

cloud-member.ribbon.ConnectTimeout=60000

请求处理的超时时间,5分钟

cloud-member.ribbon.ReadTimeout=60000

所有操作都重试

cloud-member.ribbon.OkToRetryOnAllOperations=true

重试发生,更换节点数最大值

cloud-member.ribbon.MaxAutoRetriesNextServer=10

单个节点重试最大值

cloud-member.ribbon.MaxAutoRetries=1

传递Token

在许多情况下,我们会发现当外部请求经过网关到达服务A(可以获取token)后,再到达服务B时token丢失,导致token验证失败。我们可以使用拦截器来处理这个问题。

开启Feign调用日志

我们可以为每个Feign client开启日志。在application.properties文件中,使用logging.level.FeignClient的参数配置格式来开启指定Feign客户端的DEBUG日志。

@FeignClient(value ="cloud-member",fallback=MemberQueryFeignHystrix.class)
public interface MemberQueryFeignApi {
@RequestMapping(value = "/memberQueryFeign/getMemberById",method=RequestMethod.GET)
Result getMemberById(@RequestParam(value = "memberId")Long memberId);
}

在配置文件中:

logging.level.com.ding.member.api.MemberQueryFeignApi=DEBUG

仅添加上述配置无法实现DEBUG日志的输出。这是由于Feign客户端默认对Logger.Level对象定义为NONE级别,该级别不会记录任何Feign调用过程中的信息,因此我们需要调整其级别。

@EnableEurekaClient
@SpringBootApplication
@EnableFeignClients
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Bean
public Logger.Level feignLoggerLevel() {
return Logger.Level.FULL;
}
}

NONE:不记录任何信息。 BASIC:仅记录请求方法、URL以及响应状态码和执行时间。 HEADERS:除了记录BASIC级别的信息之外,还会记录请求和响应的头信息。 FULL:记录所有请求与响应的细节,包括头信息、请求体、元数据等。

参考《重新定义Spring Cloud》Spring Cloud Feign使用详解

标签:# 可以使用  # Token  # 接口  # map  # 对象  # okhttp  # http  # 负载均衡  # 重试  # Logging  # 是在  # 配置文件  # 首次  # 多个  # 这个问题  # 这是一个  # 我们可以  # 可以直接  # restful  # apache  # ai  # 会员  # spring mvc  # 动态代理  # asic  # mvc  # spring  # linux  # 架构  # ribbon  # spring cloud  # hystrix  # String  # Integer  # 封装  
在线客服
服务热线

服务热线

4008888355

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!