diff --git a/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/AccessLogFilter.java b/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/AccessLogFilter.java index 5850b1f01ae729f491574687b7be4fd34b768385..fd4ec75e20d2583cfcf0122047fba1b509a28dc9 100644 --- a/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/AccessLogFilter.java +++ b/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/AccessLogFilter.java @@ -81,6 +81,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered { @Override @SuppressWarnings("unchecked") public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { + ServerHttpRequest request = exchange.getRequest(); // 璇锋眰璺緞 String requestPath = request.getPath().pathWithinApplication().value(); @@ -165,6 +166,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered { headers.putAll(exchange.getRequest().getHeaders()); headers.remove(HttpHeaders.CONTENT_LENGTH); CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange, headers); + log.info("contentLens:"+HttpHeaders.CONTENT_LENGTH); return bodyInserter.insert(outputMessage, new BodyInserterContext()) .then(Mono.defer(() -> { // 閲嶆柊灏佽璇锋眰 diff --git a/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/GlobalLogFilter.java b/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/GlobalLogFilter.java index 8759a1c435dcf24d3ee1148d14e2842edb26020d..adb34d8609fe1731c027009adac93eee8e4a8f9a 100644 --- a/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/GlobalLogFilter.java +++ b/smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/GlobalLogFilter.java @@ -53,7 +53,7 @@ public class GlobalLogFilter implements GlobalFilter, Ordered { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { - log.info("GlobalLogFilter:{}",getOrder()); + //淇濆瓨璇锋眰閾捐矾锛岃缃暟鎹拷韪猧d鍒癶eader涓� Integer pspanId = 0; Integer spanId = 1; @@ -66,40 +66,6 @@ public class GlobalLogFilter implements GlobalFilter, Ordered { .build(); return chain.filter(exchange.mutate().request(newRequest).build()); - //鍒ゆ柇璇锋眰绫诲瀷 -// String paramStr =""; -// if (isJsonRequest(request)) { -// //璇诲彇璇锋眰浣撳悗 鍐呭闇€瑕侀噸鏂拌缃繘鍘� -// paramStr = resolveBodyFromRequest(request); -// } else { -// //闈瀓son绫诲瀷锛� -// MultiValueMap<String, String> parameterMap = request.getQueryParams(); -// paramStr=JSON.toJSONString(parameterMap); -// } - - -// AccessLogPdu accessLogPdu = new AccessLogPdu(); -// accessLogPdu.initAttrValue(); -// accessLogPdu.setAppName(appName); -// accessLogPdu.setHostName(NetUtil.getLocalHostName()); -// accessLogPdu.setLogLevel("INFO"); -// accessLogPdu.setRequestIp(IpUtils.getRealIpAddress(exchange.getRequest())); -// accessLogPdu.setRequestData(paramStr); -// accessLogPdu.setLogTime(new Date()); -// accessLogPdu.setMethod(method); -// accessLogPdu.setUri(path); -// accessLogPdu.setTraceID(traceId); - - // messageProducer.syncAccessSend(accessLogPdu); - //exchange.getAttributes().put(START_TIME, System.currentTimeMillis()); -// ServerHttpRequest newRequest = exchange.getRequest().mutate() -// .header(TRACE_ID, traceId) -// .header(TRACE_ID, traceId) -// .header(TRACE_ID, traceId) -// .build(); -// -// return chain.filter(exchange.mutate().request(newRequest).build()); - } @Override