SpringCloud Open feign 使用okhttp 优化详解

  
   org.springframework.boot
   spring-boot-starter-web
   
    
    
     spring-boot-starter-tomcat
     org.springframework.boot
    
   
  
  
   org.springframework.boot
   spring-boot-starter-aop
  
  
  
   org.springframework.boot
   spring-boot-starter-undertow
  
  
  
   io.github.openfeign
   feign-okhttp
  

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

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

import lombok.extern.log4j.Log4j2;
import okhttp3.Interceptor;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import java.io.IOException;
@Log4j2
public 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;
 }
}

 @Bean
 public Contract feignContract() {
  return new feign.Contract.Default();
 }

import com.netflix.loadbalancer.ILoadBalancer;
//….
@ConditionalOnClass({ILoadBalancer.class, Feign.class})
@Configuration
@AutoConfigureBefore({FeignAutoConfiguration.class}) // 本配置类具备优先权
@EnableConfigurationProperties({FeignHttpClientProperties.class})
@Import({
HttpClientFeignLoadBalancedConfiguration.class, //配置：包装ApacheHttpClient实例的负载均衡客户端
OkHttpFeignLoadBalancedConfiguration.class, //配置：包装OkHttpClient 实例的负载均衡客户端
DefaultFeignLoadBalancedConfiguration.class //配置：包装Client.Default 实例的负载均衡客户端
})
public class FeignRibbonClientAutoConfiguration {
 //空的构造器
 public FeignRibbonClientAutoConfiguration() {
 }
//….
}

  
  
   org.springframework.cloud
   spring-cloud-starter-netflix-ribbon
  

package com.netflix.loadbalancer;
import java.util.List;
public interface ILoadBalancer {
 // 通过负载均衡算法计算server服务器
Server chooseServer(Object var1);
// 取得全部的服务器
List getAllServers();
//…
}

@Configuration
@ConditionalOnClass({ApacheHttpClient.class})
@ConditionalOnProperty(
 value = {"feign.httpclient.enabled"},
 matchIfMissing = true
)
class HttpClientFeignLoadBalancedConfiguration {
 //空的构造器
 HttpClientFeignLoadBalancedConfiguration() {
 }
 @Bean
 @ConditionalOnMissingBean({Client.class})
public Client feignClient(
CachingSpringLoadBalancerFactory cachingFactory,
SpringClientFactory clientFactory, HttpClient httpClient) 
{
  ApacheHttpClient delegate = new ApacheHttpClient(httpClient);
  return new LoadBalancerFeignClient(delegate, cachingFactory, clientFactory); // 进行包装
 }
//…省略不相干的代码
}

 
   io.github.openfeign
   feign-httpclient
   9.5.1
   
  

 org.apache.httpcomponents
 httpclient
 ${httpclient.version}
 

@Configuration
@ConditionalOnClass({OkHttpClient.class})
@ConditionalOnProperty("feign.okhttp.enabled")
class OkHttpFeignLoadBalancedConfiguration {
 //空的构造器
 OkHttpFeignLoadBalancedConfiguration () {
 }
 @Bean
 @ConditionalOnMissingBean({Client.class})
public Client feignClient(
CachingSpringLoadBalancerFactory cachingFactory,
SpringClientFactory clientFactory, HttpClient httpClient) 
{
  OkHttpClient delegate = new OkHttpClient (httpClient);
  return new LoadBalancerFeignClient(delegate, cachingFactory, clientFactory); // 进行包装
 }
//…省略不相干的代码
}

 com.squareup.okhttp3
 okhttp



 io.github.openfeign
 feign-okhttp

feign.httpclient.enabled=false
feign.okhttp.enabled=true

package org.springframework.cloud.openfeign.ribbon;
//…省略import
@Configuration
class DefaultFeignLoadBalancedConfiguration {
 DefaultFeignLoadBalancedConfiguration() {
 }
 @Bean
 @ConditionalOnMissingBean
public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory,
 SpringClientFactory clientFactory)
 {
  return new LoadBalancerFeignClient(
new Default((SSLSocketFactory)null,
 (HostnameVerifier)null), cachingFactory, clientFactory);
 }
}