pom配置

报错配置：spring.main.web-application-type: reactive
或者移除web

  1. <dependency>
  2.   <!--            如果启动GateWay报错 可能是GateWay模块引入了web和监控的starter依赖,需要移除-->
  3.   <groupId>org.springframework.cloud</groupId>
  4.   <artifactId>spring-cloud-starter-gateway</artifactId>
  5. </dependency>

yml配置

  1. spring:
  2.   application:
  3.     name: cloud-gateway
  4.   cloud:
  5.     gateway:
  6.       discovery:
  7.         locator:
  8.           enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由
  9.       routes:
  10.         - id: payment_routh #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名
  11.           #uri: http://localhost:8001          #匹配后提供服务的路由地址
  12.           uri: lb://cloud-payment-service #匹配后提供服务的路由地址
  13.           predicates:
  14.             - Path=/payment/get/**         # 断言，路径相匹配的进行路由
  16.         - id: payment_routh2 #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名
  17.           #uri: http://localhost:8001          #匹配后提供服务的路由地址
  18.           uri: lb://cloud-payment-service #匹配后提供服务的路由地址
  19.           predicates:
  20.             - Path=/payment/lb/**         # 断言，路径相匹配的进行路由
  21.             - After=2020-03-08T10:59:34.102+08:00[Asia/Shanghai] # 断言，ZonedDateTime now()只有在这个时间后才可以访问，否则404
  22.             # - Before=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]
  23.             # - Between=2020-03-08T10:59:34.102+08:00[Asia/Shanghai] ,  2020-03-08T10:59:34.102+08:00[Asia/Shanghai]
  24.             # curl http://localhost:9527/payment/lb --cookie "username=zzyy"
  25.             # - Cookie=username,zzyy   #Cookie=cookieName,正则表达式
  26.             # 请求头要有X-Request-Id属性并且值为整数的正则表达式 curl http://localhost:9527/payment/lb --cookie "username=zzyy" -H "X-Request-Id:11"
  27. #            - Header=X-Request-Id, \d+
  28. #            - Host=**.atguigu.com  # curl http://localhost:9527/payment/lb -H "Host:afae.atguigu.com"

yml配置2

  1. server:
  2.   port: 8009
  4. spring:
  5.   application:
  6.     name: demo-seata
  7. #  cloud:
  8. #    nacos:
  9. #      server-addr: 192.168.2.20:30010
  10. #      username: nacos
  11. #      password: nacos
  12.     sentinel:
  13.       transport:
  14.         dashboard: 192.168.2.20:31596    # 控制台的安装位置
  15.   main:
  16.     web-application-type: reactive
  17.   cloud:
  18.     gateway:
  19.       discovery:
  20.         locator:
  21.           enabled: true
  22.       routes:
  23.         - id: demo-eureka-client
  24.           uri: lb://demo-eureka-client
  25.           predicates:
  26.             - Path=/eureka-client/**
  27. #  profiles:
  28. #    active: public
  29. #        port: 8719    # 与sentinel单独连接的端口
  30. #        client-ip: 192.168.2.6    # 本机的ip，如果sentinel装在虚拟机，必须配这个
  31. #        port: 30195    # 与sentinel单独连接的端口
  32. #        client-ip: 192.168.2.20    # 本机的ip，如果sentinel装在虚拟机，必须配这个
  33. eureka:
  34.   client:
  35.     service-url:
  36.       defaultZone: http://localhost:7001/eureka
  38. logging:
  39.   level:
  40.     root: debug

gateway响应式异常处理

handler

  1. package com.demo.gateway.common.filter;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.boot.autoconfigure.web.ErrorProperties;
  5. import org.springframework.boot.autoconfigure.web.ResourceProperties;
  6. import org.springframework.boot.autoconfigure.web.reactive.error.DefaultErrorWebExceptionHandler;
  7. import org.springframework.boot.web.error.ErrorAttributeOptions;
  8. import org.springframework.boot.web.reactive.error.ErrorAttributes;
  9. import org.springframework.context.ApplicationContext;
  10. import org.springframework.http.HttpStatus;
  11. import org.springframework.http.MediaType;
  12. import org.springframework.web.reactive.function.BodyInserters;
  13. import org.springframework.web.reactive.function.server.RequestPredicates;
  14. import org.springframework.web.reactive.function.server.RouterFunction;
  15. import org.springframework.web.reactive.function.server.RouterFunctions;
  16. import org.springframework.web.reactive.function.server.ServerRequest;
  17. import org.springframework.web.reactive.function.server.ServerResponse;
  18. import reactor.core.publisher.Mono;
  20. import java.util.HashMap;
  21. import java.util.Map;
  22. import java.util.Objects;
  24. /**
  25. * <p>
  26. * 全局异常处理
  27. * </p>
  28. */
  29. @Slf4j
  30. public class GlobalExceptionHandler extends DefaultErrorWebExceptionHandler {
  31.     public GlobalExceptionHandler(ErrorAttributes errorAttributes, ResourceProperties resourceProperties, ErrorProperties errorProperties, ApplicationContext applicationContext) {
  32.         super(errorAttributes, resourceProperties, errorProperties, applicationContext);
  33.     }
  35.     /**
  36.     * 统一处理异常信息
  37.     */
  38.     protected Map<String, Object> getErrorMap(ServerRequest request, Throwable error) {
  39.         Map<String, Object> errorAttributes = new HashMap<>(8);
  40.         errorAttributes.put("message", error.getMessage());
  41.         errorAttributes.put("code", HttpStatus.INTERNAL_SERVER_ERROR.value());
  42.         errorAttributes.put("method", request.methodName());
  43.         errorAttributes.put("path", request.path());
  44.         return errorAttributes;
  45.     }
  47.     /**
  48.     * 统一处理异常信息
  49.     */
  50.     @Override
  51.     @SuppressWarnings(value = "unchecked")
  52.     protected Map<String, Object> getErrorAttributes(ServerRequest request, boolean includeStackTrace) {
  53.         Throwable error = super.getError(request);
  54.         //调用处理异常的方法，并将对象转换成map
  55.         return getErrorMap(request, error);
  56.     }
  58.     /**
  59.     * Extract the error attributes from the current request, to be used to populate error
  60.     * views or JSON payloads.
  61.     * @param request the source request
  62.     * @param options options to control error attributes
  63.     * @return the error attributes as a Map
  64.     */
  65.     @Override
  66.     protected Map<String, Object> getErrorAttributes(ServerRequest request, ErrorAttributeOptions options) {
  67.         Throwable error = super.getError(request);
  68.         return getErrorMap(request, error);
  69.     }
  71.     @Override
  72.     protected RouterFunction<ServerResponse> getRoutingFunction(ErrorAttributes errorAttributes) {
  73.         return RouterFunctions.route(RequestPredicates.all(), this::renderErrorResponse);
  74.     }
  76.     @Override
  77.     protected Mono<ServerResponse> renderErrorResponse(ServerRequest request) {
  78.         boolean includeStackTrace = isIncludeStackTrace(request, MediaType.ALL);
  79.         Map<String, Object> error = getErrorAttributes(request, includeStackTrace);
  80.         return ServerResponse
  81.             .status(getHttpStatus(error))
  82.             .contentType(MediaType.APPLICATION_JSON)
  83.             .body(BodyInserters.fromValue(error));
  84.     }
  86.     @Override
  87.     protected int getHttpStatus(Map<String, Object> errorAttributes) {
  88.         HttpStatus status = (HttpStatus) errorAttributes.get("status");
  89.         if (Objects.isNull(status)) {
  90.             return HttpStatus.OK.value();
  91.         }
  92.         return status.value();
  93.     }
  94. }

