webclient阻塞主线程netty，为什么？

Question

我不明白为什么webclient会阻止我使用gradle的主要netty线程，以下是它的依赖项：

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:Hoxton.SR11"
    }
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-webflux'
    ...
}

这个gradle脚本在两个应用程序中都使用。在第一个应用程序中，我执行：

    @GetMapping
    open fun otherApp(): Mono<String> {
        return WebClient.create("http://localhost:8081")
                .get()
                .uri("/test")
                .retrieve()
                .bodyToMono(String::class.java)
//              I tried to use an additional scheduler but the main stream is blocked with it too
//              .publishOn(Schedulers.boundedElastic())
    }

第二个应用程序模拟长响应处理：

@GetMapping("/test")
    open fun test(): Mono<String> {
        Thread.sleep(15000L)
        return Mono.just("Hello");
    }

我希望呼叫服务不会阻塞主线程，而是会继续处理传入的连接，但直到我收到第一个呼叫的响应（睡眠将起作用），我的下一个连接将挂起等待。

结果：第一个应用程序像tomcat一样工作，只有一个线程

我的问题是：我做错了什么？

Answer 1

客户端应用程序不会阻塞，它能够处理新请求。您可以通过添加日志来确认：

@GetMapping("/test")
public Mono<String> test() {
    return Mono.just("incoming request")
        .doOnNext(e -> logger.info("Process: {}", e))
        .flatMap(e -> webclient.test());
}

服务器应用程序被阻止，因为线程。sleep（15000L）阻塞主线程（考虑改用.delayElement（持续时间秒（15）））

这是由于浏览器缓存。您应该禁用缓存或强制硬刷新（CTRL F5）。

我测试了硬刷新，它似乎工作得很好。