提问者:小点点

什么是超时运算符准确地衡量一个单声道链在Reactor和网络通量?


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

例如,有一个Mono调用链:

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

如何应用超时:

1)一般操作(操作时间总和)

2)对于ech操作(每次操作时间不要超过超时时间)

3)仅用于最后一次操作(n操作)

?

我几乎可以肯定超时是应用到最后一个发布器的。如果是,超时如何应用到操作总和?


共2个答案

匿名用户

超时运算符测量从订阅时间到超时运算符观察到的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操作)

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

操作总和没有超时,为什么需要那个?