一、全局配置自定义

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 使用场景

统一添加 header 信息；

对 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

引入依赖

<dependency>

<groupId>io.github.openfeign</groupId>

<artifactId>feign-httpclient</artifactId>

</dependency>

修改yml配置

开启feign ,这里可以不用配置，可以参考源码分析

feign:

httpclient:

#使用apache httpclient做请求，而不是jdk的HttpUrlConnection

enabled: true

# feign最大链接数 默认200

max-connections: 200

#feign 单个路径的最大连接数 默认 50

max-connections-per-route: 50

源码分析 FeignAutoConfiguration

此时默认增加一个ApacheHttpCient实现类

4.3 设置OkHttp

引入依赖

<dependency>

<groupId>io.github.openfeign</groupId>

<artifactId>feign-okhttp</artifactId>

</dependency>

增加配置

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;

}

最后

最近很多宝子都在准备面试吧，正好我这儿有之前整理的一些高频面试题，或许对你有帮助。需要的可私信【面试题】领取。

需要领取的小伙伴可以私信我 【面试题】

需要领取的小伙伴可以私信我 【面试题】