Spring Cloud Gateway嵌套Mono调用时401状态不生效问题求助

问题场景 #

基于Project Reactor的Spring Cloud Gateway应用，需求是异常发生时发送logout HTTP请求，同时将主响应设置为401状态。但遇到以下异常情况：

• 在onErrorResume块中调用logout(exchange)（方式A）时，根响应完全忽略finishWithStatus()逻辑，返回200状态码
• 直接调用finishWithStatus(exchange, HttpStatus.UNAUTHORIZED)（方式B）时，能正常返回401状态码

代码示例 #

@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    return someFunctionWhichReturnsMono()
            .flatMap(chain::filter)
            .onErrorResume(e -> {
                log.error("Unexpected Filter Error, logging out user", e);

                // A. 此方式无法设置401，finishWithStatus(..)逻辑被忽略
                return logout(exchange);  

                // B. 此方式正常生效，返回401响应
                // return finishWithStatus(exchange, HttpStatus.UNAUTHORIZED);
            });
}

protected Mono<Void> finishWithStatus(ServerWebExchange exchange, HttpStatus status) {
    exchange.getResponse().setStatusCode(status);
    return exchange.getResponse().setComplete();
}

protected void logout(ServerWebExchange exchange) {
    webClient
            .post()
            .uri(....)
            .retrieve()
            .bodyToMono(Void.class)
            .doOnSuccess(any -> {
                log.info("Successfully logged out user");
            })
            .then(finishWithStatus(exchange, HttpStatus.UNAUTHORIZED))
            .onErrorResume(e -> {
                log.error("Failed to logout user", e);
                // 出错时以下代码无效果
                return finishWithStatus(exchange, HttpStatus.UNAUTHORIZED);
            });
}

问题原因 #

核心问题是logout方法的返回类型错误：你将它定义为void，而非Mono<Void>，导致Reactor链的连续性被打断：

1. 方式B中直接返回finishWithStatus的Mono<Void>，这个流会被Gateway的Reactor上下文订阅，执行设置状态和完成响应的逻辑，因此能正常返回401。
2. 方式A中调用logout(exchange)时，方法内创建的WebClient请求流没有被返回，相当于这个流处于"悬挂"状态——既没有被订阅，也没有整合到根Reactor链中。此时根链没有收到有效的响应完成信号，Gateway默认返回200状态码。

解决方案 #

1. 修正logout方法的返回值 #

将logout方法改为返回Mono<Void>，确保整个WebClient请求流被纳入根链：

protected Mono<Void> logout(ServerWebExchange exchange) {
    return webClient
            .post()
            .uri(....) // 替换为实际的logout地址
            .retrieve()
            .bodyToMono(Void.class)
            .doOnSuccess(any -> {
                log.info("Successfully logged out user");
            })
            .then(finishWithStatus(exchange, HttpStatus.UNAUTHORIZED))
            .onErrorResume(e -> {
                log.error("Failed to logout user", e);
                return finishWithStatus(exchange, HttpStatus.UNAUTHORIZED);
            });
}

2. 确保根链正确接收流 #

在onErrorResume中直接返回修正后的logout(exchange)返回的Mono，让整个流被Gateway上下文订阅执行：

.onErrorResume(e -> {
    log.error("Unexpected Filter Error, logging out user", e);
    return logout(exchange); // 现在返回的是有效的响应处理流
})

嵌套错误处理通用方案 #

• 保持Reactor链的连续性：所有异步操作必须返回Mono/Flux，并确保它们被正确整合到主链中，避免出现未订阅的"悬挂"流。
• 错误传递要明确：嵌套的onErrorResume处理完错误后，必须返回有效的流信号，确保上层链能正确接收并处理响应。
• 禁止在void方法中创建流：这类流不会被自动订阅，手动调用.subscribe()会脱离Gateway的Reactor上下文，导致响应状态异常。
• 统一响应处理逻辑：将finishWithStatus这类通用响应封装成独立方法，确保所有路径下的响应设置逻辑一致，减少重复代码。

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