在微服务架构盛行的时代,我们将一个大型系统拆分成多个服务。为了完成一个业务逻辑,可能需要调用不同的服务。例如,订单服务需要调用会员服务。我们可以使用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入门案例
- 引入依赖
org.springframework.cloud spring-cloud-starter-openfeign
- 启动类通过注解开启
/**
* 会员服务
*/
@SpringBootApplication(scanBasePackages = { "com.ding" })
@EnableDiscoveryClient
@EnableFeignClients
public class MemberApplication {
public static void main(String[] args) {
SpringApplication.run(MemberApplication.class, args);
}
}其中,@EnableFeignClients注解表示在项目启动时,会自动扫描带有@FeignClient注解的类并进行处理。
- 编写接口
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替换
- 引入依赖

- 修改配置文件

使用OkHttp替换
- 引入依赖

- 修改配置文件

使用POST和GET传递实体参数
在实际开发中,我们经常将多个参数封装成一个POJO用于参数接收。在Spring MVC中,GET请求可以直接绑定POJO,但在Feign中,GET请求不能这样做。POST请求可以通过addUser(User user)来解决。
解决方案包括:
- 将参数拆成独立的属性,放在方法参数列表中,如
addUser(Integer age, String name)。 - 将参数变成一个Map进行传递和接收。
- 使用GET请求传递@RequestBody,但这违反了RESTful规范,如
addUser(@RequestBody User user)。 - 使用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使用详解










