This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.3.2
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.3.2 by this push:
new 25ae320b2 [feat:4099] gateway log ip info (#4100)
25ae320b2 is described below
commit 25ae320b29f3f11527c84e4715bf7d0d359f0158
Author: aiceflower <[email protected]>
AuthorDate: Thu Feb 16 15:05:52 2023 +0800
[feat:4099] gateway log ip info (#4100)
[feat:4099] gateway log ip info (#4100)
---
.../org/apache/linkis/gateway/route/GatewayRouter.scala | 3 ---
.../springcloud/http/GatewayAuthorizationFilter.java | 15 +++++++++++++++
2 files changed, 15 insertions(+), 3 deletions(-)
diff --git
a/linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-core/src/main/scala/org/apache/linkis/gateway/route/GatewayRouter.scala
b/linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-core/src/main/scala/org/apache/linkis/gateway/route/GatewayRouter.scala
index 78e62edc1..24870808a 100644
---
a/linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-core/src/main/scala/org/apache/linkis/gateway/route/GatewayRouter.scala
+++
b/linkis-spring-cloud-services/linkis-service-gateway/linkis-gateway-core/src/main/scala/org/apache/linkis/gateway/route/GatewayRouter.scala
@@ -187,9 +187,6 @@ class DefaultGatewayRouter(var gatewayRouters:
Array[GatewayRouter]) extends Abs
gatewayContext.getResponse.sendResponse()
return null
}
- logger.info(
- "GatewayRouter route requestUri " +
gatewayContext.getGatewayRoute.getRequestURI + " with parsedService " +
parsedService + " to " + serviceInstance
- )
serviceInstance
} else null
diff --git
a/linkis-spring-cloud-services/linkis-service-gateway/linkis-spring-cloud-gateway/src/main/java/org/apache/linkis/gateway/springcloud/http/GatewayAuthorizationFilter.java
b/linkis-spring-cloud-services/linkis-service-gateway/linkis-spring-cloud-gateway/src/main/java/org/apache/linkis/gateway/springcloud/http/GatewayAuthorizationFilter.java
index a3bfa01cf..9bc1fa601 100644
---
a/linkis-spring-cloud-services/linkis-service-gateway/linkis-spring-cloud-gateway/src/main/java/org/apache/linkis/gateway/springcloud/http/GatewayAuthorizationFilter.java
+++
b/linkis-spring-cloud-services/linkis-service-gateway/linkis-spring-cloud-gateway/src/main/java/org/apache/linkis/gateway/springcloud/http/GatewayAuthorizationFilter.java
@@ -163,6 +163,21 @@ public class GatewayAuthorizationFilter implements
GlobalFilter, Ordered {
return gatewayHttpResponse.getResponseMono();
}
serviceInstance = router.route(gatewayContext);
+ if (serviceInstance != null) {
+ logger.info(
+ "Client request ip: "
+ + gatewayContext.getRequest().getRemoteAddress()
+ + " and uri: "
+ + gatewayContext.getRequest().getRequestURI()
+ + "GatewayRouter route requestUri: "
+ + gatewayContext.getGatewayRoute().getRequestURI()
+ + " with parsedService "
+ +
gatewayContext.getGatewayRoute().getServiceInstance().getApplicationName()
+ + " to "
+ + serviceInstance);
+ } else {
+ logger.info("Client request uri: " +
gatewayContext.getRequest().getRequestURI());
+ }
} catch (Throwable t) {
logger.warn("", t);
Message message =
Message.error(t).$less$less(gatewayContext.getRequest().getRequestURI());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
