Spring Cloud全分析：服务调用之OpenFeign集成OkHttp

---

---

OpenFeign集成OkHttp

OpenFeign本质是HTTP来举行服务调用的，也就是须要集成一个Http客户端。
使用的是Client接口来举行哀求的

1. public interface Client {
3. // request是封装的请求方式、参数、返回值类型
4.   // options 是连接超时、读取超时等的配置项
5.   Response execute(Request request, Options options) throws IOException;
6. }

复制代码

默认是HttpURLConnection方式，也就是jdk中提供的最原始的谁人

1. public static class Default implements Client {
3.   @Override
4.   public Response execute(Request request, Options options) throws IOException {
5.     HttpURLConnection connection = convertAndSend(request, options);
6.     return convertResponse(connection).toBuilder().request(request).build();
7.   }
8. }

复制代码

HTTP毗连须要举行TCP三次握手，是一个比力耗时的使用，一样平常我们不直接使用HttpURLConnection，而是使用HttpClient/okHttp等支持毗连池的客户端工具，以Feign集成OkHttp为例
添加依赖

1.         <dependency>
2.             <groupId>io.github.openfeign</groupId>
3.             <artifactId>feign-okhttp</artifactId>
4.         </dependency>

复制代码

其包内有一个Client的实现类OkHttpClient，

1. public final class OkHttpClient implements Client {
3.   @Override
4.   public feign.Response execute(feign.Request input, feign.Request.Options options)
5.       throws IOException {
6.     okhttp3.OkHttpClient requestScoped;
7.     if (delegate.connectTimeoutMillis() != options.connectTimeoutMillis()
8.         || delegate.readTimeoutMillis() != options.readTimeoutMillis()) {
9.       requestScoped = delegate.newBuilder()
10.           .connectTimeout(options.connectTimeoutMillis(), TimeUnit.MILLISECONDS)
11.           .readTimeout(options.readTimeoutMillis(), TimeUnit.MILLISECONDS)
12.           .followRedirects(options.isFollowRedirects())
13.           .build();
14.     } else {
15.       requestScoped = delegate;
16.     }
17.     Request request = toOkHttpRequest(input);
18.     Response response = requestScoped.newCall(request).execute();
19.     return toFeignResponse(response, input).toBuilder().request(input).build();
20.   }
21. }

复制代码

设置毗连池

1. import okhttp3.ConnectionPool;
2. import okhttp3.OkHttpClient;
3. import org.springframework.context.annotation.Bean;
4. import org.springframework.context.annotation.Configuration;
6. import javax.net.ssl.*;
7. import java.security.KeyManagementException;
8. import java.security.NoSuchAlgorithmException;
9. import java.security.SecureRandom;
10. import java.security.cert.X509Certificate;
11. import java.util.concurrent.TimeUnit;
13. @Configuration
14. public class OkHttpConfig {
15.     /**
16.      * OkHttp 客户端配置
17.      *
18.      * @return OkHttp 客户端配
19.      */
20.     @Bean
21.     public OkHttpClient okHttpClient() {
22.         return new OkHttpClient.Builder()
23.                 .sslSocketFactory(sslSocketFactory(), x509TrustManager())
24.                 .hostnameVerifier(hostnameVerifier())
25.                 .retryOnConnectionFailure(false)    //是否开启缓存
26.                 .connectionPool(pool())             //连接池
27.                 .connectTimeout(15L, TimeUnit.SECONDS) // 连接超时时间
28.                 .readTimeout(15L, TimeUnit.SECONDS) // 读取超时时间
29.                 .followRedirects(true) // 是否允许重定向
30.                 .build();
31.     }
33.     /**
34.      * 忽略证书校验
35.      *
36.      * @return 证书信任管理器
37.      */
38.     @Bean
39.     public X509TrustManager x509TrustManager() {
40.         return new X509TrustManager() {
41.             @Override
42.             public void checkClientTrusted(X509Certificate[] x509Certificates, String s) {
43.             }
45.             @Override
46.             public void checkServerTrusted(X509Certificate[] x509Certificates, String s) {
47.             }
49.             @Override
50.             public X509Certificate[] getAcceptedIssuers() {
51.                 return new X509Certificate[0];
52.             }
53.         };
54.     }
56.     /**
57.      * 信任所有 SSL 证书
58.      *
59.      * @return
60.      */
61.     @Bean
62.     public SSLSocketFactory sslSocketFactory() {
63.         try {
64.             TrustManager[] trustManagers = new TrustManager[]{x509TrustManager()};
65.             SSLContext sslContext = SSLContext.getInstance("SSL");
66.             sslContext.init(null, trustManagers, new SecureRandom());
67.             return sslContext.getSocketFactory();
68.         } catch (NoSuchAlgorithmException | KeyManagementException e) {
69.             e.printStackTrace();
70.         }
71.         return null;
72.     }
74.     /**
75.      * 连接池配置
76.      *
77.      * @return 连接池
78.      */
79.     @Bean
80.     public ConnectionPool pool() {
81.         // 最大连接数、连接存活时间、存活时间单位（分钟）
82.         return new ConnectionPool(200, 5, TimeUnit.MINUTES);
83.     }
85.     /**
86.      * 信任所有主机名
87.      *
88.      * @return 主机名校验
89.      */
90.     @Bean
91.     public HostnameVerifier hostnameVerifier() {
92.         return (s, sslSession) -> true;
93.     }
94. }

复制代码

yml设置

要开启OkHttp ,还须要在YML 中添加开启设置项，默认是关闭的

1. feign:
2.   okhttp:
3.     enabled: true

复制代码

至于为什么须要配这个，看一下FeignAutoConfiguration中装配OkHttp的条件

1. @Configuration(proxyBeanMethods = false)
2. @ConditionalOnClass(OkHttpClient.class)
3. @ConditionalOnMissingClass("com.netflix.loadbalancer.ILoadBalancer")
4. @ConditionalOnMissingBean(okhttp3.OkHttpClient.class)
5. @ConditionalOnProperty("feign.okhttp.enabled")
6. protected static class OkHttpFeignConfiguration

复制代码

参考文献

• OpenFeign集成OkHttp
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！qidao123.com:ToB企服之家，中国第一个企服评测及软件市场,开放入驻,技术点评得现金