SpringCloud Open feign 使用okhttp 优化

<!--web 模块 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <exclusions> <!--排除tomcat依赖 --> <exclusion> <artifactId>spring-boot-starter-tomcat</artifactId> <groupId>org.springframework.boot</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> </dependency> <!--undertow容器 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-undertow</artifactId> </dependency> <!-- feign-okhttp --> <dependency> <groupId>io.github.openfeign</groupId> <artifactId>feign-okhttp</artifactId> </dependency>

配置pom,容器使用undertow，引入feign-okhttp

feign: # Okhttp参数配置 httpclient: enabled: false okhttp: enabled: true max-connections: 200 # 默认值 max-connections-per-route: 50 # 默认值

application.yml文件配置okhttp参数

import feign.Feign;import okhttp3.ConnectionPool;import org.springframework.boot.autoconfigure.AutoConfigureBefore;import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;import org.springframework.cloud.openfeign.FeignAutoConfiguration;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import java.util.concurrent.TimeUnit;@Configuration@ConditionalOnClass(Feign.class)@AutoConfigureBefore(FeignAutoConfiguration.class)public class FeignOkHttpConfig { @Bean public okhttp3.OkHttpClient okHttpClient(){ return new okhttp3.OkHttpClient.Builder() //设置连接超时 .connectTimeout(60, TimeUnit.SECONDS) //设置读超时 .readTimeout(60, TimeUnit.SECONDS) //设置写超时 .writeTimeout(120,TimeUnit.SECONDS) //是否自动重连 .retryOnConnectionFailure(true) .connectionPool(new ConnectionPool()) .addInterceptor(new OkHttpLogInterceptor()) //构建OkHttpClient对象 .build(); }}

创建FeignOkHttpConfig类文件

import lombok.extern.log4j.Log4j2;import okhttp3.Interceptor;import okhttp3.Request;import okhttp3.Response;import okhttp3.ResponseBody;import java.io.IOException;@Log4j2public class OkHttpLogInterceptor implements Interceptor { @Override public Response intercept(Interceptor.Chain chain) throws IOException { //这个chain里面包含了request和response，所以你要什么都可以从这里拿 Request request = chain.request(); long t1 = System.nanoTime();//请求发起的时间 log.info(String.format("发送请求 %s on %s%n%s", request.url(), chain.connection(), request.headers())); Response response = chain.proceed(request); long t2 = System.nanoTime();//收到响应的时间 //这里不能直接使用response.body().string()的方式输出日志 //因为response.body().string()之后，response中的流会被关闭，程序会报错，我们需要创建出一 //个新的response给应用层处理 ResponseBody responseBody = response.peekBody(1024 * 1024); log.info(String.format("接收响应: [%s] %n返回json:【%s】 %.1fms%n%s", response.request().url(), responseBody.string(), (t2 - t1) / 1e6d, response.headers())); return response; }}

创建OkHttpLogInterceptor日志拦截文件

注意FeignOkHttpConfig中添加 @Bean public Contract feignContract() { return new feign.Contract.Default(); } feigin请求的@PostMapping @GetMapping等会不受支持

图一，Feign通过jdk中的HttpURLConnection
图二，Feign使用okhttp请求