Feign 使用HttpClient和OkHttp方式
更新時(shí)間：2021年10月01日 10:34:10 作者：歐拉兔
這篇文章主要介紹了Feign 使用HttpClient和OkHttp方式，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
使用HttpClient和OkHttp
在Feign中，Client是一個(gè)非常重要的組件，F(xiàn)eign最終發(fā)送Request請求以及接收Response響應(yīng)都是由Client組件來完成的。Client在Feign源碼中是一個(gè)接口，在默認(rèn)情況下，Client的實(shí)現(xiàn)類是Client.Default。Client.Default是由HttpURLConnection來實(shí)現(xiàn)網(wǎng)絡(luò)請求的。另外,Client還支持HttpClient和OkHttp來進(jìn)行網(wǎng)絡(luò)請求。
首先查看FeignRibbonClient的自動(dòng)配置類FeignRibbonClientAutoConfiguration，該類在程序啟動(dòng)的時(shí)候注入一些Bean，其中注入了一個(gè)BeanName為feignClient的Client類型的Bean。在省缺配置BeanName為FeignClient的Bean的情況下，會(huì)自動(dòng)注入Client.Default這個(gè)對象，跟蹤C(jī)lient.Default源碼,Client.Default使用的網(wǎng)絡(luò)請求框架是HttpURLConnection，代碼如下：
public static class Default implements Client {
private final SSLSocketFactory sslContextFactory;
private final HostnameVerifier hostnameVerifier;
public Default(SSLSocketFactory sslContextFactory, HostnameVerifier hostnameVerifier) {
this.sslContextFactory = sslContextFactory;
this.hostnameVerifier = hostnameVerifier;
}
public Response execute(Request request, Options options) throws IOException {
HttpURLConnection connection = this.convertAndSend(request, options);
return this.convertResponse(connection, request);
}
......//代碼省略
}
這種情況下，由于缺乏連接池的支持，在達(dá)到一定流量的后服務(wù)肯定會(huì)出問題 。
使用HttpClient
那么如何在Feign中使用HttpClient的框架呢？我們查看FeignAutoConfiguration.HttpClientFeignConfiguration的源碼：
@Configuration
@ConditionalOnClass({ApacheHttpClient.class})
@ConditionalOnMissingClass({"com.netflix.loadbalancer.ILoadBalancer"})
@ConditionalOnMissingBean({CloseableHttpClient.class})
@ConditionalOnProperty(
value = {"feign.httpclient.enabled"},
matchIfMissing = true
)
protected static class HttpClientFeignConfiguration {
private final Timer connectionManagerTimer = new Timer("FeignApacheHttpClientConfiguration.connectionManagerTimer", true);
@Autowired(
required = false
)
private RegistryBuilder registryBuilder;
private CloseableHttpClient httpClient;
protected HttpClientFeignConfiguration() {
}
@Bean
@ConditionalOnMissingBean({HttpClientConnectionManager.class})
public HttpClientConnectionManager connectionManager(ApacheHttpClientConnectionManagerFactory connectionManagerFactory, FeignHttpClientProperties httpClientProperties) {
final HttpClientConnectionManager connectionManager = connectionManagerFactory.newConnectionManager(httpClientProperties.isDisableSslValidation(), httpClientProperties.getMaxConnections(), httpClientProperties.getMaxConnectionsPerRoute(), httpClientProperties.getTimeToLive(), httpClientProperties.getTimeToLiveUnit(), this.registryBuilder);
this.connectionManagerTimer.schedule(new TimerTask() {
public void run() {
connectionManager.closeExpiredConnections();
}
}, 30000L, (long)httpClientProperties.getConnectionTimerRepeat());
return connectionManager;
}
@Bean
public CloseableHttpClient httpClient(ApacheHttpClientFactory httpClientFactory, HttpClientConnectionManager httpClientConnectionManager, FeignHttpClientProperties httpClientProperties) {
RequestConfig defaultRequestConfig = RequestConfig.custom().setConnectTimeout(httpClientProperties.getConnectionTimeout()).setRedirectsEnabled(httpClientProperties.isFollowRedirects()).build();
this.httpClient = httpClientFactory.createBuilder().setConnectionManager(httpClientConnectionManager).setDefaultRequestConfig(defaultRequestConfig).build();
return this.httpClient;
}
@Bean
@ConditionalOnMissingBean({Client.class})
public Client feignClient(HttpClient httpClient) {
return new ApacheHttpClient(httpClient);
}
@PreDestroy
public void destroy() throws Exception {
this.connectionManagerTimer.cancel();
if (this.httpClient != null) {
this.httpClient.close();
}
}
}
從代碼@ConditionalOnClass({ApacheHttpClient.class})注解可知，只需要在pom文件上加上HttpClient依賴即可。另外需要在配置文件中配置feign.httpclient.enabled為true，從@ConditionalOnProperty注解可知，這個(gè)配置可以不寫，因?yàn)樵谀J(rèn)情況下就為true:
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
<version>9.4.0</version>
</dependency>
使用OkHttp
查看FeignAutoConfiguration.HttpClientFeignConfiguration的源碼：
@Configuration
@ConditionalOnClass({OkHttpClient.class})
@ConditionalOnMissingClass({"com.netflix.loadbalancer.ILoadBalancer"})
@ConditionalOnMissingBean({okhttp3.OkHttpClient.class})
@ConditionalOnProperty({"feign.okhttp.enabled"})
protected static class OkHttpFeignConfiguration {
private okhttp3.OkHttpClient okHttpClient;
protected OkHttpFeignConfiguration() {
}
@Bean
@ConditionalOnMissingBean({ConnectionPool.class})
public ConnectionPool httpClientConnectionPool(FeignHttpClientProperties httpClientProperties, OkHttpClientConnectionPoolFactory connectionPoolFactory) {
Integer maxTotalConnections = httpClientProperties.getMaxConnections();
Long timeToLive = httpClientProperties.getTimeToLive();
TimeUnit ttlUnit = httpClientProperties.getTimeToLiveUnit();
return connectionPoolFactory.create(maxTotalConnections, timeToLive, ttlUnit);
}
@Bean
public okhttp3.OkHttpClient client(OkHttpClientFactory httpClientFactory, ConnectionPool connectionPool, FeignHttpClientProperties httpClientProperties) {
Boolean followRedirects = httpClientProperties.isFollowRedirects();
Integer connectTimeout = httpClientProperties.getConnectionTimeout();
Boolean disableSslValidation = httpClientProperties.isDisableSslValidation();
this.okHttpClient = httpClientFactory.createBuilder(disableSslValidation).connectTimeout((long)connectTimeout, TimeUnit.MILLISECONDS).followRedirects(followRedirects).connectionPool(connectionPool).build();
return this.okHttpClient;
}
@PreDestroy
public void destroy() {
if (this.okHttpClient != null) {
this.okHttpClient.dispatcher().executorService().shutdown();
this.okHttpClient.connectionPool().evictAll();
}
}
@Bean
@ConditionalOnMissingBean({Client.class})
public Client feignClient(okhttp3.OkHttpClient client) {
return new OkHttpClient(client);
}
}
同理，如果想要在Feign中使用OkHttp作為網(wǎng)絡(luò)請求框架，則只需要在pom文件中加上feign-okhttp的依賴，代碼如下：
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-okhttp</artifactId>
<version>10.2.0</version>
</dependency>
OpenFeign替換為OkHttp
pom中引入feign-okhttp
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-okhttp</artifactId>
</dependency>
在application.yml中配置okhttp
feign:
httpclient:
connection-timeout: 2000 #單位ms,默認(rèn)2000
max-connections: 200 #線程池最大連接數(shù)
okhttp:
enabled: true
經(jīng)過上面設(shè)置已經(jīng)可以使用okhttp了，因?yàn)樵贔eignAutoConfiguration中已實(shí)現(xiàn)自動(dòng)裝配
如果需要對okhttp做更精細(xì)的參數(shù)設(shè)置，那需要自定義okhttp的實(shí)現(xiàn)，可以模仿上圖中的實(shí)現(xiàn)
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
您可能感興趣的文章:
- Android OKHttp源碼解析Https安全處理
- Minio與SpringBoot使用okhttp3問題解決
- Android開發(fā)OkHttp執(zhí)行流程源碼分析
- 解決OkHttp接收gzip壓縮數(shù)據(jù)返回亂碼問題
- Android使用OKhttp3實(shí)現(xiàn)登錄注冊功能+springboot搭建后端的詳細(xì)過程
- 淺談HttpClient、okhttp和RestTemplate的區(qū)別
- Android的簡單前后端交互(okHttp+springboot+mysql)
- OKhttp攔截器實(shí)現(xiàn)實(shí)踐環(huán)節(jié)源碼解析
相關(guān)文章
字符串廣泛應(yīng)用在Java編程中,在Java中字符串屬于對象,Java提供了String類來創(chuàng)建和操作字符串,下面這篇文章主要給大家介紹了Java中字符串初始化的相關(guān)資料,需要的朋友可以參考下2021-08-08
Java中SpringSecurity密碼錯(cuò)誤5次鎖定用戶的實(shí)現(xiàn)方法
這篇文章主要介紹了Java中SpringSecurity密碼錯(cuò)誤5次鎖定用戶的實(shí)現(xiàn)方法,非常不錯(cuò)，具有參考借鑒價(jià)值，需要的朋友可以參考下2017-03-03
如何解決shardingsphere報(bào)錯(cuò)Missing?the?data?source?name:‘null‘
使用ShardingSphere進(jìn)行分庫操作時(shí),如果遇到“Missing?the?datasource?name:?‘null’”的錯(cuò)誤,通常是因?yàn)樗僮鞯谋頉]有配置相關(guān)的路由信息,例如,如果在properties中僅配置了health_record和health_task的路由規(guī)則2024-11-11
springBoot動(dòng)態(tài)加載jar及如何將類注冊到IOC
在SpringBoot項(xiàng)目中動(dòng)態(tài)加載jar文件并將其類注冊到IOC容器是一種高級應(yīng)用方式,,這種方法為SpringBoot項(xiàng)目提供了更靈活的擴(kuò)展能力,使得項(xiàng)目可以在不修改原有代碼的基礎(chǔ)上增加新的功能模塊,感興趣的朋友一起看看吧2024-11-11
springboot 定時(shí)任務(wù)@Scheduled實(shí)現(xiàn)解析
這篇文章主要介紹了springboot 定時(shí)任務(wù)@Scheduled實(shí)現(xiàn)解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-09-09
Java中去掉字符串的最后一個(gè)逗號(hào)有多種實(shí)現(xiàn)方法,不同的方法適用于不同的場景,本文通過實(shí)例代碼介紹Java去掉字符串最后一個(gè)逗號(hào)的相關(guān)知識(shí),感興趣的朋友一起看看吧2023-12-12
JAVA實(shí)現(xiàn)基于Tcp協(xié)議的簡單Socket通信實(shí)例
本篇文章主要介紹了JAVA實(shí)現(xiàn)基于Tcp協(xié)議的簡單Socket通信實(shí)例，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-01-01
這篇文章主要介紹了java壓縮多個(gè)文件并且返回流示例，返回壓縮流主是為了在程序里再做其它操作,需要的朋友可以參考下2014-03-03
SpringBoot設(shè)置接口超時(shí)時(shí)間的方法
這篇文章主要介紹了SpringBoot設(shè)置接口超時(shí)時(shí)間的方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-08-08
Spring實(shí)戰(zhàn)之搜索Bean類操作示例
這篇文章主要介紹了Spring實(shí)戰(zhàn)之搜索Bean類操作,結(jié)合實(shí)例形式分析了Spring搜索Bean類的相關(guān)配置、接口實(shí)現(xiàn)與操作技巧,需要的朋友可以參考下2019-12-12