Reactor线程不支持block()，如何正确设计getHeaders()方法？

核心问题分析 #

你在getHeaders()里用block()强制同步等待token，违反了Reactor非阻塞线程的规则，所以触发了报错。解决思路是把整个Header获取流程改成全非阻塞的链式调用，不能在非阻塞线程里做任何阻塞操作。

步骤1：重构getHeaders()为非阻塞方法 #

把原来返回同步MultiValuedMap改成返回Mono<MultiValuedMap<String, Object>>，用Reactor操作符处理token的获取逻辑：

public Mono<MultiValuedMap<String, Object>> getHeaders() {
    // 如果token已存在，直接返回包含token的headers
    if (token != null) {
        return Mono.just(buildHeadersWithToken());
    }
    
    // token不存在时，异步获取token，设置后再返回headers
    return getTokenFromExternalApi()
        .map(this::setToken) // 获取到token后设置到实例变量
        .map(resp -> buildHeadersWithToken()) // 构建带token的headers
        .cache(); // 缓存token结果，避免重复调用外部API
}

// 抽离构建headers的逻辑，复用代码
private MultiValuedMap<String, Object> buildHeadersWithToken() {
    MultiValuedMap<String, Object> headers = new LinkedMultiValueMap<>();
    // 添加token和其他静态header数据
    headers.add("Authorization", "Bearer " + token);
    headers.add("Content-Type", MediaType.APPLICATION_JSON_VALUE);
    // 其他静态headers...
    return headers;
}

// 原setToken方法保持不变，假设是设置实例变量token
private String setToken(TokenResponse resp) {
    this.token = resp.getToken();
    return this.token;
}

步骤2：修改getSomeInformation()适配非阻塞Header #

原来的代码是同步获取headers，现在要改成先订阅headers的Mono，再在flatMap里构建并发送请求：

class OneClient {
    public Mono<Information> getSomeInformation(ClientRequest req) {
        // 先异步获取headers，再flatMap发送请求
        return getHeaders()
            .flatMap(headers -> 
                getWebTarget(req)
                    .request(MediaType.APPLICATION_JSON_TYPE)
                    .headers(headers)
                    .rx(MonoRxInvoker.class)
                    .get()
                    .map(this::processResponse)
                    .doOnError(this::processError)
            );
    }
}

关键细节说明 #

• cache()操作符：用来缓存token的Mono结果，后续请求会直接复用已获取的token，不用重复调用外部API，同时保持非阻塞特性。
• 线程安全注意：如果是多线程环境，建议用AtomicReference存储token，或者直接依赖cache()维护的缓存逻辑，避免并发修改问题。
• 全链路非阻塞：整个请求从获取token、构建headers到发送业务请求，都是Reactor的链式异步操作，不会阻塞任何非阻塞线程。

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