spring cloud服务间调用之feign-linux运维-PHP中文网

spring cloud服务间调用之feign

看不見的法師

发布： 2025-07-13 09:42:26

原创

731人浏览过

在微服务架构盛行的时代，我们将一个大型系统拆分成多个服务。为了完成一个业务逻辑，可能需要调用不同的服务。例如，订单服务需要调用会员服务。我们可以使用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入门案例

引入依赖

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

登录后复制

启动类通过注解开启

/** 
 * 会员服务 
 */
@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;
<p>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;</p><p>@FeignClient(value ="cloud-member",fallback=MemberQueryFeignHystrix.class)
public interface MemberQueryFeignApi {
@RequestMapping(value = "/memberQueryFeign/getMemberById",method=RequestMethod.GET)
Result<MemberDto> getMemberById(@RequestParam(value = "memberId")Long memberId);
}

登录后复制

Feign超时设置

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

spring cloud服务间调用之feign

Feign默认client的替换

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

使用Apache的HttpClient替换

引入依赖

spring cloud服务间调用之feign

修改配置文件

spring cloud服务间调用之feign

使用OkHttp替换

引入依赖

spring cloud服务间调用之feign

修改配置文件

spring cloud服务间调用之feign

使用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传递参数。

spring cloud服务间调用之feign

第一次请求失败

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

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

登录后复制

全局配置

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

# 以下配置全局有效
ribbon.eureka.enabled=true</p><h1>建立连接超时时间，原1000</h1><p>ribbon.ConnectTimeout=60000</p><h1>请求处理的超时时间，5分钟</h1><p>ribbon.ReadTimeout=60000</p><h1>所有操作都重试</h1><p>ribbon.OkToRetryOnAllOperations=true</p><h1>重试发生，更换节点数最大值</h1><p>ribbon.MaxAutoRetriesNextServer=10</p><h1>单个节点重试最大值</h1><p>ribbon.MaxAutoRetries=1

登录后复制

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

# 以下配置对服务cloud-member有效
cloud-member.ribbon.eureka.enabled=true</p><h1>建立连接超时时间，原1000</h1><p>cloud-member.ribbon.ConnectTimeout=60000</p><h1>请求处理的超时时间，5分钟</h1><p>cloud-member.ribbon.ReadTimeout=60000</p><h1>所有操作都重试</h1><p>cloud-member.ribbon.OkToRetryOnAllOperations=true</p><h1>重试发生，更换节点数最大值</h1><p>cloud-member.ribbon.MaxAutoRetriesNextServer=10</p><h1>单个节点重试最大值</h1><p>cloud-member.ribbon.MaxAutoRetries=1

登录后复制

传递Token

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

spring cloud服务间调用之feign

开启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<MemberDto> 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使用详解

以上就是spring cloud服务间调用之feign的详细内容，更多请关注php中文网其它相关文章！