添加应用主题

smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/AccessLogFilter.java

@@ -92,19 +92,21 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
         AccessLogPdu accessLogPdu = new AccessLogPdu();
         accessLogPdu.initAttrValue();
         accessLogPdu.setAppName(appName);
-        accessLogPdu.setTraceID(headers.getOrDefault(TRACE_ID,""));
-        accessLogPdu.setPspanId(Integer.parseInt(headers.getOrDefault(PSPAN_ID,"0")));
-        accessLogPdu.setSpanId(Integer.parseInt(headers.getOrDefault(SPAN_ID,"1")));
+        accessLogPdu.setTraceID(headers.getOrDefault(TRACE_ID, ""));
+        accessLogPdu.setPspanId(Integer.parseInt(headers.getOrDefault(PSPAN_ID, "0")));
+        accessLogPdu.setSpanId(Integer.parseInt(headers.getOrDefault(SPAN_ID, "1")));
         accessLogPdu.setSchemaData(request.getURI().getScheme());
-        accessLogPdu.setHostName(NetUtil.getLocalHostName());
+        accessLogPdu.setHostName(request.getHeaders().getHost().getHostName());
         accessLogPdu.setUri(requestPath);
         accessLogPdu.setTargetServer(route.getId());
         accessLogPdu.setRequestIp(IpUtils.getRealIpAddress(exchange.getRequest()));
-        accessLogPdu.setUa(headers.getOrDefault("User-Agent",""));
+        accessLogPdu.setUa(headers.getOrDefault("User-Agent", ""));
         accessLogPdu.setRequestTime(new Date());
         accessLogPdu.setLogTime(new Date());
         accessLogPdu.setMethod(request.getMethodValue());
 
+        log.info("origin uri:{} host:{}",requestPath,request.getHeaders().getHost().getHostName());
+
         MediaType mediaType = request.getHeaders().getContentType();
         if (MediaType.APPLICATION_FORM_URLENCODED.isCompatibleWith(mediaType) || MediaType.APPLICATION_JSON.isCompatibleWith(mediaType)) {
             return writeBodyLog(exchange, chain, accessLogPdu);
@@ -161,12 +163,8 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
         BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, String.class);
         HttpHeaders headers = new HttpHeaders();
         headers.putAll(exchange.getRequest().getHeaders());
-        // the new content type will be computed by bodyInserter
-        // and then set in the request decorator
         headers.remove(HttpHeaders.CONTENT_LENGTH);
-
         CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange, headers);
-
         return bodyInserter.insert(outputMessage, new BodyInserterContext())
                 .then(Mono.defer(() -> {
                     // 重新封装请求
@@ -183,7 +181,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
     }
 
     private void writeAccessLog(AccessLogPdu accessLogPdu) {
-       // log.info("accessLog:{}",JSON.toJSONString(accessLogPdu));
+        // log.info("accessLog:{}",JSON.toJSONString(accessLogPdu));
         messageProducer.syncAccessSend(accessLogPdu);
     }
 
@@ -234,7 +232,6 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
     private ServerHttpResponseDecorator recordResponseLog(ServerWebExchange exchange, AccessLogPdu accessLogPdu) {
         ServerHttpResponse response = exchange.getResponse();
         DataBufferFactory bufferFactory = response.bufferFactory();
-
         return new ServerHttpResponseDecorator(response) {
             @Override
             public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
@@ -264,7 +261,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
                             //accessLogPdu.setResponseData(StrUtil.maxLength(responseResult,3000));
                             return bufferFactory.wrap(content);
                         }));*/
-                    }else {
+                    } else {
                         accessLogPdu.setResponseData(JSON.toJSONString(Rest.fail()));
                     }
                 }