WebClient背压异常排查：跨服务异步请求limitRate未按预期生效

问题根源 #

场景2的核心问题是WebClient底层依赖的Reactor Netty HttpClient默认启用了自动读取/预取机制：它会主动从HTTP连接中读取尽可能多的响应数据到内存，完全绕过了下游limitRate(3)设置的背压信号。这就导致上游Service#1收到的请求量不是由下游的背压控制，而是由HttpClient的预取策略决定，所以会出现request(1)和request(31)这类不符合预期的日志。

而场景1中MongoDB的Reactive驱动直接与Flux的背压机制绑定，limitRate可以直接控制数据库查询的请求批次，因此表现正常。

解决步骤 #

1. 配置WebClient禁用自动读取，传递背压信号

需要自定义HttpClient，关闭AUTO_READ选项，让下游的背压信号能够传递到上游Service#1，控制数据发送节奏：

// 构建自定义HttpClient，关闭自动读取
HttpClient httpClient = HttpClient.create()
    .tcpConfiguration(tcpClient -> tcpClient
        .option(ChannelOption.AUTO_READ, false)
        .doOnConnected(conn -> {
            conn.addHandlerLast(new ReadTimeoutHandler(10));
            conn.addHandlerLast(new WriteTimeoutHandler(10));
        }));

// 使用自定义HttpClient创建WebClient
WebClient webClient = WebClient.builder()
    .clientConnector(new ReactorClientHttpConnector(httpClient))
    .baseUrl("http://localhost:8080")
    .build();

2. 确保上游Service#1的接口是真正的流式响应

Service#1的控制器方法必须直接返回Flux<Book>，且WebFlux框架正确启用Chunked Transfer Encoding，避免将整个响应缓存后一次性发送。示例代码：

@GetMapping("/books/stream")
public Flux<Book> streamBooks() {
    return bookRepository.findAll()
        .log() // 用于观察request日志
        .limitRate(3);
}

3. 验证下游背压的订阅方式

确保下游Service#2对WebClient返回的Flux的订阅支持背压。比如在WebFlux端点中直接返回该Flux（由框架处理订阅），或者手动订阅时明确控制请求量：

webClient.get()
    .uri("/books/stream")
    .retrieve()
    .bodyToFlux(Book.class)
    .limitRate(3)
    .delayElements(Duration.ofSeconds(1))
    .subscribe(
        book -> System.out.println("Received: " + book),
        error -> error.printStackTrace(),
        () -> System.out.println("Stream completed")
    );

补充说明 #

• 为什么添加delayElements无效？因为当HttpClient自动读取了所有响应数据到内存后，delayElements只是在内存中延迟处理数据，无法再影响上游Service#1的请求量，背压信号已经无法传递回去。
• 可以启用Reactor Netty的wiretap日志，观察HTTP连接的读取行为，验证背压是否生效：

HttpClient httpClient = HttpClient.create()
    .wiretap(true) // 启用wiretap日志
    .tcpConfiguration(...)

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