Spring Cloud Gateway MVC如何为路由添加动态请求头？

问题分析 #

你的核心问题有两个：

1. 自定义请求头处理逻辑未生效：你创建了新的ServerRequest但未返回，仍返回原请求对象，导致修改后的请求头无法传递。
2. 会话信息获取方式错误：直接依赖全局的helper.userProfile无法拿到当前请求的会话数据，且你误解了addRequestHeaderDynamicValue()的调用时机——该方法仅在启动时执行一次生成处理函数，但函数内部逻辑本应在每次请求时执行。

修正方案 #

1. 正确实现动态请求头处理函数 #

修改UserHeaderFilter，确保返回构建后的新请求对象，并从当前请求会话中获取用户数据：

@Component
public class UserHeaderFilter {

    private final UserHelper userHelper;

    // 构造注入（Spring推荐方式）
    public UserHeaderFilter(UserHelper userHelper) {
        this.userHelper = userHelper;
    }

    public Function<ServerRequest, ServerRequest> addRequestHeaderDynamicValue() {
        return request -> {
            // 从当前请求会话中获取用户邮箱
            String email = userHelper.getUserEmailFromCurrentSession(request);
            
            if (email != null) {
                // 构建请求头修改逻辑
                Consumer<HttpHeaders> headersConsumer = httpHeaders -> {
                    httpHeaders.set("X-User-Email", email);
                    // 可添加其他动态头处理逻辑
                };
                // 返回修改后的新请求对象
                return ServerRequest.from(request).headers(headersConsumer).build();
            }
            
            // 无有效用户信息时返回原请求
            return request;
        };
    }
}

2. 调整UserHelper以支持当前请求会话获取 #

修改UserHelper，添加从当前ServerRequest中提取会话用户信息的方法：

@Component
public class UserHelper {

    public String getUserEmailFromCurrentSession(ServerRequest request) {
        return request.session()
                .map(session -> session.getAttribute("userEmail")) // 替换为你实际的会话存储Key
                .orElse(null);
    }
}

3. 路由配置中注入并使用Filter #

在路由Bean中注入UserHeaderFilter实例，调用方法获取处理函数：

@Bean
public RouterFunction<ServerResponse> bookServiceRoute(UserHeaderFilter userHeaderFilter) {
    return route("bookRoute")
            .route(RequestPredicates.path("/bff/**"), http("http://localhost:8001"))
            .before(rewritePath("/crm/bff/(?<segment>.*)", "/acme/crm/${segment}"))
            .before(addRequestHeader("X-User-Key", "test"))
            .before(userHeaderFilter.addRequestHeaderDynamicValue()) // 绑定动态头处理逻辑
            .build();
}

关键说明 #

• addRequestHeaderDynamicValue()仅在启动时执行一次，目的是生成请求处理函数，该函数会在每次请求到达时触发执行，确保能获取当前请求的会话数据。
• 必须返回ServerRequest.from(request).headers(...).build()生成的新请求对象，否则请求头修改不会生效。
• 通过request.session()获取当前请求的会话，才能拿到与请求绑定的用户信息，避免全局对象导致的线程安全问题。

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