Browse Source

mongodb启动,开启日志记录

dengsixing 3 years ago
parent
commit
a51d1a8ecf
1 changed files with 1 additions and 53 deletions
  1. 1 53
      src/main/java/com/fdkankan/gateway/filter/AccessLogFilter.java

+ 1 - 53
src/main/java/com/fdkankan/gateway/filter/AccessLogFilter.java

@@ -101,65 +101,14 @@ public class AccessLogFilter  implements GlobalFilter, Ordered {
         MediaType mediaType = request.getHeaders().getContentType();
         MediaType mediaType = request.getHeaders().getContentType();
 
 
         if(MediaType.APPLICATION_FORM_URLENCODED.isCompatibleWith(mediaType)
         if(MediaType.APPLICATION_FORM_URLENCODED.isCompatibleWith(mediaType)
-            || MediaType.APPLICATION_JSON.isCompatibleWith(mediaType)
-        ||MediaType.MULTIPART_FORM_DATA.isCompatibleWith(mediaType)){
+            || MediaType.APPLICATION_JSON.isCompatibleWith(mediaType)){
             return writeBodyLog(exchange, chain, gatewayLog);
             return writeBodyLog(exchange, chain, gatewayLog);
         }
         }
-//        else if(MediaType.MULTIPART_FORM_DATA.isCompatibleWith(mediaType)){
-//            return readFormData(exchange, chain, gatewayLog);
-//        }
         else{
         else{
             return writeBasicLog(exchange, chain, gatewayLog);
             return writeBasicLog(exchange, chain, gatewayLog);
         }
         }
     }
     }
 
 
-    private Mono<Void> readFormData(ServerWebExchange exchange, GatewayFilterChain chain, GatewayLog gatewayLog) {
-        ServerRequest serverRequest = ServerRequest.create(exchange,serverCodecConfigurer.getReaders());
-
-        Mono<DataBuffer> modifiedBody = serverRequest.bodyToMono(DataBuffer.class)
-            .flatMap(body ->{
-                try {
-                    final byte[] bytes = IOUtils.toByteArray(body.asInputStream());
-                    String s = new String(bytes);
-                    System.out.println(123);
-//                    gatewayLog.setRequestBody(URLDecoder.decode(body, StandardCharsets.UTF_8));
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-                return Mono.just(body);
-            });
-
-        // 通过 BodyInserter 插入 body(支持修改body), 避免 request body 只能获取一次
-        BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, DataBuffer.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(() -> {
-
-                // 重新封装请求
-                ServerHttpRequest decoratedRequest = requestDecorate(exchange, headers, outputMessage);
-
-                // 记录响应日志
-                ServerHttpResponseDecorator decoratedResponse = recordResponseLog(exchange, gatewayLog);
-
-                // 记录普通的
-                return chain.filter(exchange.mutate().request(decoratedRequest).response(decoratedResponse).build())
-                    .doOnError(e->{
-                        // 打印日志
-                        writeBadAccessLog(gatewayLog, e);
-                    })
-                    .then(Mono.fromRunnable(() -> {
-                        // 打印日志
-                        writeAccessLog(gatewayLog);
-                    }));
-            }));
-    }
 
 
     private Mono<Void> writeBasicLog(ServerWebExchange exchange, GatewayFilterChain chain, GatewayLog accessLog) {
     private Mono<Void> writeBasicLog(ServerWebExchange exchange, GatewayFilterChain chain, GatewayLog accessLog) {
         StringBuilder builder = new StringBuilder();
         StringBuilder builder = new StringBuilder();
@@ -183,7 +132,6 @@ public class AccessLogFilter  implements GlobalFilter, Ordered {
                 }));
                 }));
     }
     }
 
 
-
     /**
     /**
      * 参考: org.springframework.cloud.gateway.filter.factory.rewrite.ModifyRequestBodyGatewayFilterFactory
      * 参考: org.springframework.cloud.gateway.filter.factory.rewrite.ModifyRequestBodyGatewayFilterFactory
      * @param exchange
      * @param exchange