如何通过WebFlux WebClient返回字符串？同步调用报错求助

错误原因 #

你碰到的IllegalStateException是因为Spring WebFlux默认基于Netty构建非阻塞Web服务，控制器方法运行在Reactor的IO线程（reactor-http-nio-*）上。这类线程是为异步非阻塞任务设计的，框架严格禁止在这些线程上调用block()/blockFirst()/blockLast()等阻塞方法——一旦阻塞，会破坏整个非阻塞执行模型，导致线程池耗尽、性能暴跌。

解决方案 #

方案1：遵循WebFlux异步非阻塞设计（推荐） #

直接返回Mono<String>，让WebFlux自动处理异步响应，完全符合框架设计理念，性能最优：

@RestController
public class HomeController {

    private final WebClient webclient;

    // 通过构造器注入WebClient实例
    public HomeController(WebClient.Builder webClientBuilder) {
        this.webclient = webClientBuilder.build();
    }

    @GetMapping("/")
    public Mono<String> home() {
        return webclient.get()
                       .uri(ANY_URL)
                       .retrieve()
                       .bodyToMono(String.class);
    }
}

方案2：强制同步返回（仅用于必须同步的场景） #

如果业务逻辑要求必须同步返回字符串，可选择以下两种方式：

方式一：切换到Servlet容器（如Tomcat）

在pom.xml中添加spring-boot-starter-web依赖，Spring Boot会自动切换为Tomcat作为服务器，控制器方法将运行在Tomcat的线程池里，此时调用block()是允许的：

<dependencies>
    <!-- 添加Web依赖，切换到Servlet容器 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
    </dependency>
    <!-- 测试依赖保持不变 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>io.projectreactor</groupId>
        <artifactId>reactor-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

添加依赖后，你原本的代码（调用block()）即可正常运行。

方式二：用自定义线程池执行阻塞操作

若不想切换Servlet容器，可将block()操作转移到专门的阻塞线程池中执行，避免阻塞WebFlux的IO线程：

@RestController
public class HomeController {

    private final WebClient webclient;
    private final ExecutorService blockingExecutor;

    public HomeController(WebClient.Builder webClientBuilder) {
        this.webclient = webClientBuilder.build();
        // 创建专门处理阻塞任务的线程池
        this.blockingExecutor = Executors.newFixedThreadPool(10);
    }

    @GetMapping("/")
    public String home() throws ExecutionException, InterruptedException {
        Mono<String> remoteMono = webclient.get()
                       .uri(ANY_URL)
                       .retrieve()
                       .bodyToMono(String.class);
        // 将block操作提交到自定义线程池执行
        return Mono.fromCallable(remoteMono::block)
                   .subscribeOn(Schedulers.fromExecutor(blockingExecutor))
                   .block();
    }

    // 应用关闭时关闭线程池
    @PreDestroy
    public void shutdownExecutor() {
        blockingExecutor.shutdown();
    }
}

注意：这种方式会引入额外线程开销，违背WebFlux非阻塞设计初衷，仅作为临时解决方案使用。

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