问题描述
在quarkus(kotlin)应用程序中,我并行请求多个端点(相同的端点,但具有不同的基本URL),然后将uni组合在一起,以免顺序地等待每个响应。
以下是示例:
val unis = repository.findUnis()
?.sites
?.map { site ->
RestClientBuilder.newBuilder()
.baseUri(URI.create(site.url))
.build(MyClientService::class.java)
.api("param")
.ifNoItem()
.after(Duration.ofMillis(1))
.recoverWithItem(null)
.onFailure()
.invoke {
logger.info("Error while connecting to ${site.url}",it)
}
.onFailure()
.recoverWithItem(null as? String)
}
return Uni.combine().all().unis<String>(unis)
.combinedWith { it as (List<String?>?) }
.await().atMost(Duration.ofMillis(1))
?.filterNotNull()
我遇到的问题是在发生超时的情况下不使用ifNoItem
。如果单个uni花费的时间超过1毫秒(此值仅用于测试...),则最后一个块在combinedWith(...).await()
处引发TimeoutException。
我想在单个uni级别上处理超时,并且将此错误视为故障(并进行记录和恢复)。但这似乎不起作用。我的实现来自https://smallrye.io/smallrye-mutiny/#_how_do_i_handle_timeout)。
如何正确执行?
解决方法
而不是.ifNoItem().after(Duration.ofMillis(1)).recoverWithItem(null)
,请使用:
.ifNoItem().after(Duration.ofMillis(1).fail()
,将传播故障。