我正在使用 Spring Webflux 并试图理解 Monos 链的超时概念。
例如,有一个 Mono 调用链:
myService.firstOperation()
.then(myService.secondOperation())
...
.then(myService.nOperation())
.timeout(3000L)
如何应用超时:
1) 对于一般操作(操作总时间)
2)对于ech操作(每次操作的时间不应超过超时时间)
3)只针对最后一次操作(nOperation)
?
我几乎可以肯定超时适用于最后一个发布者。如果是这样,如何将超时应用于操作总和?
最佳答案
超时运算符测量订阅时间与超时运算符观察到的 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),因此代码导致错误。
关于java - Reactor 和 Webflux 中的 Mono 链的超时运算符究竟测量了什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58063807/