亲宝软件园·资讯

展开

Spring Cloud Feign 自定义配置 Spring Cloud Feign 自定义配置(重试、拦截与错误码处理) 代码实践

上帝爱吃苹果- 人气:0
想了解Spring Cloud Feign 自定义配置(重试、拦截与错误码处理) 代码实践的相关内容吗,上帝爱吃苹果-在本文为您仔细讲解Spring Cloud Feign 自定义配置的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Spring,Cloud,Feign,自定义配置,Spring,Cloud,Feign,下面大家一起来学习吧。

基于 spring-boot-starter-parent 2.1.9.RELEASE, spring-cloud-openfeign 2.1.3.RELEASE

引子

Feign 是一个声明式、模板化的HTTP客户端,简化了系统发起Http请求。创建它时,只需要创建一个接口,然后加上FeignClient注解,使用它时,就像调用本地方法一样,作为开发者的我们完全感知不到这是在调用远程的方法,也感知不到背后发起了HTTP请求:

/**
 * @author axin
 * @suammry xx 客户端
 */
@FeignClient(value = "xxClient",url = "${xx.host:www.axin.com}")
public interface DemoClient {

  @PostMapping(value = "/xxx/url", headers = "Content-Type=application/json"})
  yourResponse requestHTTP(@RequestBody JSONObject param);

}

上述的代码就是一个定义一个Feign HTTP 客户端,在其他类中只需要 @Autowired DemoClient,就可以像调用本地方法一样发起HTTP请求。

介绍就到这,接下来进入主题,因为 FeignClient 将发起HTTP请求与解析返回报文都做了包装,如果你的业务场景需要定制一些调用机制,比如:

基于此,本文就以上述3个需求场景为例来介绍如何自定义 FeignClient 的配置

FeignClient的默认配置类

Feign Client 默认的配置类为 FeignClientsConfiguration, 这个类在 spring-cloud-netflix-core 的 jar 包下。

默认注入了很多 Feign 相关的配置Bean,包括FeignRetryer、 FeignLoggerFactory 和 FormattingConversionService 等。另外,Decoder、Encoder和 Contract 这3个类在没有Bean被注入的情况下,会自动注入默认配置的 Bean,即ResponseEntity Decoder、SpringEncoder 和 SpringMvcContract。

如果你不知道如何自己定义配置时,不放点进去看看人家默认配置是如何实现的。这里就不晒源码了。

FeignClient 注解参数

每个注解参数都做了注释,详情请见下方源码:

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface FeignClient {

	/**
	 * 指定FeignClient的名称,如果项目使用了Ribbon,name属性会作为微服务的名称,用于服务发现
	 */
	@AliasFor("name")
	String value() default "";
	@Deprecated
	String serviceId() default "";
	@AliasFor("value")
	String name() default "";
	
	/**
	 * Sets the <code>@Qualifier</code> value for the feign client.
	 * 这个bean在应用上下文中的名字为接口的全限定名,你也可以使用 @FeignClient 注解中的 qualifier 属性给bean指定一个别名
	 */
	String qualifier() default "";

	/**
	 * url地址
	 */
	String url() default "";

	/**
	 * 当发生404错误,如果该字段为true,会调用decoder进行解码,否则抛出FeignException
	 */
	boolean decode404() default false;

	/**
	 * 指定FeignClient 的配置类,优先级最高,默认的配置类为 FeignClientsConfiguration类
	 */
	Class<?>[] configuration() default {};

	/**
	 * 配置熔断器的处理类
	 */
	Class<?> fallback() default void.class;

	/**
	 * 工厂类,用于生产fallback类示例,通过这个属性我们可以实现每个接口通用的容错逻辑,减少重复代码
	 */
	Class<?> fallbackFactory() default void.class;

	/**
	 * 定义统一的路径前缀
	 */
	String path() default "";

	/**
	 * Whether to mark the feign proxy as a primary bean. Defaults to true.
	 */
	boolean primary() default true;
}

自定义Feign配置类

在 Spring Cloud 中,你可以通过 @FeignClient 注解声明额外的配置(比 FeignClientsConfiguration 级别高)去控制feign客户端,以一开始的feign接口为例:

/**
 * @author axin
 * @suammry xx 客户端
 */
