Spring Webflux中WebClient调用结果无法输出问题求助

问题根源 #

你的代码中，listlyResponse.subscribe(...)是异步触发HTTP请求，但当前线程（比如main线程）不会等待这个Mono的执行完成，直接执行后续的log.info("Exiting service call to Listly")后就结束了方法。如果是独立运行的程序（比如main方法测试），主线程退出会直接终止JVM，导致异步请求的响应还没返回、日志还没打印就结束了。

而断点调试时，断点会阻塞主线程，给了异步请求足够的时间完成响应，所以你能看到返回内容。

解决方案 #

根据你的运行场景，选择对应的处理方式：

1. 测试场景（如main方法/单元测试） #

如果只是临时测试，可以用block()强制等待Mono执行完成（注意：生产环境Webflux应用中禁止使用block()，会阻塞线程破坏响应式特性）：

listlyResponse.subscribe(listlyResp -> log.info(listlyResp));
listlyResponse.block(); // 等待异步请求完成后再继续执行

2. Webflux Web应用场景（生产/正式服务） #

不要用void作为方法返回值，改为返回Mono<Void>，让Spring Webflux框架管理异步流程的生命周期，确保请求完成后再结束：

@Override
public Mono<Void> callListlyService(String searchUrl) {
    if (searchUrl == null) {
        return Mono.error(new RuntimeException("Search URL cannot be null"));
    }
    log.info("Starting call to Listly API");
    Mono<String> listlyResponse = WebClient.create(baseUrl)
        .get()
        .uri(uriBuilder -> uriBuilder
                .path("/meta")
                .queryParam("url","{url}")
                .build(searchUrl))
        .retrieve()
        .bodyToMono(String.class);

    return listlyResponse
        .doOnNext(listlyResp -> log.info(listlyResp)) // 响应返回时打印日志
        .doFinally(signal -> log.info("Exiting service call to Listly")) // 操作完成后打印退出日志
        .then(); // 转换为Mono<Void>表示操作完成
}

在控制器中调用这个方法时，直接返回该Mono即可，Webflux会自动处理订阅和等待逻辑。

3. 添加错误处理（排查异常情况） #

如果请求本身出错（比如网络问题、API返回错误），异常会被默认的订阅者吞掉，导致看不到日志。可以给subscribe添加错误处理分支：

listlyResponse.subscribe(
    listlyResp -> log.info(listlyResp),
    error -> log.error("Failed to call Listly API", error)
);

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