Webflux timeout for a chain of Mono(Mono链的Webflow超时)
问题描述
我正在使用Spring Webflow,并尝试理解Monos链的超时概念。
例如,有一系列Mono调用:
myService.firstOperation()
.then(myService.secondOperation())
...
.then(myService.nOperation())
.timeout(3000L)
如何应用超时:
1)一般操作(操作总时间)
2)用于ECH操作(每次操作不应超过超时)
3)仅用于最后一次操作(n操作)
?
我几乎可以肯定,超时适用于最后一个发布者。如果是,如何将超时应用于操作总数?
推荐答案
超时运算符测量从订阅时间到超时运算符观察到的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),因此代码会导致错误。
这篇关于Mono链的Webflow超时的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:Mono链的Webflow超时
基础教程推荐
- Java 中保存最后 N 个元素的大小受限队列 2022-01-01
- 如何强制对超级方法进行多态调用? 2022-01-01
- Spring Boot Freemarker从2.2.0升级失败 2022-01-01
- 如何使用 Eclipse 检查调试符号状态? 2022-01-01
- 在螺旋中写一个字符串 2022-01-01
- 如何在不安装整个 WTP 包的情况下将 Tomcat 8 添加到 Eclipse Kepler 2022-01-01
- 如何使用 Stream 在集合中拆分奇数和偶数以及两者的总和 2022-01-01
- 首次使用 Hadoop,MapReduce Job 不运行 Reduce Phase 2022-01-01
- 如何对 HashSet 进行排序? 2022-01-01
- 由于对所需库 rt.jar 的限制,对类的访问限制? 2022-01-01