Spring Cloud Gateway中避免使用block()方法的正确实现方案

在Spring Cloud Gateway这类基于Reactor的响应式框架中，block()会阻塞事件循环线程（如reactor-http-nio），违反响应式编程的非阻塞原则，因此被框架禁止。以下是针对你问题的具体解决方案：

1. 替代block()的正确实现方式 #

全程保持响应式流的连续性，所有依赖getPayload()返回结果的操作，都通过Reactor操作符（如map、flatMap）在Mono流中完成，最终返回Mono对象，由框架负责订阅执行。

示例改造（以Gateway过滤器场景为例）： #

@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    return client.getPayload(...)
            .flatMap(response -> {
                // 处理获取到的Response对象，比如存入请求上下文
                exchange.getAttributes().put("ACCESS_TOKEN", response.getAccessToken());
                // 继续执行网关过滤链
                return chain.filter(exchange);
            });
}

通用响应式场景改造： #

public Mono<BusinessResult> processToken() {
    return client.getPayload(...)
            .map(response -> {
                // 基于响应结果转换为业务对象
                return new BusinessResult(response.getAccessToken());
            });
}

2. 正确处理subscribe()中的结果 #

subscribe()是触发异步流执行的入口，但回调逻辑是异步执行的，无法从外部直接获取回调内的对象（外部代码会先于回调执行，此时对象尚未赋值）。正确做法是放弃"获取普通Java对象"的思维，用响应式操作符串联逻辑：

错误写法（请勿使用）： #

Mono<UaaToken> tokenMono = client.getPayload(...);
UaaToken plainJavaObject = null;
tokenMono.subscribe(token -> plainJavaObject = token);
// 此处plainJavaObject大概率为null，因为subscribe是异步执行

正确写法： #

Mono<UaaToken> tokenMono = client.getPayload(...);

// 转换结果，保持响应式流
Mono<String> tokenValueMono = tokenMono.map(UaaToken::getAccessToken);

// 调用其他异步服务，用flatMap串联
Mono<BusinessResult> resultMono = tokenMono.flatMap(token -> {
    return businessService.processToken(token);
});

仅在非响应式环境（如单元测试）中，才允许使用block()，但Spring Cloud Gateway的业务逻辑中绝对禁止。

3. 简化AtomicReference的代码 #

你提供的AtomicReference写法是典型的"将响应式代码强行转为阻塞式"的错误实践，完全不需要原子引用，直接通过响应式操作符处理即可：

原错误代码： #

AtomicReference<ResponseObject> plainJavaObject = new AtomicReference<>();
processData().subscribe(transformedToken -> {
    plainJavaObject.set(transformedToken);
});
ResponseObject responseObject = plainJavaObject.get();

简化后的正确写法： #

// 处理结果并返回响应式对象
public Mono<ProcessedResult> handleData() {
    return processData()
            .map(responseObject -> {
                // 转换为业务需要的对象
                return new ProcessedResult(responseObject.getContent());
            });
}

// 直接在响应式流中使用结果
processData().subscribe(responseObject -> {
    // 在此处直接使用responseObject完成同步操作（如日志）
    // 若需异步操作，改用flatMap串联而非在subscribe内调用
});

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