如何将Mono结果传入非反应式方法（WebClient场景）

场景
用户通过产品名称请求产品图片URL，但图片URL的解析API只接受产品ID而非名称。在命令式应用里，我会先查询productId，再构建请求URI，最后发起请求。但在反应式场景下，我尝试了三种方式都有问题，求正确的声明式实现方法。

服务接口

@Service
public class ProductService {
    public Mono<Long> lookupProductId(String name) {
        // 实现逻辑：根据名称查询产品ID，返回Mono<Long>
    }
}

控制器代码（含三次失败尝试）

@RestController
@RequestMapping("product")
public class ProductController {
    @GetMapping("/{name}/imageUrl")
    public Flux<String> getProductImages(@PathVariable("name") String name) {
        // 目标URL格式: https://myapp.com/latest/products/XXXXXXXX/imageUrl/?datasource=production
        
        String baseUri = "https://myapp.com/latest/products";
        String dataUri = "/imageUrl/";
        String sourceUri = "?datasource=production";
        
        WebClient otherWebClient = WebClient.builder().baseUrl(baseUri).build();

        // 尝试1：直接subscribe()会阻塞且获取不到正确值，还会破坏反应式流
        return otherWebClient.get()
                .uri(uriBuilder -> uriBuilder.path("/").build(
                    dataUri, 
                    productService.lookupProductId(name).subscribe(), // 错误：subscribe()返回Void，且会提前触发订阅
                    sourceUri))
                .retrieve()
                .bodyToFlux(String.class);
    
        // 尝试2：map里返回WebClient请求，但map会把Mono<Long>转成Mono<Object>，没有正确串联流
        return productService.lookupProductId(name)
            .map(productNumber -> {
                System.out.println(productNumber.toString());   // 能打印正确ID，但后续流处理错误
                return otherWebClient.get()
                    .uri(uriBuilder -> uriBuilder.path("{productId}" + dataUri)
                        .query(sourceUri)
                        .build(productNumber))
                    .retrieve()
                    .bodyToFlux(String.class);
            });     
            
        // 尝试3：Flux.zip需要两个独立的流，但第二个流依赖第一个的结果，无法提前构建
        return Flux.zip(productService.lookupProductId(name),
                otherWebClient.get()
                    .uri(uriBuilder -> uriBuilder.path("/").build(
                        dataUri, 
                        // 无法获取到productId，因为此时Mono还没订阅
                        sourceUri))
                    .retrieve()
                    .bodyToFlux(String.class));
    }
}

问题分析与正确实现
核心问题是没有正确串联反应式流：

• 尝试1：手动调用subscribe()会触发异步操作，但返回Void无法获取ID，还会破坏反应式背压机制。
• 尝试2：map是同步转换，内部返回的Flux<String>会被包装成Mono<Flux<String>>，与方法声明的Flux<String>类型不匹配，且未正确订阅内部流。
• 尝试3：Flux.zip要求两个独立流，但第二个WebClient流依赖第一个Mono的结果，无法提前构建，导致编译失败。

正确实现方式：

@RestController
@RequestMapping("product")
public class ProductController {

    private final ProductService productService;
    private final WebClient otherWebClient;

    // 推荐通过构造函数注入WebClient，避免方法内重复创建
    public ProductController(ProductService productService, WebClient.Builder webClientBuilder) {
        this.productService = productService;
        this.otherWebClient = webClientBuilder.baseUrl("https://myapp.com/latest/products").build();
    }

    @GetMapping("/{name}/imageUrl")
    public Flux<String> getProductImages(@PathVariable("name") String name) {
        // 步骤1：先获取产品ID，再用ID构建WebClient请求
        return productService.lookupProductId(name)
                // flatMapMany将Mono<Long>转换为Flux<String>，串联反应式流
                .flatMapMany(productId -> 
                    otherWebClient.get()
                        .uri(uriBuilder -> uriBuilder
                                .path("/{productId}/imageUrl")
                                .queryParam("datasource", "production") // 用queryParam安全构建查询参数
                                .build(productId))
                        .retrieve()
                        .bodyToFlux(String.class)
                );
    }
}

关键说明

• 使用flatMapMany：适配Mono<Long>到Flux<String>的转换，确保流的正确串联，框架会自动处理订阅逻辑。
• 复用WebClient实例：WebClient是线程安全的，通过构造函数注入单实例，避免重复创建资源。
• 用uriBuilder的queryParam方法：替代字符串拼接，自动处理URL编码，避免参数注入问题。
• 禁止手动调用subscribe()：Spring WebFlux框架会统一管理流的订阅与生命周期，手动调用会引发线程与背压问题。

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