spring cloud服务间调用之feign

发布时间 - 2025-07-13 00:00:00    点击率:

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


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


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: 北京专业网站制作设计师招聘,北京白云观官方网站?  宙斯浏览器视频悬浮窗怎么开启 边看视频边操作其他应用教程  Python进程池调度策略_任务分发说明【指导】  zabbix利用python脚本发送报警邮件的方法  如何获取上海专业网站定制建站电话?  微信h5制作网站有哪些,免费微信H5页面制作工具?  nodejs redis 发布订阅机制封装实现方法及实例代码  微信小程序 wx.uploadFile无法上传解决办法  网站制作软件有哪些,制图软件有哪些?  制作公司内部网站有哪些,内网如何建网站?  北京网站制作的公司有哪些,北京白云观官方网站?  桂林网站制作公司有哪些,桂林马拉松怎么报名?  html5如何实现懒加载图片_ intersectionobserver api用法【教程】  Laravel怎么上传文件_Laravel图片上传及存储配置  Laravel辅助函数有哪些_Laravel Helpers常用助手函数大全  如何用VPS主机快速搭建个人网站?  Laravel怎么实现模型属性转换Casting_Laravel自动将JSON字段转为数组【技巧】  Swift中循环语句中的转移语句 break 和 continue  Laravel的路由模型绑定怎么用_Laravel Route Model Binding简化控制器逻辑  Laravel如何实现数据导出到CSV文件_Laravel原生流式输出大数据量CSV【方案】  音响网站制作视频教程,隆霸音响官方网站?  Laravel事件监听器怎么写_Laravel Event和Listener使用教程  JavaScript数据类型有哪些_如何准确判断一个变量的类型  C++用Dijkstra(迪杰斯特拉)算法求最短路径  潮流网站制作头像软件下载,适合母子的网名有哪些?  如何快速生成ASP一键建站模板并优化安全性?  今日头条微视频如何找选题 今日头条微视频找选题技巧【指南】  Android中Textview和图片同行显示(文字超出用省略号,图片自动靠右边)  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱?  关于BootStrap modal 在IOS9中不能弹出的解决方法(IOS 9 bootstrap modal ios 9 noticework)  Laravel与Inertia.js怎么结合_使用Laravel和Inertia构建现代单页应用  nginx修改上传文件大小限制的方法  HTML5空格和nbsp有啥关系_nbsp的作用及使用场景【说明】  七夕网站制作视频,七夕大促活动怎么报名?  BootStrap整体框架之基础布局组件  Python自然语言搜索引擎项目教程_倒排索引查询优化案例  Laravel如何使用withoutEvents方法临时禁用模型事件  JavaScript常见的五种数组去重的方式  Laravel如何实现图片防盗链功能_Laravel中间件验证Referer来源请求【方案】  安克发布新款氮化镓充电宝:体积缩小 30%,支持 200W 输出  如何快速查询网站的真实建站时间?  Linux系统命令中tree命令详解  Laravel如何使用查询构建器?(Query Builder高级用法)  Bootstrap整体框架之CSS12栅格系统  打开php文件提示内存不足_怎么调整php内存限制【解决方案】  如何用西部建站助手快速创建专业网站?  网站制作价目表怎么做,珍爱网婚介费用多少?  Laravel怎么自定义错误页面_Laravel修改404和500页面模板  网易LOFTER官网链接 老福特网页版登录地址  教你用AI将一段旋律扩展成一首完整的曲子