解決Feign切換client到okhttp無法生效的坑(出現(xiàn)原因說明)
提示:如果只看如何解決問題,請看文章的末尾如何解決這個問題
1. 場景描述
最近項目中使用了feign當做http請求工具來使用、相對于httpclient、resttemplate來說,fegin用起來方便很多。
然后項目有httptrace的需求,需要輸出請求日志。
所以就開啟了feign自己的日志,發(fā)現(xiàn)它自帶的日志是debug級別才能打印。而且是逐行打印的,看日志非常的不方便。所以需要輸出json格式的日志最好。
2.解決步驟
2.1 引入feign依賴
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${自行選擇適合項目的版本}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
這里使用了spring-cloud-openfeing來避免自己手工實現(xiàn)feign的注入,用法上和feign一樣
2.2 配置feign
在入口類上添加 @EnableFeignClients 注解
@SpringBootApplication
@EnableFeignClients
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
使用feing自己的Contract,方便使用feign自己的注解來聲明http接口。這里使用了一個配置類
@Configuration
public class FeignConfig {
@Bean
public Contract feignContract() {
return new feign.Contract.Default();
}
}
2.3 聲明接口
只需要聲明一個帶有@FeignClient注解的接口,就聲明好了一個Feign的http請求接口
@FeignClient(name = "accessPlatform", url = "${url.access-platform}")
public interface AccessPlatformFeignClient {
@RequestLine("GET /access-platform/resource")
List<AccessResource> queryResourceList(@QueryMap Map<String, Object> query);
}
3.切換Feign的客戶端為OkHttp
由于feign自帶的http客戶端實現(xiàn)是HttpURLConnection,沒有連接池功能,可配置能力也比較差,因此我們使用okhttp作為底層的http客戶端的具體實現(xiàn)。
3.1 引入okhttp的依賴
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-okhttp</artifactId>
<version>${feign-okhttp.version}</version>
</dependency>
3.2 修改之前的FeignConfig配置類
問題就出在這里、不過先不急,我們繼續(xù)
@Configuration
@ConditionalOnClass(Feign.class)
@AutoConfigureBefore(FeignAutoConfiguration.class)
public class FeignConfig {
// 注入feignContract
@Bean
public Contract feignContract() {
return new feign.Contract.Default();
}
// 注入自定義的okHttpClient
@Bean
public okhttp3.OkHttpClient okHttpClient(){
return new okhttp3.OkHttpClient.Builder()
.readTimeout(60, TimeUnit.SECONDS)
.connectTimeout(60, TimeUnit.SECONDS)
.writeTimeout(120, TimeUnit.SECONDS)
.connectionPool(new ConnectionPool())
.build();
}
}
開啟okhttp作為feign的客戶端
# application.yml feign: okhttp: enabled: true
一切完美、網(wǎng)上的許多博客也都是這么寫的。然后它們告訴你已經(jīng)配置完了?呵呵,你們到底自己試過沒有??
3.3 試著請求一下
當然這里出問題了,發(fā)出的請求并非來自okhttp,還是默認的JDK的HttpURLConnection,問題出在哪里呢?接著看
4.找出問題所在
我懷疑是feing在注入配置的時候,根本就沒有運行關(guān)于okhttp的配置
4.1 查看服務(wù)啟動時feign配置過程
1.將服務(wù)根日志級別調(diào)整為debug級別
logging: level: root: debug
2.啟動服務(wù)、查看控制臺輸出

