Spring Cloud Gateway中AbstractGatewayFilterFactory认证处理问题排查

方案1：请求重定向主机错误的问题修复 #

问题原因 #

你当前的实现是修改请求后通过chain.filter继续转发，本质是内部路由转发而非返回重定向响应。虽然设置了GATEWAY_REQUEST_URL_ATTR，但Spring Cloud Gateway的路由逻辑会结合原请求的服务发现元数据（比如USERSERVICE的实例地址），导致最终转发到错误的主机。

正确实现方式 #

直接返回HTTP 302重定向响应，通过设置Location头指定目标地址：

@Component
public class UserAuthenticationFilter extends AbstractGatewayFilterFactory<UserAuthenticationFilter.Config> {

    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            try {
                // 此处执行令牌检查逻辑
                return chain.filter(exchange);
            } catch (TokenNotFoundException e) {
                ServerHttpResponse response = exchange.getResponse();
                // 设置302重定向状态码
                response.setStatusCode(HttpStatus.FOUND);
                // 设置重定向目标地址
                response.getHeaders().setLocation(URI.create("http://127.0.0.1:8080/apigw/askauth"));
                return response.setComplete();
            }
        };
    }

    public static class Config {
        // 按需定义配置参数
    }
}

方案2：401响应无消息的问题修复 #

问题原因 #

仅设置状态码但未向响应体写入错误内容，导致前端无法看到具体说明。

正确实现方式 #

手动写入JSON格式的错误消息到响应体：

@Component
public class UserAuthenticationFilter extends AbstractGatewayFilterFactory<UserAuthenticationFilter.Config> {

    private final ObjectMapper objectMapper;

    // 注入ObjectMapper用于序列化JSON响应
    public UserAuthenticationFilter(ObjectMapper objectMapper) {
        this.objectMapper = objectMapper;
    }

    @Override
    public GatewayFilter apply(Config config) {
        return (exchange, chain) -> {
            try {
                // 此处执行令牌检查逻辑
                return chain.filter(exchange);
            } catch (TokenNotFoundException e) {
                ServerHttpResponse response = exchange.getResponse();
                response.setStatusCode(HttpStatus.UNAUTHORIZED);
                // 设置响应内容类型为JSON
                response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
                
                // 构造错误响应体
                Map<String, Object> errorResponse = new HashMap<>();
                errorResponse.put("status", 401);
                errorResponse.put("message", "请求中无认证令牌");
                
                // 将响应体写入缓冲区
                DataBuffer buffer = response.bufferFactory().wrap(objectMapper.writeValueAsBytes(errorResponse));
                return response.writeWith(Mono.just(buffer));
            }
        };
    }

    public static class Config {
        // 按需定义配置参数
    }
}

优化建议 #

为了避免硬编码地址，可通过配置文件动态注入重定向地址：

1. 在Config类中添加配置属性：

public static class Config {
    private String redirectUri;

    public String getRedirectUri() {
        return redirectUri;
    }

    public void setRedirectUri(String redirectUri) {
        this.redirectUri = redirectUri;
    }
}

2. 在application.yml中配置过滤器参数：

spring:
  cloud:
    gateway:
      routes:
        - id: user_service_route
          uri: lb://USERSERVICE
          predicates:
            - Path=/users/**
          filters:
            - name: UserAuthenticationFilter
              args:
                redirectUri: http://127.0.0.1:8080/apigw/askauth

3. 修改过滤器代码使用配置地址：

// 在重定向逻辑中替换为配置值
response.getHeaders().setLocation(URI.create(config.getRedirectUri()));

内容的提问来源于stack exchange，提问作者Dec0de