我正在使用Spring Web流并试图理解Monos链的超时概念。
例如,有一个Mono调用链:
myService.firstOperation()
.then(myService.secondOperation())
...
.then(myService.nOperation())
.timeout(3000L)
如何应用超时:
1)一般操作(操作时间总和)
2)对于ech操作(每次操作时间不要超过超时时间)
3)仅用于最后一次操作(n操作)
?
我几乎可以肯定超时是应用到最后一个发布器的。如果是,超时如何应用到操作总和?
超时运算符测量从订阅时间到超时运算符观察到的onNext/on完成信号之间经过的时间。
考虑以下示例:
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),因此代码会导致错误。
文件很清楚
timeout-来自此Mono的onNext信号之前的超时时间
因此,在您的示例中,超时仅适用于从最后一个然后
返回的Mono。
.then( ... )
.timeout(3000L)
正确答案是:
3)仅用于最后一次操作(n操作)
因为这是链中的最后一个。
操作总和没有超时,为什么需要那个?