Spring WebFlux结合WebClient如何实现可中断的响应式URL迭代调用

核心原则是严格对齐原有for循环的语义：按列表顺序串行发起请求，前一个请求返回非200才发起下一个，拿到200响应立刻终止遍历，不发起多余请求，不需要提前固定URL总数，直接用Reactor原生操作符即可实现。

标准实现代码 #

推荐用concatMap+next()的组合，逻辑最直观，也最容易维护：

// 初始化你的WebClient实例
WebClient webClient = WebClient.create();
List<String> targetUrls = Arrays.asList("one","two","three");

Mono<ClientResponse> firstSuccessResp = Flux.fromIterable(targetUrls)
        // concatMap保证请求严格按顺序串行执行，前一个处理完才会处理下一个
        .concatMap(targetUrl -> webClient.get()
                .uri(targetUrl)
                // 用exchangeToMono拿到完整响应，方便做状态码判断和资源释放
                .exchangeToMono(resp -> {
                    if (resp.statusCode().is2xxSuccessful()) {
                        // 命中200，返回响应对象，触发流终止
                        return Mono.just(resp);
                    } else {
                        // 非200必须释放响应体避免内存泄漏，返回空Mono继续遍历下一个URL
                        return resp.releaseBody().then(Mono.empty());
                    }
                })
        )
        // 取第一个有效响应，拿到后立刻向上游发送取消信号，后续URL不会再被处理
        .next();

写法说明 #

• 适配任意长度的动态URL列表，不需要提前感知列表总长度，Flux.fromIterable直接支持任意集合类型的输入
• 不存在flatMap方案的适配问题：flatMap会并发预取多个元素发起请求，既不保证调用顺序，也无法及时终止后续请求；concatMap会按顺序逐个处理元素，完全对齐传统for循环的串行执行逻辑
• .next()操作符天然实现break效果：一旦流中出现第一个有效元素，就会取消上游订阅，后续未遍历的URL不会触发任何REST调用

简化写法（直接拿业务反序列化对象） #

如果不需要处理原始响应，只需要拿到接口返回的业务DTO，可以用更简洁的retrieve写法：

Mono<YourBusinessDTO> firstSuccessBizData = Flux.fromIterable(targetUrls)
        .concatMap(targetUrl -> webClient.get()
                .uri(targetUrl)
                .retrieve()
                // 匹配所有非200状态码，抛出错误
                .onStatus(status -> !status.is2xxSuccessful(), resp -> Mono.error(new IllegalStateException("请求失败:" + resp.statusCode())))
                .bodyToMono(YourBusinessDTO.class)
                // 捕获非200触发的错误，转成空Mono继续遍历下一个URL
                .onErrorResume(e -> Mono.empty())
        )
        .next();

注意：非200的响应一定要确保资源被释放，不要遗漏资源清理逻辑避免Netty内存泄漏。

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