@FeignClient(value = "xxClient",url = "${xx.host:www.axin.com}",configuration = MyConfiguration.class)
public interface DemoClient {

  @PostMapping(value = "/xxx/url", headers = "Content-Type=application/json"})
  yourResponse requestHTTP(@RequestBody JSONObject param);
}

在上面这个示例中,feign客户端在MyConfiguration中的配置将会覆盖FeignClientsConfiguration中的配置。

要注意的是: MyConfiguration不需要使用@Configuration注解。如果加上了,它将全局生效。

Retryer-重试机制的自定义

/**
 * @author axin
 * @summary fegin 客户端的自定义配置
 */
public class MyConfiguration {

  /**
   * 自定义重试机制
   * @return
   */
  @Bean
  public Retryer feignRetryer() {
    //fegin提供的默认实现,最大请求次数为5,初始间隔时间为100ms,下次间隔时间1.5倍递增,重试间最大间隔时间为1s,
    return new Retryer.Default();
  }
}

ErrorDecoder-错误解码器的自定义

当feign调用返回HTTP报文时,会触发这个方法,方法内可以获得HTTP状态码,可以用来定制一些处理逻辑等等。

/**
 * @author axin
 * @summary fegin 客户端的自定义配置
 */
@Slf4j
public class MyConfiguration {

  /**
   * 自定义重试机制
   * @return
   */
  @Bean
  public Retryer feignRetryer() {
    //最大请求次数为5,初始间隔时间为100ms,下次间隔时间1.5倍递增,重试间最大间隔时间为1s,
    return new Retryer.Default();
  }

  @Bean
  public ErrorDecoder feignError() {
    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
      return new ErrorDecoder.Default().decode(key, response);
    };
  }

}

采用了lambda的写法,response变量是Response类型,通过status()方法可以拿到返回的HTTP状态码,body()可以获得到响应报文。

Feign拦截器实践

拦截器在请求发出之前执行,在拦截器代码里可以修改请求参数,header等等,如果你有签名生成的需求,可以放在拦截器中来实现

/**
 * @author axin
 * @summary fegin 客户端的自定义配置
 */
@Slf4j
public class MyConfiguration {

  /**
   * 自定义重试机制
   * @return
   */
  @Bean
  public Retryer feignRetryer() {
    //最大请求次数为5,初始间隔时间为100ms,下次间隔时间1.5倍递增,重试间最大间隔时间为1s,
    return new Retryer.Default();
  }

  @Bean
  public ErrorDecoder feignError() {
    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
      return new ErrorDecoder.Default().decode(key, response);
    };
  }

   /**
   * fegin 拦截器
   * @return
   */
  @Bean
  public RequestInterceptor cameraSign() {
    return template -> {

      // 如果是get请求
      if (template.method().equals(Request.HttpMethod.GET.name())) {
        //获取到get请求的参数
        Map<String, Collection<String>> queries = template.queries();
      }

      //如果是Post请求
      if (template.method().equals(Request.HttpMethod.POST.name())) {
        //获得请求body
        String body = template.requestBody().asString();
        JSONPObject request = JSON.parseObject(body, JSONPObject.class);
      }

      //Do what you want... 例如生成接口签名

      String sign = "根据请求参数生成的签名";
      //放入url?之后
      template.query("sign", sign);

      //放入请求body中
      String newBody = "原有body" + sign;
      template.body(Request.Body.encoded(newBody.getBytes(StandardCharsets.UTF_8), StandardCharsets.UTF_8));
    };
  }
}

可以看到代码中给了如何获取请求参数和修改请求参数的示例。

总结

小结一下,对于开头提出的场景:

  1. 我想在发起请求响应超时失败时自动重试 —— 自定义重试机制
  2. 我想单独对某些异常的HTTP状态码特殊处理 —— 自定义ErrorDecoder
  3. 服务端接口需要验证签名,所以我方在发起请求时要生成签名然后传过去 —— 定义 Fegin 拦截器

给出了自定义 feign 配置的方式实现的样例代码,希望对你有用,如果有更好的方式简化HTTP请求,欢迎留言分享~

参考链接

重新定义Spring Cloud实战

Spring Cloud Netflix官方文档

总结

加载全部内容

相关教程
猜你喜欢
用户评论