看到?jīng)],okhttp的配置不符合配置運行條件。
3.查詢 FeignAutoConfiguration 這個配置類的細節(jié)
@Configuration
@ConditionalOnClass({Feign.class})
@EnableConfigurationProperties({FeignClientProperties.class, FeignHttpClientProperties.class})
public class FeignAutoConfiguration {
// .....其他的配置
@Configuration
@ConditionalOnClass({OkHttpClient.class})
@ConditionalOnMissingClass({"com.netflix.loadbalancer.ILoadBalancer"})
@ConditionalOnMissingBean({okhttp3.OkHttpClient.class})
@ConditionalOnProperty({"feign.okhttp.enabled"})
protected static class OkHttpFeignConfiguration {
// ...okhttp的配置
}
// .....其他的配置
}
就是這個自動配置類搞的鬼、當我看到 @ConditionalOnMissingBean({okhttp3.OkHttpClient.class}) 這個注解時,我就明白了。
翻成白話就是,只有當容器中沒有OkHttpClient的實例時。他才會運行。
如果在 FeignAutoConfiguration之前注入了我們自己定義的OkHttpClient實例,那不好意思,我不干了?無不注入。
5.解決問題
既然自動配置不干,那我們自己動手干。拷貝 FeignAutoConfiguration 配置類中的配置過程,粘貼在FeignConfig配置類中手動注入feign的client。Ok!完美解決。
@Configuration
@ConditionalOnClass(Feign.class)
@AutoConfigureAfter(FeignAutoConfiguration.class)
public class FeignConfig {
// private okhttp3.OkHttpClient okHttpClient;
@Bean
public Contract feignContract() {
return new feign.Contract.Default();
}
@Bean
@ConditionalOnMissingBean({Client.class})
public Client feignClient(okhttp3.OkHttpClient client) {
return new feign.okhttp.OkHttpClient(client);
}
@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 OkHttpClient client(OkHttpClientFactory httpClientFactory, ConnectionPool connectionPool, FeignHttpClientProperties httpClientProperties) {
Boolean followRedirects = httpClientProperties.isFollowRedirects();
Integer connectTimeout = httpClientProperties.getConnectionTimeout();
Boolean disableSslValidation = httpClientProperties.isDisableSslValidation();
return httpClientFactory.createBuilder(disableSslValidation)
.connectTimeout((long)connectTimeout, TimeUnit.MILLISECONDS)
.followRedirects(followRedirects)
.connectionPool(connectionPool)
.addInterceptor(new OkHttpLogInterceptor()) // 自定義請求日志攔截器
.build();
}
}
6.小結(jié)
如果你沒有耐心看完所有的過程的話。就記住一句話:用自己手動注入Feign的Client實現(xiàn),來代替 Feign的自動配置所做的過程就好了。
具體的配置請看第5點
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。
相關(guān)文章
Java靜態(tài)方法不能調(diào)用非靜態(tài)成員的原因分析
在Java中,靜態(tài)方法是屬于類的方法,而不是屬于對象的方法,它可以通過類名直接調(diào)用,無需創(chuàng)建對象實例,非靜態(tài)成員指的是類的實例變量和實例方法,它們需要通過對象實例才能訪問和調(diào)用,本文小編將和大家一起探討Java靜態(tài)方法為什么不能調(diào)用非靜態(tài)成員2023-10-10
SpringBoot基于過濾器和內(nèi)存實現(xiàn)重復請求攔截功能
這篇文章主要介紹了SpringBoot基于過濾器和內(nèi)存實現(xiàn)重復請求攔截,這里我們使用過濾器的方式對進入服務(wù)器的請求進行過濾操作,實現(xiàn)對相同客戶端請求同一個接口的過濾,需要的朋友可以參考下2023-01-01
mybatis-plus IdWorker生成的Id和返回給前臺的不一致的解決
這篇文章主要介紹了mybatis-plus IdWorker生成的Id和返回給前臺的不一致的解決,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2021-03-03
eclipse實現(xiàn)ElGamal數(shù)字簽名
這篇文章主要為大家詳細介紹了eclipse實現(xiàn)ElGamal數(shù)字簽名,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2020-06-06
Java生成N個不重復的隨機數(shù)的三種方法總結(jié)
這篇文章主要為大家詳細介紹了三種Java生成N個不重復的隨機數(shù)的方法,文中的示例代碼講解詳細,具有一定的參考價值,有需要的可以了解下2023-10-10
java中break和continue區(qū)別及使用場合分析
本文力圖通過實例加使用場合詳解來引導菜鳥重新認識break和continue語句,需要的朋友可以參考下2014-01-01

