Mono 链的 Webflux 超时

Question

我正在使用 Spring Webflux 并试图理解 Monos 链的超时概念。

例如，有一个 Mono 调用链：

myService.firstOperation()
.then(myService.secondOperation())
...
.then(myService.nOperation())
.timeout(3000L)

如何应用超时：

1) 对于一般操作（操作总时间）

2) 对于ech操作（每次操作的时间不应超过超时时间）

3) 只针对最后一次操作(nOperation)

?

我几乎可以肯定超时适用于最后一个发布者。如果是这样，如何将超时应用于操作总和？

Answer 1

文档很清楚

timeout - the timeout before the onNext signal from this Mono

因此在您的示例中，超时仅适用于从最后一个 then 返回的 Mono。

.then( ... )
.timeout(3000L)

正确答案是：

3) 只针对最后一次操作(nOperation)

因为这是链中的最后一个。

操作总和没有超时，你为什么需要那个？

Answer 2

超时运算符测量订阅时间与超时运算符观察到的 onNext/onComplete 信号之间经过的时间。

考虑以下示例：

Mono.delay(Duration.ofMillis(1000))
    .then(Mono.delay(Duration.ofMillis(1000)))
    .then(Mono.delay(Duration.ofMillis(1000)))
    .timeout(Duration.ofMillis(2500))
    .block();

如果语句 2（在操作之间测量的时间）或 3（仅计算最后一次操作的持续时间）是正确的，则上述代码不会引发任何错误。

但是，情况是超时操作测量上游所有内容的持续时间，这使得语句 1（测量的所有操作的总和）正确。

在示例中，所有操作的总和 (1000 + 1000 + 1000 = 3000ms) 大于配置的超时 (2500ms)，因此代码导致错误。

Mono 链的 Webflux 超时

Webflux timeout for a chain of Mono

java

spring

reactive-programming

project-reactor

spring-webflux