PS：

response.setComplete();// 加上这个会使得前端取不到返回值，其content-length = 0

  1. package xyz.haishui.offer.gateway.filter;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.cloud.gateway.filter.GatewayFilterChain;
  7. import org.springframework.cloud.gateway.filter.GlobalFilter;
  8. import org.springframework.core.Ordered;
  9. import org.springframework.core.io.buffer.DataBuffer;
  10. import org.springframework.http.HttpStatus;
  11. import org.springframework.http.MediaType;
  12. import org.springframework.http.server.reactive.ServerHttpResponse;
  13. import org.springframework.stereotype.Component;
  14. import org.springframework.web.server.ServerWebExchange;
  15. import reactor.core.publisher.Mono;
  16. import xyz.haishui.offer.common.RestResult;
  17. import xyz.haishui.offer.gateway.config.AuthFilterConfig;
  19. import java.net.URI;
  20. import java.nio.charset.StandardCharsets;
  21. import java.util.List;
  23. @Component
  24. public class AuthFilter implements GlobalFilter, Ordered {
  26.     private Logger logger = LoggerFactory.getLogger(this.getClass());
  28.     @Autowired
  29.     private AuthFilterConfig authFilterConfig;
  31.     @Override
  32.     public int getOrder() {
  33.         return 1;
  34.     }
  36.     /**
  37.      * Process the Web request and (optionally) delegate to the next {@code WebFilter}
  38.      * through the given {@link GatewayFilterChain}.
  39.      *
  40.      * @param exchange the current server exchange
  41.      * @param chain    provides a way to delegate to the next filter
  42.      * @return {@code Mono<Void>} to indicate when request processing is complete
  43.      */
  44.     @Override
  45.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  46.         if (!authFilterConfig.isEnable()){
  47.             return chain.filter(exchange);
  48.         }
  49.         URI uri = exchange.getRequest().getURI();
  50.         if (authFilterConfig.getCheckUrls().stream().anyMatch(
  51.                 url ->  uri.getPath().matches(url)
  52.                 )){
  53.             // 检查token
  54.             List<String> authorizationList = exchange.getRequest().getHeaders().get("Authorization");
  55.             if (authorizationList==null||authorizationList.size()==0){
  56.                 return errorReturn(exchange.getResponse());
  57.             }
  58.             logger.debug("检查token");
  59.         }
  60.         return chain.filter(exchange);
  61.     }
  63.     /**
  64.      * token检验不通过
  65.      * @param response ServerHttpResponse
  66.      * @return 写入错误提示并结束过滤链条，返回给前端
  67.      */
  68.     private Mono<Void> errorReturn(ServerHttpResponse response){
  69.         String data=new RestResult<String>().unauthorized().msg("请登录").toString();
  70.         byte[] bytes = data.getBytes(StandardCharsets.UTF_8);
  71.         DataBuffer buffer = response.bufferFactory().wrap(bytes);
  72.         response.getHeaders().add("Content-Type", "text/plain;charset=UTF-8");
  73. //        response.setComplete();// 加上这个会使得前端取不到返回值，其content-length = 0
  74.         response.setStatusCode(HttpStatus.OK);
  75.         return response.writeWith(Mono.just(buffer));
  76.     }
  77. }