config

  1. package com.demo.gateway.common.config;
  3. import com.demo.gateway.common.filter.GlobalExceptionHandler;
  4. import org.springframework.beans.factory.ObjectProvider;
  5. import org.springframework.boot.autoconfigure.web.ResourceProperties;
  6. import org.springframework.boot.autoconfigure.web.ServerProperties;
  7. import org.springframework.boot.context.properties.EnableConfigurationProperties;
  8. import org.springframework.boot.web.reactive.error.ErrorAttributes;
  9. import org.springframework.boot.web.reactive.error.ErrorWebExceptionHandler;
  10. import org.springframework.context.ApplicationContext;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.core.annotation.Order;
  13. import org.springframework.http.codec.ServerCodecConfigurer;
  14. import org.springframework.stereotype.Component;
  15. import org.springframework.web.reactive.result.view.ViewResolver;
  17. import java.util.Collections;
  18. import java.util.List;
  20. /**
  21. * @author yuwenbo
  22. */
  23. @Component
  24. @EnableConfigurationProperties({ServerProperties.class, ResourceProperties.class})
  25. public class ErrorHandlerConfiguration {
  27.     private final ServerProperties serverProperties;
  29.     private final ApplicationContext applicationContext;
  31.     private final ResourceProperties resourceProperties;
  33.     private final List<ViewResolver> viewResolvers;
  35.     private final ServerCodecConfigurer serverCodecConfigurer;
  37.     public ErrorHandlerConfiguration(ServerProperties serverProperties,
  38.                                      ResourceProperties resourceProperties,
  39.                                      ObjectProvider<List<ViewResolver>> viewResolversProvider,
  40.                                      ServerCodecConfigurer serverCodecConfigurer,
  41.                                      ApplicationContext applicationContext) {
  42.         this.serverProperties = serverProperties;
  43.         this.applicationContext = applicationContext;
  44.         this.resourceProperties = resourceProperties;
  45.         this.viewResolvers = viewResolversProvider.getIfAvailable(Collections::emptyList);
  46.         this.serverCodecConfigurer = serverCodecConfigurer;
  47.     }
  49.     @Bean
  50.     @Order(Integer.MIN_VALUE)
  51.     public ErrorWebExceptionHandler errorWebExceptionHandler(ErrorAttributes errorAttributes) {
  52.         GlobalExceptionHandler exceptionHandler = new GlobalExceptionHandler(
  53.             errorAttributes,
  54.             this.resourceProperties,
  55.             this.serverProperties.getError(),
  56.             this.applicationContext);
  57.         exceptionHandler.setViewResolvers(this.viewResolvers);
  58.         exceptionHandler.setMessageWriters(this.serverCodecConfigurer.getWriters());
  59.         exceptionHandler.setMessageReaders(this.serverCodecConfigurer.getReaders());
  60.         return exceptionHandler;
  61.     }
  62. }

参考

异常处理：https://www.cnblogs.com/duanxz/p/14786337.html