一、全局配置自定义
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;
}