如何处理WebClient的异步响应？解决移除block()后无请求日志问题

首先，你遇到的核心问题是Reactor序列的惰性求值特性：Mono<ClientResponse>只有在被订阅的时候才会触发实际的HTTP请求。原来的block()方法既是订阅操作，也是阻塞当前线程等待结果的方式；当你去掉block()后，如果没有其他订阅操作，整个请求链根本不会执行，自然看不到Netty的日志，也不会处理响应。

而你尝试的doOnSuccess只是一个副作用操作符——它定义了成功时要执行的逻辑，但并不会触发订阅，所以依然不会有任何请求发生。

正确的异步处理方式 #

要让请求执行并处理异步响应，你需要显式调用subscribe()，同时可以结合doOnSuccess、doOnError等操作符来处理响应和异常，或者直接在subscribe()中传入回调：

方案1：直接在subscribe()中处理成功/失败

@Override
public void push(Data data) {
    String body = constructString(data);
    webClient.post()
            .uri(URL + getLogType(data))
            .contentLength(body.length())
            .contentType(MediaType.APPLICATION_JSON)
            .syncBody(body)
            .exchange()
            .subscribe(
                    // 成功处理响应
                    clientResponse -> {
                        logger.debug("Status : " + clientResponse.statusCode());
                        // 处理响应体：需要订阅bodyToMono才能获取实际内容
                        clientResponse.bodyToMono(String.class)
                                .subscribe(bodyStr -> logger.debug("Body : " + bodyStr));
                    },
                    // 处理请求异常
                    error -> logger.error("Request failed", error)
            );
}

方案2：用doOn系列操作符+subscribe()

如果想把副作用逻辑和订阅分开，可以这样写：

@Override
public void push(Data data) {
    String body = constructString(data);
    Mono<ClientResponse> res = webClient.post()
            .uri(URL + getLogType(data))
            .contentLength(body.length())
            .contentType(MediaType.APPLICATION_JSON)
            .syncBody(body)
            .exchange();

    res.doOnSuccess(clientResponse -> {
                logger.debug("Status : " + clientResponse.statusCode());
                // 注意：bodyToMono也是惰性的，需要订阅才能获取内容
                clientResponse.bodyToMono(String.class)
                        .doOnSuccess(bodyStr -> logger.debug("Body : " + bodyStr))
                        .subscribe(); // 订阅响应体的Mono
            })
            .doOnError(error -> logger.error("Request failed", error))
            .subscribe(); // 必须订阅这个顶层的Mono，才会触发请求
}

关键注意点 #

1. 响应体的处理：clientResponse.bodyToMono(String.class)返回的也是一个Mono，同样需要订阅才能读取响应体内容，直接打印这个Mono对象只会输出它的引用，不会显示实际内容。
2. 异常处理：一定要添加错误处理逻辑（比如doOnError或者subscribe的错误回调），否则请求过程中发生的异常会被静默丢弃，难以排查问题。
3. 日志配置：确保reactor.ipc.netty和reactor.netty.http.client的日志级别都设置为DEBUG，这样能完整看到请求发送和响应接收的细节。

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