java - 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)，因此代码导致错误。