Webflux返回Mono时，如何不违反响应式原则设置Location响应头

直接调用monoProduct.block()会阻塞线程，完全违背Webflux的非阻塞响应式设计原则。正确的做法是利用响应式操作符链式处理数据流，在产品数据就绪后再构建包含Location头的响应。

核心实现思路 #

使用flatMap操作符订阅Mono<Product>，当产品创建完成并返回数据时，在回调中获取产品ID生成Location URI，同时构建完整的响应对象。这样所有操作都保持在响应式管道中，不会产生阻塞。

修正后的代码示例 #

public Mono<ServerResponse> handleRequest(ServerRequest serverRequest) {
    Mono<Product> monoProduct = // 调用服务获取创建后的产品Mono流
    return monoProduct.flatMap(product -> {
        // 生成Location URI
        URI locationUri = URI.create(String.format("/api/products/%s", product.getId()));
        // 构建响应，包含Location头和响应体
        return ServerResponse.ok()
                .contentType(MediaType.APPLICATION_JSON)
                .location(locationUri)
                .bodyValue(product); // 若需转换为ProductResponse，先做转换再传入
    });
}

扩展：转换为ProductResponse的场景 #

如果需要将Product转换为ProductResponse返回，只需在flatMap回调中先完成对象转换：

public Mono<ServerResponse> handleRequest(ServerRequest serverRequest) {
    Mono<Product> monoProduct = // 调用服务获取创建后的产品Mono流
    return monoProduct.flatMap(product -> {
        // 自定义转换逻辑，将Product转为ProductResponse
        ProductResponse productResponse = new ProductResponse();
        productResponse.setId(product.getId());
        productResponse.setName(product.getName());
        // 其他字段转换...
        
        URI locationUri = URI.create(String.format("/api/products/%s", product.getId()));
        return ServerResponse.ok()
                .contentType(MediaType.APPLICATION_JSON)
                .location(locationUri)
                .bodyValue(productResponse);
    });
}

关键注意点 #

• 绝对避免在响应式流中使用block()、blockFirst()等阻塞方法，这些会破坏非阻塞模型，导致性能瓶颈
• flatMap是响应式编程中常用的转换操作符，用于将一个Mono/Flux转换为另一个Mono/Flux，保持数据流的异步非阻塞特性

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