Spring Cloud Feign 自定义配置(重试、拦截与错误码处理) 代码实践
基于spring-boot-starter-parent2.1.9.RELEASE,spring-cloud-openfeign2.1.3.RELEASE
引子
Feign是一个声明式、模板化的HTTP客户端，简化了系统发起Http请求。创建它时，只需要创建一个接口，然后加上FeignClient注解,使用它时，就像调用本地方法一样，作为开发者的我们完全感知不到这是在调用远程的方法，也感知不到背后发起了HTTP请求：
/**
*@authoraxin
*@suammryxx客户端
*/
@FeignClient(value="xxClient",url="${xx.host:www.axin.com}")
publicinterfaceDemoClient{
@PostMapping(value="/xxx/url",headers="Content-Type=application/json"})
yourResponserequestHTTP(@RequestBodyJSONObjectparam);
}
上述的代码就是一个定义一个FeignHTTP客户端，在其他类中只需要@AutowiredDemoClient，就可以像调用本地方法一样发起HTTP请求。
介绍就到这，接下来进入主题，因为FeignClient将发起HTTP请求与解析返回报文都做了包装，如果你的业务场景需要定制一些调用机制，比如：
- 我想在发起请求响应超时失败时自动重试——自定义重试机制
- 我想单独对某些异常的HTTP状态码特殊处理——自定义ErrorDecoder
- 服务端接口需要验证签名，所以我方在发起请求时要生成签名然后传过去——定义Fegin拦截器
基于此，本文就以上述3个需求场景为例来介绍如何自定义FeignClient的配置
FeignClient的默认配置类
FeignClient默认的配置类为FeignClientsConfiguration，这个类在spring-cloud-netflix-core的jar包下。
默认注入了很多Feign相关的配置Bean，包括FeignRetryer、FeignLoggerFactory和FormattingConversionService等。另外，Decoder、Encoder和Contract这3个类在没有Bean被注入的情况下，会自动注入默认配置的Bean，即ResponseEntityDecoder、SpringEncoder和SpringMvcContract。
如果你不知道如何自己定义配置时，不放点进去看看人家默认配置是如何实现的。这里就不晒源码了。
FeignClient注解参数
每个注解参数都做了注释，详情请见下方源码：
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public@interfaceFeignClient{
/**
*指定FeignClient的名称，如果项目使用了Ribbon，name属性会作为微服务的名称，用于服务发现
*/
@AliasFor("name")
Stringvalue()default"";
@Deprecated
StringserviceId()default"";
@AliasFor("value")
Stringname()default"";
/**
*Setsthe@Qualifiervalueforthefeignclient.
*这个bean在应用上下文中的名字为接口的全限定名，你也可以使用@FeignClient注解中的qualifier属性给bean指定一个别名
*/
Stringqualifier()default"";
/**
*url地址
*/
Stringurl()default"";
/**
*当发生404错误，如果该字段为true，会调用decoder进行解码，否则抛出FeignException
*/
booleandecode404()defaultfalse;
/**
*指定FeignClient的配置类，优先级最高，默认的配置类为FeignClientsConfiguration类
*/
Class[]configuration()default{};
/**
*配置熔断器的处理类
*/
Classfallback()defaultvoid.class;
/**
*工厂类，用于生产fallback类示例，通过这个属性我们可以实现每个接口通用的容错逻辑，减少重复代码
*/
ClassfallbackFactory()defaultvoid.class;
/**
*定义统一的路径前缀
*/
Stringpath()default"";
/**
*Whethertomarkthefeignproxyasaprimarybean.Defaultstotrue.
*/
booleanprimary()defaulttrue;
}
自定义Feign配置类
在SpringCloud中，你可以通过@FeignClient注解声明额外的配置(比FeignClientsConfiguration级别高)去控制feign客户端，以一开始的feign接口为例:
/**
*@authoraxin
*@suammryxx客户端
*/
@FeignClient(value="xxClient",url="${xx.host:www.axin.com}",configuration=MyConfiguration.class)
publicinterfaceDemoClient{
@PostMapping(value="/xxx/url",headers="Content-Type=application/json"})
yourResponserequestHTTP(@RequestBodyJSONObjectparam);
}
在上面这个示例中，feign客户端在MyConfiguration中的配置将会覆盖FeignClientsConfiguration中的配置。
要注意的是：MyConfiguration不需要使用@Configuration注解。如果加上了，它将全局生效。
Retryer-重试机制的自定义
/**
*@authoraxin
*@summaryfegin客户端的自定义配置
*/
publicclassMyConfiguration{
/**
*自定义重试机制
*@return
*/
@Bean
publicRetryerfeignRetryer(){
//fegin提供的默认实现，最大请求次数为5，初始间隔时间为100ms，下次间隔时间1.5倍递增，重试间最大间隔时间为1s，
returnnewRetryer.Default();
}
}
ErrorDecoder-错误解码器的自定义
当feign调用返回HTTP报文时，会触发这个方法，方法内可以获得HTTP状态码，可以用来定制一些处理逻辑等等。
/**
*@authoraxin
*@summaryfegin客户端的自定义配置
*/
@Slf4j
publicclassMyConfiguration{
/**
*自定义重试机制
*@return
*/
@Bean
publicRetryerfeignRetryer(){
//最大请求次数为5，初始间隔时间为100ms，下次间隔时间1.5倍递增，重试间最大间隔时间为1s，
returnnewRetryer.Default();
}
@Bean
publicErrorDecoderfeignError(){
return(key,response)->{
if(response.status()==400){
log.error("请求xxx服务400参数错误,返回:{}",response.body());
}
if(response.status()==409){
log.error("请求xxx服务409异常,返回:{}",response.body());
}
if(response.status()==404){
log.error("请求xxx服务404异常,返回:{}",response.body());
}
//其他异常交给Default去解码处理
//这里使用单例即可，Default不用每次都去new
returnnewErrorDecoder.Default().decode(key,response);
};
}
}
采用了lambda的写法，response变量是Response类型，通过status()方法可以拿到返回的HTTP状态码，body()可以获得到响应报文。
Feign拦截器实践
拦截器在请求发出之前执行，在拦截器代码里可以修改请求参数，header等等，如果你有签名生成的需求，可以放在拦截器中来实现
/**
*@authoraxin
*@summaryfegin客户端的自定义配置
*/
@Slf4j
publicclassMyConfiguration{
/**
*自定义重试机制
*@return
*/
@Bean
publicRetryerfeignRetryer(){
//最大请求次数为5，初始间隔时间为100ms，下次间隔时间1.5倍递增，重试间最大间隔时间为1s，
returnnewRetryer.Default();
}
@Bean
publicErrorDecoderfeignError(){
return(key,response)->{
if(response.status()==400){
log.error("请求xxx服务400参数错误,返回:{}",response.body());
}
if(response.status()==409){
log.error("请求xxx服务409异常,返回:{}",response.body());
}
if(response.status()==404){
log.error("请求xxx服务404异常,返回:{}",response.body());
}
//其他异常交给Default去解码处理
//这里使用单例即可，Default不用每次都去new
returnnewErrorDecoder.Default().decode(key,response);
};
}
/**
*fegin拦截器
*@return
*/
@Bean
publicRequestInterceptorcameraSign(){
returntemplate->{
//如果是get请求
if(template.method().equals(Request.HttpMethod.GET.name())){
//获取到get请求的参数
Map>queries=template.queries();
}
//如果是Post请求
if(template.method().equals(Request.HttpMethod.POST.name())){
//获得请求body
Stringbody=template.requestBody().asString();
JSONPObjectrequest=JSON.parseObject(body,JSONPObject.class);
}
//Dowhatyouwant...例如生成接口签名
Stringsign="根据请求参数生成的签名";
//放入url？之后
template.query("sign",sign);
//放入请求body中
StringnewBody="原有body"+sign;
template.body(Request.Body.encoded(newBody.getBytes(StandardCharsets.UTF_8),StandardCharsets.UTF_8));
};
}
}
可以看到代码中给了如何获取请求参数和修改请求参数的示例。
总结
小结一下，对于开头提出的场景：
- 我想在发起请求响应超时失败时自动重试——自定义重试机制
- 我想单独对某些异常的HTTP状态码特殊处理——自定义ErrorDecoder
- 服务端接口需要验证签名，所以我方在发起请求时要生成签名然后传过去——定义Fegin拦截器
给出了自定义feign配置的方式实现的样例代码，希望对你有用，如果有更好的方式简化HTTP请求，欢迎留言分享~
参考链接
重新定义SpringCloud实战
SpringCloudNetflix官方文档
总结
到此这篇关于SpringCloudFeign自定义配置(重试、拦截与错误码处理)实践的文章就介绍到这了,更多相关SpringCloudFeign自定义配置内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。