spring-boot - Spring WebFlux WebClient 挂起并且 Mono.timeout 没有捕捉到它

Question

我有相当简单的 Kotlin 代码，它总是阻塞并且从不返回:

WebClient
        .create()
        .get()
        .uri("https://httpbin.org/status/200")
        .exchange()
        .flatMap {
            println("Status ${it.statusCode()}")
            it.bodyToMono(String::class.java)
        }
        .timeout(Duration.ofSeconds(5), Mono.just("fallback"))
        .map { println("Response $it") } // never runs
        .block()

• httpbin 在这种情况下不返回任何内容(仅返回标题)，那么 bodyToMono 是否会永远等待这里的内容？有没有可靠的方法来处理这种情况(阅读 Content-Length 不可靠)

• 我用回退值设置了 Mono.timeout，为什么它没有涵盖它？

Answer 1

在这种情况下，httpbin.org 不会返回响应主体，因此 bodyToMono 方法将返回与 Mono.empty() 等效的方法。

如果您将 map { println("Response $it") }(永远不会运行，因为我们没有得到主体)更改为 doOnSuccess { log.info ("Response received") }，打印“Response received”消息。

这意味着 Mono 没有卡住，它只是用一个空体完成。