我在Webflux中使用SpringBoot和反应式编程。我想重复一些对端点的调用，直到数据可用(将返回一些内容)。如何告诉Webflux我的链的这一部分应该被调用5次，因为我的数据库中的数据应该在5-10秒后出现…… 我认为当前的代码导致再次调用整个链，而不仅仅是我的链的适当部分(.flatMap(commandResponse); })
// .re
浏览 109提问于2020-06-29得票数 1
回答已采纳
我想要做的是在Webflux中的单声道上有条件地重复，webclient.The的情况如下：
我们有一些业务rest服务返回一个生成的文档。此文档的生成是从在此服务之前调用的另一个服务触发的。如果没有，请在5秒后重复(或重试)并检查是否生成了文档。依此类推，直到(最坏的情况) 30秒后超时。这个是可能的吗？
浏览 1提问于2019-04-30得票数 18
回答已采纳
1回答
我对WebFlux的研究不是很多，但我发现了一个我无法解决的任务。如果我在当前的请求中有一个超时错误，我应该调用另一个api，如果这个API返回ok -我应该离开这个方法继续执行我的应用程序。.bodyToMono(SendAndStatusResponseDto.class) .retryWhen
浏览 55提问于2020-07-22得票数 0
1回答
secondRequestSender.sendPdf(r))) .repeatWhenEmpty(req -> Flux.interval(Duration.ofSeconds(5)));
// also try .repeatWhenEmpty(3, req -> Flux.interval
浏览 16提问于2020-04-18得票数 0
回答已采纳
3回答
使用spring reactive WebClient，我使用一个应用程序接口，如果响应状态为500，我需要使用指数回退重试。但是在Mono类中，我没有看到任何带有Predicate作为输入参数的retryBackoff。 这是我要搜索的函数类型： public final Mono<T> retryBackoff(Predicate<? super Throwable> retryMatcher, long numRetries, Duration firstBackoff) 现在我的实现如下(我没有使用backOff机制重试)： client.sendReques
浏览 20提问于2019-04-05得票数 1
1回答
在失败或超时的情况下，我需要用指数退避重新尝试发送。我有两种实现逻辑的方法：WebClient.create() .uri(URL) ...
.retryWhen应用WebFlux内部重试特性很容易开发，但我对使用它有一些担心，因为消息存储在应用程序内存中，当消息数量很大时，它可能会影响性能。我想知道其他开发人员对这些选项的想法。还有更好的选择吗？
浏览 14提问于2022-02-13得票数 0
情况如下:有一个API端点作为响应“未决”或“悬空”返回。 .filter(response -> equals("completed"))
.repeatWhenEmptyGenerationApiGetSta
浏览 4提问于2021-08-13得票数 0
我正在尝试使用Kotlin Coroutines + WebFlux.fn + WebClient -addons为反应器添加一个条件重试： suspend fun ClientResponse.asResponseasHttpHeaders()) } .retryWhen
浏览 20提问于2020-03-24得票数 1
2回答
我有一个方法，它发送请求以获取作业状态并返回状态，如下所示：JobStatus对象有一个方法JobStatus.isDone()，它返回挂起的任务是否已完成。
浏览 0提问于2019-06-10得票数 3
回答已采纳
我是webflux的新手，我想做以下事情:我想用不同的参数值对同一个url进行并行的http请求，并在得到第一个非空(和非异常)结果时停止。{id}", id) .bodyToMono(MyObject.class)
.retryWhen
浏览 25提问于2020-12-14得票数 0
回答已采纳
我有个问题要用angular HttpClient在retryWhen上订阅。 this._httpClient.get('myUrl').retryWhen((errors) => { return errors.scandelay(retryOptions.delay)
.takeWhile(count => count <= ret
浏览 0提问于2018-06-18得票数 0
retryWhen(notificationHandler -> Observable.never()).subscribe(x -> {}, t -> log("error"), () -> log("completed"));为什么它永远不会存在？
附言:我有这样的想法，那就是执行中断，因为它都运行在单线程上。并尝试将r
浏览 1提问于2017-05-16得票数 0
我对rxjava有一个非常具体的问题或误解，希望有人能帮上忙。emitter -> { });
.retryWhenProcess finished with exit code 0
我的问题是，我不明白的是:为什么retryWhen在订阅可观察到的内容时立即被调用？我想要的是当在发射器上调用retryWhen时，onError被调用。
浏览 1提问于2017-10-25得票数 3
回答已采纳
1回答
如果有弹性，我正试图模拟数据库崩溃。 participationAdviceSource.getParticipationAdvicesByAMaximumLimitOf(numberOfAdvices) // i want to retry this }
我的测试场景指定
浏览 7提问于2022-01-14得票数 1
我想用repeatWhenEmpty操作符来实现类似的。RuntimeException("Status code : " + clientResponse.statusCode); }).retryWhen
浏览 1提问于2020-03-08得票数 0
1回答
catchError(this.getCatchError)); forkJoin(getPosts, getPostsFaliure) retryWhen
浏览 0提问于2021-04-28得票数 0
回答已采纳
嗨，我有WebFlux和背压的问题： .flatMap((Integer y) -> {
return
浏览 1提问于2021-01-03得票数 0
当连接断开或错误时，源从源stream.Downstream上发出一个错误，我使用retryWhen在每x秒之后尝试重新连接到套接字连接。<any> { .pipe( catchError( () => of( false ) ), //
浏览 2提问于2019-11-29得票数 0
请帮助我处理反应堆，我需要检查一个条件，最多n次，并返回最终结果。它看起来是正确的解决方案，但我不知道该在哪里请举例说明代码private int culculateNextResult(some params) {
浏览 0提问于2019-01-16得票数 5
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
