一、全局配置自定義

1、代碼配置

• 方式一:讓父子上下文ComponentScan重疊（強烈不建議使用）

  @Configuration
  public class StockFeignConfiguration {
      /**
       * 日志級別
       * 通過源碼可以看到日志等級有 4 種，分別是：
       * NONE：不輸出日志。
       * BASIC：只輸出請求方法的 URL 和響應的狀態碼以及接口執行的時間。
       * HEADERS：將 BASIC 信息和請求頭信息輸出。
       * FULL：輸出完整的請求信息。
       */
      @Bean
      public Logger.Level level(){
          return Logger.Level.FULL;
      }
  }
  

• 方式二【唯一正確的途徑】: EnableFeignClients(defaultConfiguration=xxx.class)

2、屬性配置

logging:
  level:
    com.nx: debug
feign:
  client:
    config:
      default:
        loggerLevel: full

二、 支持的配置項

1、契約配置

Spring Cloud 在 Feign 的基礎上做了擴展，可以讓 Feign 支持 Spring MVC 的注解來調用。原生的 Feign 是不支持 Spring MVC 注解的，如果你想在 Spring Cloud 中使用原生的注解方式來定義客戶端也是 可以的，通過配置契約來改變這個配置，Spring Cloud 中默認的是 SpringMvcContract。

1.1代碼方式

    /**
     * 修改契約配置，這里僅僅支持Feign原生注解
     * 這里是一個擴展點，如果我們想支持其他的注解，可以更改Contract的實現類。
     * @return
     */
    @Bean
    public Contract feignContract(){
        return new Contract.Default();
    }

注意：這里修改了契約配置之后，我們就只能用Fegin的原生注解

1.2 屬性方式

2、編解碼

Feign 中提供了自定義的編碼解碼器設置，同時也提供了多種編碼器的實現，比如 Gson、Jaxb、Jackson。 我們可以用不同的編碼解碼器來處理數據的傳輸。。

擴展點：Encoder & Decoder

默認我們使用：SpringEncoder和SpringDecoder

package feign.codec;
public interface Encoder {
  void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException;
}
復制代碼

package feign.codec;
public interface Decoder {
  Object decode(Response response, Type type) throws IOException, DecodeException, FeignException;
}
復制代碼

2.1 代碼方式

@Bean
public Decoder decoder(){
    return new CustomDecoder();
}
@Bean
public Encoder encoder(){
    return new CustomEncoder();
}
復制代碼

2.2 屬性方式

feign:
  client:
    config:
      #想要調用的微服務的名稱
      msb-user:
        encoder: com.xxx.CustomDecoder
        decoder: com.xxx..CustomEncoder
復制代碼

3、攔截器

通常我們調用的接口都是有權限控制的，很多時候可能認證的值是通過參數去傳遞的，還有就是通過請求頭 去傳遞認證信息，比如 Basic 認證方式。

3.1 擴展點：

package feign;

public interface RequestInterceptor {
  void Apply(RequestTemplate template);
}
復制代碼

3.2 使用場景

1. 統一添加 header 信息；
2. 對 body 中的信息做修改或替換；

3.3 自定義邏輯

package com.msb.order.interceptor;

import feign.RequestInterceptor;
import feign.RequestTemplate;

public class FeignAuthRequestInterceptor implements RequestInterceptor {

    private String tokenId;

    public FeignAuthRequestInterceptor(String tokenId) {
        this.tokenId = tokenId;
    }

    @Override
    public void apply(RequestTemplate template) {
        template.header("Authorization",tokenId);
    }
}
復制代碼

package com.msb.order.configuration;

import com.msb.order.interceptor.FeignAuthRequestInterceptor;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FeignConfig {
    @Value("${feign.tokenId}")
    private String tokenId;

    /**
     * 自定義攔截器
     * @return
     */

    @Bean
    public FeignAuthRequestInterceptor feignAuthRequestInterceptor(){
        return new FeignAuthRequestInterceptor(tokenId);
    }
}
復制代碼

feign:
  tokenId: d874528b-a9d9-46df-ad90-b92f87ccc557
復制代碼

在msb-stock項目中增加springmvc中的攔截器

攔截器代碼：

package com.msb.stock.interceptor;
import JAVAx.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@Slf4j
public class AuthInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        boolean flag = true;
        // 邏輯認證
        String authorization = request.getHeader("Authorization");
        log.info("獲取的認證信息 Authorization：{}",authorization);
        if(StringUtils.hasText(authorization)){
            return true;
        }
        return false;
    }
}
復制代碼

增加類配置:

package com.nx.user.interceptor;

import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
@Configuration
public class WebMvcConfig extends WebMvcConfigurationSupport {
    @Override
    protected void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new AuthInterceptor());
    }

復制代碼

優先級：

全局代碼<全局屬性<細粒度代碼<細粒度屬性
復制代碼

4、Client 設置

Feign 中默認使用 JDK 原生的 URLConnection 發送 HTTP 請求，我們可以集成別的組件來替換掉 URLConnection，比如 Apache HttpClient，OkHttp。

4.1 擴展點

Feign發起調用真正執行邏輯：feign.Client#execute （擴展點）

public interface Client {
  Response execute(Request request, Options options) throws IOException;
 }

4.2 配置Apache HttpClient

1. 引入依賴

   <dependency>
       <groupId>io.github.openfeign</groupId>
       <artifactId>feign-httpclient</artifactId>
   </dependency>
   

2. 修改yml配置

   開啟feign ,這里可以不用配置，可以參考源碼分析

   feign:
     httpclient:
       #使用apache httpclient做請求，而不是jdk的HttpUrlConnection
       enabled: true
       # feign最大鏈接數 默認200
       max-connections: 200
       #feign 單個路徑的最大連接數  默認 50
       max-connections-per-route: 50
   

3. 源碼分析 FeignAutoConfiguration

此時默認增加一個ApacheHttpCient實現類

4.3 設置OkHttp

1. 引入依賴

   <dependency>
       <groupId>io.github.openfeign</groupId>
       <artifactId>feign-okhttp</artifactId>
   </dependency>
   復制代碼
   

2. 增加配置

   feign:
     okhttp:
       enabled: true
       #線程池可以使用httpclient的配置   
     httpclient:
       max-connections: 200
       max-connections-per-route: 50
   復制代碼
   

3、源碼分析 FeignAutoConfiguration

5、超時配置

通過 Options 可以配置連接超時時間和讀取超時時間，Options 的第一個參數是連接的超時時間（ms）， 默認值是 10s；第二個是請求處理的超時時間（ms），默認值是 60s。

Request.Options

5.1 代碼配置

@Bean
public Request.Options options(){
    return new Request.Options(2000,50000);
}

msb-stock改造

@GetMapping("query")
public User queryInfo(User user){
    try {
        Thread.sleep(10*1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return user;
}