ソースを参照

maven依赖整理

by su 3 年 前
コミット
8e20aad857

+ 3 - 0
4dkankan-gateway/src/main/java/com/fdkankan/gateway/config/CustomErrorWebFluxAutoConfiguration.java

@@ -25,6 +25,9 @@ import org.springframework.web.reactive.result.view.ViewResolver;
 import java.util.List;
 import java.util.stream.Collectors;
 
+/**
+ * 网关全局异常配置
+ */
 @Configuration
 @ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.REACTIVE)
 @ConditionalOnClass(WebFluxConfigurer.class)

+ 0 - 57
4dkankan-gateway/src/main/java/com/fdkankan/gateway/exception/GlobalErrorWebExceptionHandler.java

@@ -1,57 +0,0 @@
-//package com.fdkankan.gateway.exception;
-//
-//import com.fasterxml.jackson.core.JsonProcessingException;
-//import com.fasterxml.jackson.databind.ObjectMapper;
-//import com.fdkankan.common.constant.ServerCode;
-//import com.fdkankan.common.response.ResultData;
-//import lombok.RequiredArgsConstructor;
-//import lombok.extern.slf4j.Slf4j;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.boot.web.reactive.error.ErrorWebExceptionHandler;
-//import org.springframework.cloud.gateway.support.NotFoundException;
-//import org.springframework.context.annotation.Configuration;
-//import org.springframework.core.annotation.Order;
-//import org.springframework.core.io.buffer.DataBufferFactory;
-//import org.springframework.http.MediaType;
-//import org.springframework.http.server.reactive.ServerHttpResponse;
-//import org.springframework.web.server.ResponseStatusException;
-//import org.springframework.web.server.ServerWebExchange;
-//import reactor.core.publisher.Mono;
-//
-//@Slf4j
-//@Order(-1)
-////@Configuration
-//@RequiredArgsConstructor(onConstructor = @__(@Autowired))
-//public class GlobalErrorWebExceptionHandler implements ErrorWebExceptionHandler {
-//
-//    private final ObjectMapper objectMapper;
-//
-//    @Override
-//    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
-//
-//        ServerHttpResponse response = exchange.getResponse();
-//        if (response.isCommitted()) {
-//            return Mono.error(ex);
-//        }
-//
-//        // 设置返回JSON
-//        response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
-//
-//        if (ex instanceof ResponseStatusException) {
-//            response.setStatusCode(((ResponseStatusException) ex).getStatus());
-//        }
-//
-//        return response.writeWith(Mono.fromSupplier(() -> {
-//            DataBufferFactory bufferFactory = response.bufferFactory();
-//            try {
-//                //返回响应结果
-//                log.error(ex.getMessage());
-//                return bufferFactory.wrap(objectMapper.writeValueAsBytes(ResultData.fail(ServerCode.SYSTEM_ERROR.code(), ServerCode.SYSTEM_ERROR.message())));
-//            }
-//            catch (JsonProcessingException e) {
-//                log.error("Error writing response", ex);
-//                return bufferFactory.wrap(new byte[0]);
-//            }
-//        }));
-//    }
-//}

+ 3 - 0
4dkankan-gateway/src/main/java/com/fdkankan/gateway/filter/AccessLogFilter.java

@@ -42,6 +42,9 @@ import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
+/**
+ * 请求、响应过滤器
+ */
 @Slf4j
 @Component
 public class AccessLogFilter  implements GlobalFilter, Ordered {