Spring Integration 5.x混合模式下如何避免WebClient调用使用block()？

一、怎么避免用block() #

你用的Spring MVC是Servlet阻塞栈，但WebClient是响应式组件，不用非得在transformer里硬写block()等待结果。Spring Integration本身支持响应式操作，直接把WebClient返回的Mono/Flux融入流程即可，不用手动阻塞。

举个代码对比的例子：
原来的阻塞写法：

@Bean
public IntegrationFlow mvcInboundFlow() {
    return IntegrationFlows.from(Mvc.inboundGateway("/api"))
            .transform(payload -> {
                // 硬阻塞等待WebClient响应
                String downstreamResp = webClient.get()
                        .uri("/downstream-service")
                        .retrieve()
                        .bodyToMono(String.class)
                        .block();
                return downstreamResp;
            })
            .get();
}

改成响应式衔接的写法：

@Bean
public IntegrationFlow mvcInboundFlow() {
    return IntegrationFlows.from(Mvc.inboundGateway("/api"))
            // 直接返回WebClient的Mono，Spring Integration会自动处理订阅流程
            .handle((payload, headers) -> 
                webClient.get()
                        .uri("/downstream-service")
                        .retrieve()
                        .bodyToMono(String.class)
            )
            // 指定用响应式通道处理流
            .channel(MessageChannels.flux())
            .get();
}

如果必须用gateway接口，也可以定义返回Mono的响应式网关：

// 响应式网关接口
@Gateway
public interface DownstreamGateway {
    @GatewayRequest(channel = "downstreamCallChannel")
    Mono<String> callDownstream(String requestPayload);
}

// 下游调用的IntegrationFlow
@Bean
public IntegrationFlow downstreamCallFlow() {
    return IntegrationFlows.from("downstreamCallChannel")
            .handle((payload, headers) -> 
                webClient.get()
                        .uri("/downstream-service")
                        .retrieve()
                        .bodyToMono(String.class)
            )
            .get();
}

之后在主流程里调用这个网关，直接返回Mono即可，完全不用block()。

二、避免block()有没有实际意义 #

当然有，哪怕Spring MVC本身是阻塞模型，这么做依然能带来不少实际价值：

• 提升资源利用率：block()会占用当前Servlet线程直到下游响应返回，响应式方式下这个线程会立刻释放去处理其他请求，高并发场景下能扛住更多流量，不会轻易把线程池耗干。
• 降低服务雪崩风险：如果下游服务响应变慢，大量block()会导致Servlet线程池耗尽，直接引发服务不可用；非阻塞模式下，线程不会被长时间占用，能更好应对慢请求的冲击。
• 贴合WebClient的设计初衷：WebClient就是为非阻塞响应式编程设计的，用block()相当于浪费了它的性能优势，响应式衔接才能真正发挥它的价值。
• 方便后续架构演进：要是以后想把服务迁移到Spring WebFlux响应式栈，现在的非阻塞代码可以直接复用，不用大规模重构。

需要注意的是，Spring MVC最终还是要等响应式流处理完成后再返回结果给客户端，但中间过程的非阻塞处理已经能有效优化服务的并发能力了。

内容的提问来源于stack exchange，提问作者al.truisme