Spring Cloud Gateway中WebSocket请求未经过全局过滤器的咨询

1. WebSocket请求是否会经过GlobalFilters？ #

WebSocket请求分两个阶段处理：

• 握手阶段：这是标准HTTP请求（带Upgrade: websocket等专属头），会完整经过Spring Cloud Gateway的GlobalFilter和路由过滤器链，逻辑和普通HTTP请求完全一致。
• 连接建立后的帧传输阶段：此时是基于TCP的长连接数据交互，不会再走Gateway的HTTP过滤器链，网关仅做透明转发。

你遇到的过滤器不生效问题，大概率是WebSocket握手请求的路径未匹配网关路由，或者握手请求未携带Authorization头导致过滤器触发了降级分支。

2. 若WebSocket请求不经过GlobalFilters，是否有办法为WebSocket指定过滤器？ #

针对WebSocket场景，有两种针对性处理方式：

• 针对握手请求：直接复用现有GlobalFilter，确保握手请求路径匹配网关路由且携带必要请求头即可。如果需要单独为WebSocket路由配置过滤器，可在网关路由中添加专属的GatewayFilter，而非依赖全局过滤器。
• 针对WebSocket连接后的帧处理：Gateway本身不提供这类过滤器，需在后端WebSocket服务中通过WebSocketHandlerDecorator或自定义HandshakeInterceptor来处理消息帧。

3. 有没有办法通过Spring Cloud Gateway向WebSocket请求中注入用户信息？ #

可以实现，核心是利用WebSocket握手阶段的HTTP请求特性：

1. 适配现有GlobalFilter：确保握手请求能触发你的CustomGlobalFilter，在握手时解析JWT并将username注入请求头。后端WebSocket服务在握手过程中（比如通过HandshakeInterceptor）读取该请求头，将用户信息存入WebSocket Session，后续消息处理即可直接获取。
2. 优化过滤器逻辑：当前过滤器在缺少Authorization头时直接返回原请求，建议针对WebSocket握手请求增加判断，避免遗漏用户信息注入：

override fun filter(exchange: ServerWebExchange, chain: GatewayFilterChain): Mono<Void> {
    // 判断是否为WebSocket握手请求
    val isWebSocketHandshake = exchange.request.headers.getFirst("Upgrade")?.equals("websocket", ignoreCase = true) == true
    return modifyHeaders(exchange)
        .flatMap { chain.filter(it) }
}

3. 后端服务配合：在后端WebSocket服务中配置HandshakeInterceptor，读取网关注入的username头并存入Session：

@Component
public class WebSocketHandshakeInterceptor implements HandshakeInterceptor {
    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
        String username = request.getHeaders().getFirst("username");
        if (username != null) {
            attributes.put("username", username);
        }
        return true;
    }

    @Override
    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {}
}

额外路由配置建议 #

确保WebSocket路由配置精准，建议显式指定WebSocket专属路由：

gateway:
  routes:
    - id: example-websocket
      uri: ws://localhost:80
      predicates:
        - Path=/example/ws/**
        - Header=Upgrade, websocket
      filters:
        - RewritePath=/example/ws/(?<path>.*), /$\{path}

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