我有一个java webclient代码，我将其响应转换为Mono。我想对api调用进行迭代，直到Mono响应符合特定条件。当然，我不想迭代到无穷大。我想每隔5秒迭代一次，直到30秒。condition) { return Mono.just(r);
浏览 94提问于2020-05-05得票数 0
回答已采纳
1回答
我使用的是Mono的filterWhen()，有多个条件，如下所示，但不知道如何实现正确的方式。webClient.call(....).map(Boolean);//sample return Boolean here}
Mono<Boolean> conditionB(String a) {return webClient.call(....).map(Boolean);//sample retu
浏览 5提问于2021-11-11得票数 0
回答已采纳
当使用WebClient的exchangeToMono()时，主体检索部分总是返回一个空的Mono：public Mono<Pojo> getCalled(@RequestBody Pojo pojo) {
System.out.println(pojo); //
浏览 37提问于2021-12-21得票数 0
回答已采纳
如果响应状态为200，则使用不同的WebClient再次调用另一个端点。在第二次webclient调用之后，返回一个字符串。
否则，我只需从方法中返回一个字符串，例如“未能创建顺序”。我想要做的是捕获异常并优雅地处理它，并返回一个字符串，如“错误调用第一个端点等等”。orderWebClient()只是一个方法，它返回包含baseUrl和标头等预构建的WebClient。(BlockingSingleSubscr
浏览 5提问于2020-08-29得票数 3
1回答
我不明白这个问题，我不知道我做错了什么我已经附加了代码片段，doOnNext将填充categoryIdToPrintRepository我已经了解了如何在通量结束后返回mono，并在处理onNextSite之前找到了“那时”，但仍在执行“then”方法，这会导致错误：
java.lang.IllegalArgumentExceptionpublic Mono<S
浏览 5提问于2020-06-26得票数 1
回答已采纳
1回答
工程反应器条件流的最佳实践
、、、、
我正在与、spring、webflux、和项目反应堆合作，构建一个包含2层的API：控制器、和服务。我的API发送和返回的所有3端点都是用Mono包装的。在服务层，有两个类:第一个类用Mono响应调用多个for客户端，第二个类是对这些调用的类集成。我一直在努力构建Mono调用的“管道”，因为业务流程要求我需要调用webclient 1，进行一些验证，使用它的响应并调用web
浏览 4提问于2021-01-27得票数 1
我有一个自定义过滤器的Spring Cloud Gateway。在这个过滤器中，我尝试用一个参数调用我的webclient。ReactiveSecurityContextHolder中的角色。如果我只返回"getAccessToken(webClient，"fixString“).flatMap(chain::filter)”，而不返回实际的角色，则返回一个accessToken。: WebClient</
浏览 12提问于2020-11-02得票数 0
我有一个简单的Java程序，可以用Spring WebClient发送多个请求。每个函数都返回一个单声道，我使用response.subscribe()来检查结果。但是，我的主线程在处理所有请求之前就结束了，除非我添加了一个很长的Thread.sleep()。对于期货，您可以使用:CompletableFuture.allOf( CompletableFutures ).join()；
有没有办法等待所有的Mono都完成？
浏览 1提问于2018-06-07得票数 13
回答已采纳
我是春季WebFlux的新手，所以请温柔一点.我很抱歉，如果我错过了一些明显的东西，但我试着寻找网上的例子，每次我结束了顺序电话。我有这样的情况：Mono<，当它们完成时，保存对resp1、resp2、resp3的响应，如果r
浏览 2提问于2020-03-25得票数 1
回答已采纳
我正在尝试使用Kotlin Coroutines + WebFlux.fn + WebClient -addons为反应器添加一个条件重试： suspend fun ClientResponse.asResponsedoOnRetry { log.error("Retry for {}", it.exception()) } .awaitSingle() 同时在重试之前添加一个条件if (statusCode().isError) {
浏览 20提问于2020-03-24得票数 1
我的任务是重构方法(代码片段1)，在重复/重试逻辑中不需要使用for循环和睡眠线程的组合。要调用外部api，可以使用WebClient。它是在一个分离的方法中创建、配置和注册为Spring的，我相信它运行得很好。让我们假设它是自动配置的，可以使用。getSomething() { JsonNode response = <
浏览 5提问于2022-09-01得票数 0
1回答
我有两个类，分别是Utility.java和ServiceImpl.java。我使用WebClient的地方是ServiceImpl.java。我打的一个帖子看起来像这样- .uri(path)
.body(Mono.just问题是-当我在我的实用程序类中执行'response my ResponseDTO.<
浏览 2提问于2020-09-11得票数 1
2回答
我想在一定条件下结合两个Mono的结果。这两个Mono都是WebClient调用的结果：
第二个是几个呼叫的组合和一个缓慢的响应。“取消”第二个Mono的想法，如果由第一个结果满足一定的条件，以节省时间和避免不必要的网络调用。如果第一个Mono的结果不够zip，则使用第
浏览 0提问于2019-05-15得票数 6
回答已采纳
: Mono<Unit> = Mono.empty() }
浏览 1提问于2020-06-18得票数 1
2回答
被测试的类：import java.time.Instant;import org.slf4j.Logger{
private WebClient webClient;
public Mono<ServiceResponse> fetchOffersByItemIdAndStoreI
浏览 13提问于2021-02-23得票数 2
回答已采纳
我正在编写一个简单的get方法来从API URL检索评论。API将json数据作为字符串返回。返回Mono<Object>会抛出错误。请在下面找到HTTP响应。Internal Server Error",
"message": "Content type 'text/plain;charset=utf-8' not supported for bodyType=java.lang.Object所以返回</e
浏览 77提问于2019-02-05得票数 6
回答已采纳
1回答
我想发送并行的网页请求，并收集结果也并行。然后，我的方法应该返回聚合结果。 List<Mono> monos = bodys.stream(body -> sendcollectList(); //pseudeocode
pr
浏览 1提问于2019-08-14得票数 2
回答已采纳
我有一个控制器，它要求服务到达服务端点以获取帐号列表，然后针对每个帐户号向另一个服务伸出手，并检索有关该帐户的其他数据。“幸福之路”本质上是这样的：@ApiOperation(value = "getRelatedAccounts")
@GetMapping(value = "/relatedaccounts"Comparator.comparing(RelatedAccounts::getCorrectOrder)) // blah blah, convert from Par
浏览 3提问于2021-08-13得票数 1
回答已采纳
1回答
我有一个由两部分组成的简单程序:一个带有返回Mono的端点的Spring5服务器，以及一个读取值并打印它的客户机程序。我遗漏了什么？文件Main.java@EnableWebFlux public static void main(S
浏览 0提问于2017-11-21得票数 2
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
