feign 如何獲取請求真實目的ip地址
更新時間：2021年06月24日 12:05:25 作者：帆影匆匆
這篇文章主要介紹了feign 獲取請求真實目的ip地址操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
需求
最近小編的項目中出現了很多feign 調用出現 Read Time out 的異常，但因為沒有集成鏈路追蹤的第三方框架，查不到原因。
所以想到打印請求的ip地址，判斷是指定的服務器出現的問題還是所有服務器都有這個問題，但是feign 打印異常日志不會顯示目的端地址，這就很難受了沒辦法只能自己改裝下
大致想法
需要改裝肯定需要知道feign 具體請求調用的源碼，大致需要知道下面幾個問題
- feign 集成了ribbon 如何在負載均衡之后獲取真實的ip地址
- feign 實際請求 http 源碼在哪
- 能否替換 feign http 請求的組件
源碼解析
之前小編有兩篇文章分析過 feign相關的源碼
自定義 feign 調用實現 hystrix 超時、異常熔斷
Feign 集成 Hystrix實現不同的調用接口不同的設置
這其中有個關鍵的源碼位置在于 InvocationHandler 的 invoke 方法，在feign 組件中大致有兩個類實現了此接口
FeignInvocationHandler HystrixInvocationHandler
如果 項目中使用了 Hystrix 那么會用到HystrixInvocationHandler那個，否則一般是FeignInvocationHandler（自定義組件的除外）
那么此時只需要在invoke 方法中打個斷點就行
此時跟蹤到
feign.SynchronousMethodHandler#executeAndDecode
Object executeAndDecode(RequestTemplate template) throws Throwable {
Request request = targetRequest(template);
.......
Response response;
long start = System.nanoTime();
try {
// 真正執(zhí)行請求
response = client.execute(request, options);
response.toBuilder().request(request).build();
} catch (IOException e) {
....
throw errorExecuting(request, e);
}
.....
}
通過debug就知道這個 client 是
LoadBalancerFeignClient org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient#execute
public Response execute(Request request, Request.Options options) throws IOException {
try {
URI asUri = URI.create(request.url());
String clientName = asUri.getHost();
URI uriWithoutHost = cleanUrl(request.url(), clientName);
// 封裝 ribbon 請求組件
FeignLoadBalancer.RibbonRequest ribbonRequest = new FeignLoadBalancer.RibbonRequest(
this.delegate, request, uriWithoutHost);
IClientConfig requestConfig = getClientConfig(options, clientName);
// 這行是關鍵
return
// 獲取 FeignLoadBalancer
lbClient(clientName)
// 負載之后請求真實的url
// com.netflix.client.AbstractLoadBalancerAwareClient#executeWithLoadBalancer(....)
.executeWithLoadBalancer(ribbonRequest,requestConfig)
.toResponse();
}
catch (ClientException e) {
....
throw new RuntimeException(e);
}
}
com.netflix.client.AbstractLoadBalancerAwareClient#executeWithLoadBalancer(....)
public T executeWithLoadBalancer(final S request, final IClientConfig requestConfig) throws ClientException {
LoadBalancerCommand<T> command = buildLoadBalancerCommand(request, requestConfig);
try {
// 在com.netflix.loadbalancer.reactive.LoadBalancerCommand#submit 中會根據 負載均衡算法之后獲取到真實的ip地址
return command.submit(
new ServerOperation<T>() {
@Override
// 傳入的server 就是真實的ip
public Observable<T> call(Server server) {
URI finalUri = reconstructURIWithServer(server, request.getUri());
// 路徑替換把原本 http://client-name/xxxx 地址改為 http://127.0.0.1:9090/xxxx
S requestForServer = (S) request.replaceUri(finalUri);
try {
// 請求父類中的 execute 方法，也就是 上面 lbClient(clientName) 返回的 FeignLoadBalancer
return Observable.just(AbstractLoadBalancerAwareClient.this.execute(requestForServer, requestConfig));
}
catch (Exception e) {
return Observable.error(e);
}
}
})
.toBlocking()
.single();
} catch (Exception e) {
Throwable t = e.getCause();
if (t instanceof ClientException) {
throw (ClientException) t;
} else {
throw new ClientException(e);
}
}
}
org.springframework.cloud.openfeign.ribbon.FeignLoadBalancer#execute
@Override
public RibbonResponse execute(RibbonRequest request, IClientConfig configOverride)
throws IOException {
Request.Options options;
.....
// 這里的 request 就是 `org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient#execute`
// 封裝的FeignLoadBalancer.RibbonRequest
// request.client() 返回就是 feign.Client.Default
Response response = request.client().execute(request.toRequest(), options);
return new RibbonResponse(request.getUri(), response);
}
feign.Client.Default#execute
@Override
public Response execute(Request request, Options options) throws IOException {
HttpURLConnection connection = convertAndSend(request, options);
return convertResponse(connection).toBuilder().request(request).build();
}
這里的request 中 url 就是真實的url資源路徑了
現在屢屢邏輯
org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient和feign.Client.Default
都實現了 feign.Client 接口，但是 LoadBalancerFeignClient 實際上調用的還是 feign.Client.Default，無非做了自己處理（負載），有些類似于靜態(tài)代理
那么上面的問題就只剩下能否替換的問題了
@Configuration
class DefaultFeignLoadBalancedConfiguration {
@Bean
@ConditionalOnMissingBean
public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory,
SpringClientFactory clientFactory) {
return new LoadBalancerFeignClient(new Client.Default(null, null),
cachingFactory, clientFactory);
}
}
這就不需要我來過多解釋了，我們只需要自定義一個 LoadBalancerFeignClient 或者 實現Client的類就行 然后注入就行
實現代碼
我選擇的是 自定義實現一個 Client,去繼承 feign.Client.Default
@Slf4j
public class InFeignClient extends Client.Default {
/**
*/
public InFeignClient(SSLSocketFactory sslContextFactory, HostnameVerifier hostnameVerifier) {
super(sslContextFactory, hostnameVerifier);
}
@Override
public Response execute(Request request, Request.Options options) throws IOException {
try {
return super.execute(request, options);
} catch (IOException e) {
log.warn(" 請求 {} 異常 ======> {}", request.url(), e.getMessage());
throw e;
}
}
}
然后將這個類替換
@Component
public class RestConfig {
public CachingSpringLoadBalancerFactory cachingLBClientFactory(
SpringClientFactory factory) {
return new CachingSpringLoadBalancerFactory(factory);
}
@Bean
public Client feignClient(SpringClientFactory clientFactory) {
CachingSpringLoadBalancerFactory bean = cachingLBClientFactory(clientFactory);
return new LoadBalancerFeignClient(new InFeignClient(null, null), bean, clientFactory);
}
}
相關文章
這篇文章主要介紹了關于Mybatis插入對象時空值的處理方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
本文主要介紹了SpringBoot配置連接兩個或多個數據庫的實現，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-05-05
本文主要介紹了Java list亂序的實現三種方法,包含Collections.shuffle()方法,random和Stream API這三種,具有一定的參考價值,感興趣的可以了解一下2024-03-03
如何利用NetworkInterface獲取服務器MAC地址
今天介紹一種通用的跨平臺的操作方式，那就是JDK自帶的NetworkInterface接口，該接口在JDK1.4已經出現，但是功能比較少，JDK1.6之后新增了不少新功能，比較不錯2013-08-08
Java concurrency集合之ConcurrentHashMap_動力節(jié)點Java學院整理
這篇文章主要介紹了Java concurrency集合之ConcurrentHashMap的相關資料,需要的朋友可以參考下2017-06-06
Jvisualvm監(jiān)控遠程SpringBoot項目的過程詳解
這篇文章主要介紹了Jvisualvm監(jiān)控遠程SpringBoot項目,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-04-04
本文將介紹如何使用Java編寫串口程序,包括串口的基本概念、Java串口通信API的使用、串口程序的開發(fā)流程以及一些常見問題的解決方法等,希望通過本文的介紹,讀者能夠對使用Java編寫串口程序有一個基本的了解,并能夠實踐和應用于實際項目中2023-11-11
本文章向大家介紹Java多態(tài)數組，主要包括Java多態(tài)數組使用實例、基本知識點總結和需要注意事項，具有一定的參考價值，需要的朋友可以參考一下2022-05-05
詳解Java的Hibernate框架中的List映射表與Bag映射
這篇文章主要介紹了Java的Hibernate框架中的List映射表與Bag映射,Hibernate是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-12-12
詳解SpringBoot優(yōu)雅編碼之Lombok加持
這篇文章主要介紹了詳解SpringBoot優(yōu)雅編碼之Lombok加持，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-06-06