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 {// 真正执行请求 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 // 获取 FeignLoadBalancerlbClient(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 就是真实的ippublic Observable<T> call(Server server) {URI finalUri = reconstructURIWithServer(server, request.getUri());// 路径替换把原本 http://client-name/xxxx 地址改为 http://127.0.0.1:9090/xxxxS requestForServer = (S) request.replaceUri(finalUri);try {// 请求父类中的 execute 方法,也就是 上面 lbClient(clientName) 返回的 FeignLoadBalancerreturn 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
@Overridepublic 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.DefaultResponse response = request.client().execute(request.toRequest(), options);return new RibbonResponse(request.getUri(), response);}
feign.Client.Default#execute
@Overridepublic 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
,无非做了自己处理(负载),有些类似于静态代理
那么上面的问题就只剩下能否替换的问题了
@Configuration
class DefaultFeignLoadBalancedConfiguration {@Bean@ConditionalOnMissingBeanpublic 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);}@Overridepublic 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);}@Beanpublic Client feignClient(SpringClientFactory clientFactory) {CachingSpringLoadBalancerFactory bean = cachingLBClientFactory(clientFactory);return new LoadBalancerFeignClient(new InFeignClient(null, null), bean, clientFactory);}}
feign 获取请求真实目的ip地址相关推荐
- request获取mac地址_【Go】获取用户真实的ip地址
原文链接:https://blog.thinkeridea.com/201903/go/get_client_ip.html 用户请求到达提供服务的服务器中间有很多的环节,导致服务获取用户真实的 ip ...
- 网站配置了Cloudflare代理后,如何配置Nginx获取的真实客户端IP地址?
网站配置了Cloudflare代理后,如何配置Nginx获取的真实客户端IP地址? 这是一个很简单的问题,如何在后台获取真实的访问者IP地址? 网站为了避免有些不怀好意的访问者,不得不自动分析一下客户 ...
- 2021-08-26——获取电脑真实的IP地址,忽略虚拟机等IP地址的干扰
获取电脑真实的IP地址,忽略虚拟机等IP地址的干扰 此代码中只要读取到了WiFi或者有线地址其中之一立即return. 微信搜索"HUC思梦"关注我吧,关注有惊喜,不定时有免费资源 ...
- java获取请求本机ip地址
在JSP里,获取客户端的IP地址的方法是:request.getRemoteAddr(),这种方法在大部分情况下都是有效的.但是在通过了Apache,Squid等反向代理软件就不能获取到客户端的真实I ...
- JavaWeb - 获取访问者真实的 IP 地址(一)
在 JSP 里,获取客户端的 IP 地址的方法是:request.getRemoteAddr(),这种方法在大部分情况下都是有效的.但是在通过了Apache.Squid等反向代理软件就不能获取到客户端 ...
- Java获取访问者真实的IP地址
个人收录的一些小工具类,供大家参考 方式一 import javax.servlet.http.HttpServletRequest; /** 自定义访问对象工具类获取对象的IP地址等信息 @auth ...
- LinuxC下获取UDP包中的路由目的IP地址和头标识目的地址
在接受到UDP包后,有时候我们需要根据所接收到得UDP包,获取它的路由目的IP地址和头标识目的地址. (一)主要的步骤: 在setsockopt中设置IP_PKTINFO,然后通过recvmsg来获取 ...
- Nginx在多层代理下获取真实客户端IP地址
最近在研究nginx中如何获取真实客户端IP的方法.众所周知,在编译Nginx时,可通过添加http_realip_module模块来获取真实客户端IP地址.何为真实IP地址呢?请看下图,既获取到的真 ...
- 学习笔记 - Nginx在多层代理下获取真实客户端IP地址
最近在研究nginx中如何获取真实客户端IP的方法.众所周知,在编译Nginx时,可通过添加http_realip_module模块来获取真实客户端IP地址.何为真实IP地址呢?请看下图,既获取到的真 ...
- 获取指定域名的IP地址
获取指定域名的IP地址 所需函数:gethostbyname 函数原型: struct hostent* gethostbyname(const char *name) 参数:const char * ...
最新文章
- Spring Cloud Config 集中式配置
- mybatis应用(三)优化
- Android在View拉丝工艺和invalidate()和其他相关方法
- GreenSock (TweenMax) 动画案例(二)
- 基于依存句法与语义角色标注的事件抽取项目
- 客服中心智能化技术和应用研究报告(2021年)
- java 抽象类的匿名类_Java匿名内部类(通过继承抽象类来实现)
- css实现文本过长时自动添加省略号
- Python之输入输出
- 静态代理,动态代理,Cglib代理详解
- php-5.6.2-Win32-VC11-x64.zip+ apache2.4.10 +php_xdebug-2.2.5-5.6-vc11-x86_64.dll+mysql5.6安装配置
- 苹果手机在哪搜索测试版软件,如何在 beta 版软件上测试你的 App
- JEECMS安装部署方法以及使用说明教程
- 思创(Cetron)发布首款企业级Wi-Fi 6 AP
- Linux用到的大数据相关命令
- CSP在线考试环境 | OBS录屏软件下载安装和设置教程
- 3.5mm耳机喇叭和麦克接头差异
- Linux用户空间线程管理介绍之二:创建线程堆栈
- 年轻人沉迷“酒店沉浸式度假”,景区该如何与酒店“争宠”?
- PPC E500内核寄存器
热门文章
- take android,Protake
- 怎么看蛋白质编码序列_墨鱼的“墨汁”可以吃吗,它有什么营养?看完就明白,涨知识了...
- 开启Accessibility的快捷方式-3次home键或者侧边键
- 神经图灵机NTM —— 元学习
- html隐藏标签console,console的隐藏知识点,你get到了嘛?
- 输出结果 配置_用单端仪表放大器实现全差分输出
- android studio for android learning (十) android之activity的启动和关闭
- MongoDB 在windows shell环境下的基本操作和命令的使用示例(四)
- 【GYM-100889 D】Dicy Numbers【数学推导求解】
- 【HDU-5963】朋友【树上博弈】