Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/mx_charg...

puzhibing

2024-08-19 7d348d54c93e1333951c6d20f8ead81d389cd262

 ruoyi-gateway/src/main/java/com/ruoyi/gateway/handler/GatewayExceptionHandler.java

@@ -19,38 +19,30 @@
 */
@Order(-1)
@Configuration
public class GatewayExceptionHandler implements ErrorWebExceptionHandler
{
    private static final Logger log = LoggerFactory.getLogger(GatewayExceptionHandler.class);

    @Override
    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex)
    {
        ServerHttpResponse response = exchange.getResponse();

        if (exchange.getResponse().isCommitted())
        {
            return Mono.error(ex);
        }

        String msg;

        if (ex instanceof NotFoundException)
        {
            msg = "服务未找到";
        }
        else if (ex instanceof ResponseStatusException)
        {
            ResponseStatusException responseStatusException = (ResponseStatusException) ex;
            msg = responseStatusException.getMessage();
        }
        else
        {
            msg = "内部服务器错误";
        }

        log.error("[网关异常处理]请求路径:{},异常信息:{}", exchange.getRequest().getPath(), ex.getMessage());

        return ServletUtils.webFluxResponseWriter(response, msg);
    }
public class GatewayExceptionHandler implements ErrorWebExceptionHandler {
   private static final Logger log = LoggerFactory.getLogger(GatewayExceptionHandler.class);
	
   @Override
   public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
      ServerHttpResponse response = exchange.getResponse();
		
      if (exchange.getResponse().isCommitted()) {
         return Mono.error(ex);
      }
		
      String msg;
		
      if (ex instanceof NotFoundException) {
         msg = "服务未找到";
      } else if (ex instanceof ResponseStatusException) {
         ResponseStatusException responseStatusException = (ResponseStatusException) ex;
         msg = responseStatusException.getMessage();
      } else {
         msg = "内部服务器错误";
      }
		
      log.error("[网关异常处理]请求路径:{},异常信息:{}", exchange.getRequest().getPath(), ex.getMessage());
		
      return ServletUtils.webFluxResponseWriter(response, msg);
   }
}