spring cloud gateway如何获取请求的真实地址
作者：一只猪啊啊
这篇文章主要介绍了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 这个变量，然后就可以看到真实请求的地址了
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
您可能感兴趣的文章:
Spring的循环依赖、三级缓存解决方案源码详细解析2024-01-01
SpringBoot+MyBatis+Redis实现分布式缓存2024-01-01
Spring中的@ControllerAdvice和@ExceptionHandler注解处理全局异常2024-01-01
Java中Comparable与Comparator的区别解析2024-01-01
Spring Cloud Gateway组件的三种使用方2024-01-01
Java中的ThreadLocal源码及弱引用解析2024-01-01
Java连接Hbase的项目实践2024-01-01
Java中volatile关键字的线程的可见性、有序性详解2024-01-01
美国设下计谋,用娘炮文化重塑日本,已影响至中国2021-11-19
时空伴随者是什么意思?时空伴随者介绍2021-11-09
工信部称网盘企业免费用户最低速率应满足基本下载需求，天翼云盘回应：坚决支持，始终2021-11-05
2022年放假安排出炉：五一连休5天 2022年所有节日一览表2021-10-26
电脑版 - 返回首页
2006-2024 脚本之家 JB51.Net , All Rights Reserved.
苏ICP备14036222号
