spring cloud gateway如何获取请求的真实地址

更新时间：2023年05月06日 09:06:28 作者：一只猪啊啊

这篇文章主要介绍了spring cloud gateway如何获取请求的真实地址问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

spring cloud gateway获取请求的真实地址

在使用spring cloud gateway的时候，路由一般配置为服务名

例如 lb://BASE-API-WEB/xxx/bbb 路径，我们无从知道，他真正路由到什么地方去了。

经过查看源码我发现了，

org.springframework.cloud.gateway.filter.LoadBalancerClientFilter

这个filter中对lb请求进行了处理，转换成真正的url地址。

核心方法如下

 public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
       //lb下的url
 URI url = (URI)exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);
        String schemePrefix = (String)exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR);
        if (url == null || !"lb".equals(url.getScheme()) && !"lb".equals(schemePrefix)) {
            return chain.filter(exchange);
        } else {
            ServerWebExchangeUtils.addOriginalRequestUrl(exchange, url);
            log.trace("LoadBalancerClientFilter url before: " + url);
            ServiceInstance instance = this.loadBalancer.choose(url.getHost());
            if (instance == null) {
                throw new NotFoundException("Unable to find instance for " + url.getHost());
            } else {
                URI uri = exchange.getRequest().getURI();
                String overrideScheme = null;
                if (schemePrefix != null) {
                    overrideScheme = url.getScheme();
                }
                //真实的url
                URI requestUrl = this.loadBalancer.reconstructURI(new LoadBalancerClientFilter.DelegatingServiceInstance(instance, overrideScheme), uri);
                log.trace("LoadBalancerClientFilter url chosen: " + requestUrl);
                exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, requestUrl);
                return chain.filter(exchange);
            }
        }
    }

其实，spring cloud gateway 已经打印了日志，但是默认的他是trace级别的，我们常用的日志级别是info级别，所有他不会打印，这就导致了我们在日志中看不到真实的url地址

以下是解决办法

1.在配置文件中设置org.springframework.cloud.gateway.filter.LoadBalancerClientFilter的日志级别

logging.level.org.springframework.cloud.gateway.filter.LoadBalancerClientFilter=TRACE

注意这里的配置一定要在

logging.level.org.springframework之后配置 不然会覆盖

2.重写LoadBalancerClientFilter 建立org.springframework.cloud.gateway.filter包将类重写 spingboot默认会从本项目中加载类，原先的类就被弃用了。

3.继承LoadBalancerClientFilter 重写filter方法，将日志级别改为info即可

  @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        URI url = exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);
        String schemePrefix = exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR);
        if (url == null || !"lb".equals(url.getScheme()) && !"lb".equals(schemePrefix)) {
            return chain.filter(exchange);
        } else {
            ServerWebExchangeUtils.addOriginalRequestUrl(exchange, url);
            ServiceInstance instance = this.loadBalancer.choose(url.getHost());
            if (instance == null) {
                throw new NotFoundException("Unable to find instance for " + url.getHost());
            } else {
                URI uri = exchange.getRequest().getURI();
                String overrideScheme = null;
                if (schemePrefix != null) {
                    overrideScheme = url.getScheme();
                }
                URI requestUrl = this.loadBalancer.reconstructURI(new LoadBalancerClientFilterBean.DelegatingServiceInstance(instance, overrideScheme), uri);
                logger.info("before url = {} , url chosen = {} " ,url, requestUrl);
                exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, requestUrl);
                return chain.filter(exchange);
            }
        }
    }

最终效果如下：

spring cloud的GateWay网关中如何debug得到真实的路由地址

org.springframework.cloud.gateway.filter下面的

然后按下 Step over 就得到了 mergedUrl 这个变量，然后就可以看到真实请求的地址了

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

详解springboot中redis的使用和分布式session共享问题
这篇文章主要介绍了详解springboot中redis的使用和分布式session共享问题,详细的介绍了解决分布式系统的session如何共享问题，有兴趣的可以了解一下
2017-11-11
springboot整合couchbase集群的步骤
couchbase是一款开源的,分布式的nosql数据库,主要用于分布式缓存和数据存储领域,本文给大家介绍springboot整合couchbase集群的步骤,感兴趣的朋友一起看看吧
2025-03-03
详解Java类动态加载和热替换
本文主要介绍类加载器、自定义类加载器及类的加载和卸载等内容，并举例介绍了Java类的热替换。
2021-05-05
RabbitMQ的ACK确认机制保障消费端消息的可靠性详解
这篇文章主要介绍了RabbitMQ的ACK确认机制保障消费端消息的可靠性详解,简单来说,就是你必须关闭 RabbitMQ 的自动ack ,可以通过一个 api 来调用就行,然后每次你自己代码里确保处理完的时候,再在程序里 ack 一把,需要的朋友可以参考下
2023-12-12
Spring5.2.x 源码本地环境搭建的方法步骤
这篇文章主要介绍了Spring5.2.x 源码本地环境搭建的方法步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-09-09
java获取各种路径的基本方法
这篇文章主要为大家详细介绍了java获取各种路径的基本方法,具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2016-10-10
spring boot整合CAS Client实现单点登陆验证的示例
本篇文章主要介绍了spring boot整合CAS Client实现单点登陆验证的示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-01-01
解决IDEA安装插件搜索不到插件的问题
这篇文章主要介绍了解决IDEA安装插件搜索不到插件的问题,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-03-03
老生常谈Java中instanceof关键字的理解
java 中的instanceof 运算符是用来在运行时指出对象是否是特定类的一个实例。这篇文章主要介绍了老生常谈Java中instanceof关键字的理解,需要的朋友可以参考下
2018-10-10
代理模式:JAVA静态代理和动态代理的实例和实现详解
这篇文章主要给大家介绍了关于Java静态代理和动态代理的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-08-08