一、全局配置自定義

1、代碼配置

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

  @Configuration
  public class StockFeignConfiguration {
      /**
       * 日志級(jí)別
       * 通過源碼可以看到日志等級(jí)有 4 種，分別是：
       * NONE：不輸出日志。
       * BASIC：只輸出請求方法的 URL 和響應(yīng)的狀態(tài)碼以及接口執(zhí)行的時(shí)間。
       * 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

二、 支持的配置項(xiàng)

1、契約配置

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

1.1代碼方式

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

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

1.2 屬性方式

2、編解碼

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

擴(kuò)展點(diǎn)：Encoder & Decoder

默認(rèn)我們使用：SpringEncoder和SpringDecoder

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

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

2.1 代碼方式

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

2.2 屬性方式

feign:
  client:
    config:
      #想要調(diào)用的微服務(wù)的名稱
      msb-user:
        encoder: com.xxx.CustomDecoder
        decoder: com.xxx..CustomEncoder
復(fù)制代碼

3、攔截器

通常我們調(diào)用的接口都是有權(quán)限控制的，很多時(shí)候可能認(rèn)證的值是通過參數(shù)去傳遞的，還有就是通過請求頭 去傳遞認(rèn)證信息，比如 Basic 認(rèn)證方式。

3.1 擴(kuò)展點(diǎn)：

package feign;

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

3.2 使用場景

1. 統(tǒng)一添加 header 信息；
2. 對(duì) 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);
    }
}
復(fù)制代碼

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);
    }
}
復(fù)制代碼

feign:
  tokenId: d874528b-a9d9-46df-ad90-b92f87ccc557
復(fù)制代碼

在msb-stock項(xiàng)目中增加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;
        // 邏輯認(rèn)證
        String authorization = request.getHeader("Authorization");
        log.info("獲取的認(rèn)證信息 Authorization：{}",authorization);
        if(StringUtils.hasText(authorization)){
            return true;
        }
        return false;
    }
}
復(fù)制代碼

增加類配置:

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());
    }

復(fù)制代碼

優(yōu)先級(jí)：

全局代碼<全局屬性<細(xì)粒度代碼<細(xì)粒度屬性
復(fù)制代碼

4、Client 設(shè)置

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

4.1 擴(kuò)展點(diǎn)

Feign發(fā)起調(diào)用真正執(zhí)行邏輯：feign.Client#execute （擴(kuò)展點(diǎn)）

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最大鏈接數(shù) 默認(rèn)200
       max-connections: 200
       #feign 單個(gè)路徑的最大連接數(shù)  默認(rèn) 50
       max-connections-per-route: 50
   

3. 源碼分析 FeignAutoConfiguration

此時(shí)默認(rèn)增加一個(gè)ApacheHttpCient實(shí)現(xiàn)類

4.3 設(shè)置OkHttp

1. 引入依賴

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

2. 增加配置

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

3、源碼分析 FeignAutoConfiguration

5、超時(shí)配置

通過 Options 可以配置連接超時(shí)時(shí)間和讀取超時(shí)時(shí)間，Options 的第一個(gè)參數(shù)是連接的超時(shí)時(shí)間（ms）， 默認(rèn)值是 10s；第二個(gè)是請求處理的超時(shí)時(shí)間（ms），默認(rèn)值是 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;
}