Reactor 和 Webflux 中的 Mono 链超时算子到底测量了什么？

Question

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

例如，有一系列 Mono 调用：

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

如何应用超时：

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

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

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

？

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

Answer 1

超时运算符测量订阅时间和超时运算符观察到的 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)，因此代码会导致错误。