/**
 * @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);

}

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

	/**
	 * 指定FeignClient的名稱，如果項(xiàng)目使用了Ribbon，name屬性會(huì)作為微服務(wù)的名稱，用于服務(wù)發(fā)現(xiàn)
	 */
	@AliasFor("name")
	String value() default "";
	@Deprecated
	String serviceId() default "";
	@AliasFor("value")
	String name() default "";
	
	/**
	 * Sets the <code>@Qualifier</code> value for the feign client.
	 * 這個(gè)bean在應(yīng)用上下文中的名字為接口的全限定名，你也可以使用 @FeignClient 注解中的 qualifier 屬性給bean指定一個(gè)別名
	 */
	String qualifier() default "";

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

	/**
	 * 當(dāng)發(fā)生404錯(cuò)誤，如果該字段為true，會(huì)調(diào)用decoder進(jìn)行解碼，否則拋出FeignException
	 */
	boolean decode404() default false;

	/**
	 * 指定FeignClient 的配置類，優(yōu)先級(jí)最高，默認(rèn)的配置類為 FeignClientsConfiguration類
	 */
	Class<?>[] configuration() default {};

	/**
	 * 配置熔斷器的處理類
	 */
	Class<?> fallback() default void.class;

	/**
	 * 工廠類，用于生產(chǎn)fallback類示例，通過這個(gè)屬性我們可以實(shí)現(xiàn)每個(gè)接口通用的容錯(cuò)邏輯，減少重復(fù)代碼
	 */
	Class<?> fallbackFactory() default void.class;

	/**
	 * 定義統(tǒng)一的路徑前綴
	 */
	String path() default "";

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

/**
 * @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);
}

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

  /**
   * 自定義重試機(jī)制
   * @return
   */
  @Bean
  public Retryer feignRetryer() {
    //fegin提供的默認(rèn)實(shí)現(xiàn)，最大請(qǐng)求次數(shù)為5，初始間隔時(shí)間為100ms，下次間隔時(shí)間1.5倍遞增，重試間最大間隔時(shí)間為1s，
    return new Retryer.Default();
  }
}

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

  /**
   * 自定義重試機(jī)制
   * @return
   */
  @Bean
  public Retryer feignRetryer() {
    //最大請(qǐng)求次數(shù)為5，初始間隔時(shí)間為100ms，下次間隔時(shí)間1.5倍遞增，重試間最大間隔時(shí)間為1s，
    return new Retryer.Default();
  }

  @Bean
  public ErrorDecoder feignError() {
    return (key, response) -> {
      if (response.status() == 400) {
        log.error("請(qǐng)求xxx服務(wù)400參數(shù)錯(cuò)誤,返回:{}", response.body());
      }

      if (response.status() == 409) {
        log.error("請(qǐng)求xxx服務(wù)409異常,返回:{}", response.body());
      }

      if (response.status() == 404) {
        log.error("請(qǐng)求xxx服務(wù)404異常,返回:{}", response.body());
      }

      // 其他異常交給Default去解碼處理
      // 這里使用單例即可，Default不用每次都去new
      return new ErrorDecoder.Default().decode(key, response);
    };
  }

}

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

  /**
   * 自定義重試機(jī)制
   * @return
   */
  @Bean
  public Retryer feignRetryer() {
    //最大請(qǐng)求次數(shù)為5，初始間隔時(shí)間為100ms，下次間隔時(shí)間1.5倍遞增，重試間最大間隔時(shí)間為1s，
    return new Retryer.Default();
  }

  @Bean
  public ErrorDecoder feignError() {
    return (key, response) -> {
      if (response.status() == 400) {
        log.error("請(qǐng)求xxx服務(wù)400參數(shù)錯(cuò)誤,返回:{}", response.body());
      }

      if (response.status() == 409) {
        log.error("請(qǐng)求xxx服務(wù)409異常,返回:{}", response.body());
      }

      if (response.status() == 404) {
        log.error("請(qǐng)求xxx服務(wù)404異常,返回:{}", response.body());
      }

      // 其他異常交給Default去解碼處理
      // 這里使用單例即可，Default不用每次都去new
      return new ErrorDecoder.Default().decode(key, response);
    };
  }

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

      // 如果是get請(qǐng)求
      if (template.method().equals(Request.HttpMethod.GET.name())) {
        //獲取到get請(qǐng)求的參數(shù)
        Map<String, Collection<String>> queries = template.queries();
      }

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

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

      String sign = "根據(jù)請(qǐng)求參數(shù)生成的簽名";
      //放入url？之后
      template.query("sign", sign);

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