webclient返回Mono的Java循环结束条件
在Java中，webclient返回Mono是指使用Spring WebFlux框架中的WebClient类发送HTTP请求并获取响应。Mono是一种Reactive类型，表示0或1个元素的异步序列。
循环结束条件是根据具体需求而定的，以下是一些常见的循环结束条件示例：
- 根据响应状态码判断：可以通过判断HTTP响应的状态码来确定循环是否结束。例如，当状态码为200时表示成功，可以结束循环。
- 根据响应内容判断：可以根据返回的响应内容来判断循环是否结束。例如，当返回的内容满足某个条件时，可以结束循环。
- 根据循环次数判断：可以设置一个计数器，在每次循环迭代时递增，当达到一定次数时结束循环。
- 根据时间限制判断：可以设置一个时间限制，在循环开始时记录当前时间，当超过指定时间时结束循环。
需要注意的是，循环结束条件应该合理并满足业务需求，避免出现死循环或过早结束循环的情况。
推荐的腾讯云相关产品和产品介绍链接地址如下：
- 腾讯云云服务器（CVM）：提供弹性计算能力，支持多种操作系统和应用场景。详情请参考：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库MySQL版（TencentDB for MySQL）：提供高性能、可扩展的MySQL数据库服务。详情请参考：https://cloud.tencent.com/product/cdb_mysql
- 腾讯云对象存储（COS）：提供安全、稳定、低成本的云端存储服务，适用于各种数据存储和传输场景。详情请参考：https://cloud.tencent.com/product/cos
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估。
相关·内容
我有一个自定义过滤器的Spring Cloud Gateway。在这个过滤器中，我尝试用一个参数调用我的webclient。ReactiveSecurityContextHolder中的角色。getAccessToken结果为
com.xy.HeaderGatewayFilter$apply$1$1.apply(HeaderGatewayFilter.kt:37).
如果我只返回"getAccessToken(webClient，"fixString“).flatMap(chain::filter)”，而不返回实际的角色，则返回一个accessToken。
@Component
浏览 12提问于2020-11-02得票数 0
我尝试使用WebClient并行地发出请求，但我不知道如何去做，因为无论我做什么，代码都不会等待请求完成。如果我只执行一个请求(带注释的片段)，一切都会正常工作。有人能帮我一下吗？ @RequestMapping(method = [RequestMethod.POST], path = ["/upload/{batchId}"])
fun uploadFile(@RequestPart("file") file: Mono<FilePart>,
@PathVariable("batchId&#
浏览 64提问于2019-10-01得票数 0
回答已采纳
我试图使用Spring WebFlux WebClient (使用SpringBoot版本2.4.5 )获取值(String)。
@GetMapping("/test")
public Mono<String> getData(){
WebClient webClient = WebClient.create("http://localhost:9999");
Mono<String> stringMono = webClient.get()
.uri("/some/thing")
浏览 9提问于2021-05-11得票数 2
1回答
工程反应器条件流的最佳实践
、、、、
我正在与、spring、webflux、和项目反应堆合作，构建一个包含2层的API：控制器、和服务。我的API发送和返回的所有3端点都是用Mono包装的。在服务层，有两个类:第一个类用Mono响应调用多个for客户端，第二个类是对这些调用的类集成。我一直在努力构建Mono调用的“管道”，因为业务流程要求我需要调用webclient 1，进行一些验证，使用它的响应并调用webclient 2，如果通过其他的webclient 4，执行验证调用webclient 3等等。我尝试过使用平面图，但这对我来说不是很自然，我用Mono创建一个条件流，如下所示：
正如您在图中所看到的，对于我来说，实现反应
浏览 4提问于2021-01-27得票数 1
1回答
考虑代码示例：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
import java.time.Duration;
import static com.google.common.collect.Immutabl
浏览 1提问于2018-09-04得票数 2
下面是我实现的rest服务
@GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE, value = "/events")
Flux<Event> events() {
Flux<Event> eventFlux = Flux.fromStream(Stream.generate {new Event(System.currentTimeMillis(), LocalDate.now())})
Flux<Long> durationFlux = Flux.interva
浏览 491提问于2020-05-14得票数 1
我正在尝试将资源与spring webClient同步：
this.semaphore.acquire()
webClient
.post()
.uri("/a")
.bodyValue(payload)
.retrieve()
.bodyToMono(String.class)
// release
.doFinally(st -> this.semaphore.release())
.switchIfEmpty(Mono.just("a"))
.onErrorResume(
浏览 17提问于2022-02-11得票数 3
回答已采纳
2回答
被测试的类：
import java.time.Duration;
import java.time.Instant;
import java.util.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.
浏览 13提问于2021-02-23得票数 2
回答已采纳
我是Spring-Webflux的新手。
我在一个双核处理器上运行下面的示例项目。我的RESTful接口会调用外部接口，外部接口响应小于500ms。
当我使用jMeter进行负载测试时，不能达到超过15TPS。
我是不是在下面的设计中遗漏了什么或者什么错误？
在Webflux项目中覆盖默认的线程池执行器有多有效？
提前谢谢你。
Controller.java
LookupController
{
@自动连接
private LookupService lookupService；
@PostMapping(value = "/findOrder")
public Mono&
浏览 0提问于2019-05-17得票数 0
1回答
我对反应性编程有点陌生，我正在尝试组装以下内容:使用Java、Springboot 2、Webflux和反应堆核心，我想处理需要额外身份验证的非常具体的请求。因此，我用一系列步骤实现了一个WebFilter：
捕获请求的路径和方法。检查组合是否存在，并需要使用Boolean).Since方法进行特定的身份验证(返回具有配置了CSRF和Spring安全性的accessPointService.getAccessPointAuthorizationRequirement的Mono，我需要csrf令牌和Spring会话凭据。我用凭证为credentials.Then发出一个GET和POST请求，我只
浏览 6提问于2021-10-27得票数 0
回答已采纳
1回答
我尝试进行连续的API调用，并将结果合并到一个mono中。第一个API包含第二个API的Id列表。
@Service
@AllArgsConstructor
public class AggregateService {
private OperationClient operationClient;
private OuvrageClient ouvrageClient;
public Mono<OperationDetailDto> getDetails(String operati
浏览 6提问于2022-06-21得票数 0
回答已采纳
2回答
我向WebClient提出了这个请求 webClient
.get()
.uri(uri)
.accept(MediaType.APPLICATION_OCTET_STREAM)
.<Optional<ByteArrayResource>>exchangeToMono(response -> {
if (response.statusCode().equals(HttpStatus.NOT_FOUND)) {
return Mono.just(Optional.empty());
浏览 23提问于2021-10-19得票数 0
当使用WebClient的exchangeToMono()时，主体检索部分总是返回一个空的Mono：
例如，公开的服务返回一个非空的Mono。
@PostMapping("/test")
public Mono<Pojo> getCalled(@RequestBody Pojo pojo) {
System.out.println(pojo); // always prints a non-null object
return Mono.just(pojo);
}
WebClient与.retrieve()
WebClient.create().po
浏览 37提问于2021-12-21得票数 0
回答已采纳
下面是我尝试使用web客户端发送帖子的不同方式，但是每次连接池在某个时候都会耗尽。我得到了以下错误。
我使用的是spring boot 2.7.3版本
请帮助哪些连接没有被释放。
web客户端初始化代码
@PostConstruct
public void getWebClient() {
logger.debug("Initializing webClient..");
ConnectionProvider provider = ConnectionProvider.builder("fixed")
.metrics(
浏览 38提问于2022-09-22得票数 0
1回答
我使用的是Mono的filterWhen()，有多个条件，如下所示，但不知道如何实现正确的方式。
Mono.just("a").filterWhen(item -> conditionA && conditionB)...
// or Mono.just("a").filterWhen(item -> conditionA || conditionB)...
// both is reactive call
Mono<Boolean> conditionA(String a) {
return webClien
浏览 5提问于2021-11-11得票数 0
回答已采纳
我尝试了在下面这些线程上提供的所有解决方案：
还有大约10个类似的线程。
这里是我的Spring应用程序：
@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class })
public class MyApplication {
@Autowired
private WebClient webClient;
public static void main(String args[]) {
SpringApplication.run(MyApplication.cla
浏览 36提问于2021-12-13得票数 -1
回答已采纳
我正在尝试通过Monotouch上的web客户端发送XML。尽管一切都在iOS模拟器上运行，但当应用程序在设备上运行时，我会得到一个异常。下面是代码。
try
{
Byte[] sendData = System.Text.Encoding.UTF8.GetBytes(someXML) ;
WebClient client = new WebClient();
Byte[] forResp;
client.Headers.Add("Content-Type","text/xml");
bresp = wc.UploadData(U
浏览 0提问于2012-04-19得票数 1
回答已采纳
我正在尝试使用WebClient实现以下场景。使用RestTemplate很简单，但我不能再这样做了。
伪java代码中Spring控制器的相关部分：
Mono<T1> t1 = webClient.get()...retrieve()...;
Mono<T2> t2;
if (t1.getResult().getValue() > 0) {
t2 = webClient.get().buildUsing(t1.getResult().getValue())...retrieve()...);
} else {
t2 = Mono.empty()
浏览 20提问于2019-10-23得票数 1
1回答
我正在编写一个小型WebFlux客户端代理，它将接受POST请求，提取JSON内容，并通过另一个POST将其传递给第三方web服务器的进一步调用。我想在我最初的POST请求中获得json主体。
curl --header "Content-Type: application/json" \
--request POST \
--data '{"username":"xyz", "preference":"123"}' \
http://localhost:3000/mih/search
浏览 1提问于2020-06-26得票数 0
我使用RouterFunction在Spring应用程序中定义端点。我的服务返回一个Mono<Object>，当端点被调用时，我想返回这个结果。我还需要进行身份验证，以便传递一个UserPrinciple对象。
路由器
@Bean
RouterFunction<ServerResponse> router() {
return route()
.GET("/api/endpoint-name", this::getExample)
.build();
}
private Mono<Serve
浏览 28提问于2022-04-29得票数 1
回答已采纳
关于Spring中的返回类型的问题。
在许多示例中，比如在线教程，Spring项目的rest控制器将返回一个Mono<MyPojo>
public Mono<MyPojo> monoPojo(String parameter) {
return WebClient.create("http://...").get().retrieve().bodyToMono(MyPojo.class)
.map(oneMyPojo -> unregisterRepository.insert(oneMyPo
浏览 1提问于2021-09-06得票数 5
回答已采纳
1回答
我已经开始使用WebClient(org.springframework.web.reactive.function.client.WebClient)来调用rest服务。我有两个类，分别是Utility.java和ServiceImpl.java。我使用WebClient的地方是ServiceImpl.java。我打的一个帖子看起来像这样-
ClientResponse response = webClient.post()
.uri(path)
.body(Mono.just(inputDTO),InputDTO.class)
浏览 2提问于2020-09-11得票数 1
当我试图通过HTTPS发布一些数据时，我会间歇性地得到这个异常。在mono 2.10.1上运行(现在更改为2.10.9)。我不知道为什么会发生这种情况，它似乎与请求大小(大约2.5MB)无关，因为其他类似大小的请求正在工作。
// these arguments are not null, as I can see them in a log.
var response1 = web1.UploadData(address, "POST", buffer);
堆栈跟踪mono 2.10.1：
System.Net.WebException: An error occurred
浏览 0提问于2013-04-29得票数 2
我用WebClient开发了外部接口，但我不知道如何检查响应体。
public class Call {
public Mono<Object> get() {
Mono<Object> http = webClient.get()
.uri(EXTERNAL_URL)
.retrieve()
.bodyToMono(Object.class);
return http;
}
}
和测试代码
public class Test {
@Test
void test() {
Call call
浏览 13提问于2021-05-12得票数 0
1回答
我有三个WebClients看起来像这样：
WebClient
public Mono<MyObject> getResponseOne() {
return webClient.get()
.uri(URI)
.header("header", header)
.bodyValue(body)
.retrieve()
.bodyToMono(MyObject.class);
}
然后我有一个控制器，它调用多个WebClients：
控制器
@ResponseBody
@Po
浏览 2提问于2022-03-15得票数 0
回答已采纳
我正在使用Sping webflux模块并创建一个WebClient、请求uri和请求主体如下：
// create webclient
WebClient wc3 = WebClient.builder()
.baseUrl("http://localhost:8080")
.defaultCookie("key", "val")
.defaultHeader(HttpHeade
浏览 0提问于2017-12-26得票数 2
回答已采纳
我是春季WebFlux的新手，所以请温柔一点.我很抱歉，如果我错过了一些明显的东西，但我试着寻找网上的例子，每次我结束了顺序电话。
我有这样的情况：
Mono<Response> mono1 = webclient1.post()...usual_stuffs....bodyToMono(Response.class);
Mono<Response> mono2 = webclient2.post()...usual_stuffs....bodyToMono(Response.class);
Mono<Response> mono3 = webclient3
浏览 2提问于2020-03-25得票数 1
回答已采纳
我想要进行异步两个webclient调用。然后等待两个响应，使用一些业务逻辑并返回一些值。下面的代码是我编写的代码的简单版本。但是，我不确定它是否是好代码。
@RequestMapping(value = ["/{userId}"], method = [RequestMethod.GET])
fun getRoomList(@PathVariable("userId") userId: String): RoomDto.FullInfo {
val countDownLatch = CountDownLatch(2)
val room
浏览 6提问于2021-04-25得票数 0
回答已采纳
因此，应用程序流就像：
WebClientValidate Spring应用程序接收请求-> {"id"：“UUID”}使用该->调用外部web服务--步骤2中从WebClient接收的响应。如果验证通过，则返回true或false。执行其他验证操作(通过调用其他进程或ext服务)并将响应发送给用户.。
这是我正在使用的webclient (副本)：
public Mono<Details> someRestCall(String name) {
return this.webClient.get().url("/{id}/det
浏览 0提问于2020-09-07得票数 0
回答已采纳
我的处境
我正在尝试创建一个功能，它将对给定的端点执行n个请求(其中n个>=0)，但我确实了解到，有时该端点可能由于500个错误或其他问题而没有响应，所以我希望将请求重复到一个端点(在此之间有一个很小的间隔尚未实现)，直到得到响应为止，或者直到我得到一个未知的错误，该错误指示由于崩溃的服务器以外的其他原因，我无法重复什么。
因此，我尝试使用Java 11提供的执行程序和并发性来实现这部分功能，但它并不像我所希望的那样工作。
我不能重新提交失败的任务，直到我得到所有的回应，我不知道为什么
我有个方法
private void DoMyTasks(List<MyRequest>
浏览 3提问于2022-06-30得票数 0
回答已采纳
我在Kotlin (使用WebFlux)中有以下代码，我想测试它：
fun checkUser(user: People.User?): Mono<Unit> =
if (user==null) {
Mono.empty()
} else {
webClient.get().uri {
uriBuilder -> uriBuilder
//... building a URI
浏览 1提问于2020-06-18得票数 1
我有两个对象 CarParts {
String id
WorkItem workItem
}
WorkItemResponse {
List<WorkItem> resource; <- always contains one item.
} 我想在汽车部件上做一个set客户端，它会为列表中的每一项返回一个Mono<List<CarParts>>，我想在第二次调用时使用id，然后用第二次调用的结果设置Carparts的每个WorkItem对象 我还想做一个 Mono<List<Carparts>>
浏览 12提问于2020-06-14得票数 1
回答已采纳
我是春季WebClient的新手。下面的方法使用WebClient调用端点，并且需要从该方法返回ResponseEntity。我知道我可以打电话给block()，但是我可以用非阻塞的方式来做吗？即使我可以返回Mono，调用方法仍然需要打开它并获取ResponseEntity，调用方法如何调用block
public ResponseEntity getData() {
Mono<ResponseEntity<String>> entityMono = webClient.post()
浏览 2提问于2022-01-26得票数 1
回答已采纳
可以在spring webflux webclient中使用Ribbon和Eureka服务发现吗？
我尝试了这段代码，但在集成测试过程中遇到错误。
reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.IllegalArgumentException: URI不是绝对的: /auth-service/auth-service/validate-manager-client-access
@Bean
@LoadBalanced
public WebClient loadBalancedWebClient() {
浏览 0提问于2019-01-04得票数 8
我试图在Spring中使用API POST 和WebClient。但我不能以JSONObject的身份发出请求并接收响应。通过RestTemplate，我做到了，最近我开始学习WebClient。所以我被困住了。
Error Spring给出：错误：(48，28) java:不兼容类型:不存在类型变量T的实例，这样reactor.core.publisher.Mono就符合org.json.simple.JSONObject
这是我的源代码：
Controller.java
JSONObject jsonObject = new JSONObject();
Tu
浏览 3提问于2020-07-06得票数 2
回答已采纳
我正在使用Spring webflux开发reactive streams应用程序。我有一个用例，我做了一个webclient请求来获取一些数据，一旦我获得了响应数据，我就验证它，如果验证失败，我想抛出一个异常，这个异常应该由main reactive管道来处理。我在平面地图中使用webclient调用，以便在管道的下一个运算符中使用该值。我的代码类似于下面的代码。 public class Example {
pubic String getData(String name) {
return Mono.just(name)
.map(name ->
浏览 149提问于2021-09-20得票数 0
2回答
嗨，我有Flux，在每个元素的迭代过程中，它创建了新的mono。在流动之外，我还有其他的单极。并想要做以下工作:当通量(与相应的内部单体的末端)，然后做第二单。challegeing是mono内部从webclient请求中创建的流量。作为起点，请看“加载”方法。基本没有webclient，它可以工作，但如果与webclient在地图工作之后的工作。使用弹簧引导2
public WebClient.ResponseSpec sendGetRequest(String path, Object... pathVariables){
try {
LOGGER.info(&
浏览 0提问于2019-05-03得票数 0
回答已采纳
1回答
异常总是包装在500中
、、、、
对于一个非常简单的项目，错误处理是不清楚的。
public class WebfluxApplication {
public static void main(String[] args) {
SpringApplication.run(WebfluxApplication.class, args);
}
}
public class EndpointRouter
{
@Bean
public WebClient webClient() {
return WebClient.builder().build();
}
@Bean
public R
浏览 1提问于2020-08-29得票数 2
回答已采纳
1回答
如果url1返回许多结果，则下面的代码将导致空列表，但url2返回一个404。如何正确地忽略错误，并继续url1的成功响应？
Set<String> list = new HashSet<>();
Mono<String> first = WebClient.create(url1)
.get()
.retrieve()
.bodyToMono(String.class)
.onErrorResume(e -> {
浏览 21提问于2022-02-05得票数 0
我希望缓存一个WebClient调用的结果的Mono (只有在它成功的情况下)。
通过阅读项目reactor addons文档，我觉得并不适合，因为它也缓存了错误，这是我不想要的。
因此，我不使用CacheMono，而是执行以下操作：
Cache<MyRequestObject, Mono<MyResponseObject>> myCaffeineCache =
Caffeine.newBuilder()
.maximumSize(100)
.expireAfterWrite(Duration.ofSeconds
浏览 3提问于2018-10-13得票数 10
回答已采纳
我有一个类似REST的服务，我使用WebFlux WebClient向其发布请求。该服务以常见的JSON格式返回响应，如下所示： {
"status": "OK",
"data": []
} 现在，对于每个端点的每个WebClient调用，我要执行公共验证，以检查状态==是否为"OK“。我是否需要为每个端点单独调用验证，例如 myClient.post().uri("/myEndpoint1")
//..
.retrieve()
.bodyToMono(MyResponse.cla
浏览 11提问于2019-08-29得票数 0
要求是使用OAuth从java客户端程序调用受WebClient保护的端点。我使用密码授予授权类型使用反应性对象。请注意，我对反应式编程模式非常熟悉。当我调用webclient时，我得到以下错误** serverWebExchange不能为空**
请让我知道以下的配置和使用是否正确和/或如何初始化serverWebExchange对象。
String data = webClient
.post().uri(endPoint)
// This will add the Authorization header wi
浏览 23提问于2020-06-24得票数 0
我正在尝试使用Kotlin Coroutines + WebFlux.fn + WebClient -addons为反应器添加一个条件重试： suspend fun ClientResponse.asResponse(): ServerResponse =
status(statusCode())
.headers { headerConsumer -> headerConsumer.addAll(headers().asHttpHeaders()) }
.body(bodyToMono(DataBuffer::class.java), Data
浏览 20提问于2020-03-24得票数 1
我有类似Vert.x这样的异步库的经验，但特别是对反应堆/WebFlux来说是新手。我想在web应用程序上公开一个端点，当被击中时，这个端点掉头并调用另一个web服务，将响应解析为一个Java对象，然后访问对象中的字段并对它们做一些事情。我使用WebClient进行HTTP调用，使用Jackson ObjectMapper反序列化它。我的代码看起来大致如下(注意：RequestUtil.safeDeserialize只是使用杰克逊将字符串体解析成一个对象并返回Optional<Object>，这就是为什么之后我有一个额外的map步骤)：
public Mono<Str
浏览 4提问于2021-02-12得票数 2
回答已采纳
我正在尝试向另一个接受内容类型"application/json- patch +json“的API发出补丁rest请求。我正在使用Spring的webclient，但是我还没能让它工作。我一直收到"415不支持的媒体类型“ 我已经尝试了下面的方法； WebClient webClient = WebClient.create(baseUrl);
Mono<ClientResponse> response = webClient.patch()
.uri(updateVmfExecutionApi, uuid)
.header("Content-T
浏览 85提问于2020-09-18得票数 1
回答已采纳
我有一个用户名列表，希望在不阻塞主线程的情况下从远程服务获取用户详细信息。我使用的是Spring的反应式客户端WebClient。对于响应，我获取Mono，然后订阅它并打印结果。 private Mono<User> getUser(String username) {
return webClient
.get()
.uri(uri + "/users/" + username)
.retrieve()
.bodyToMono(User.class)
浏览 87提问于2019-12-04得票数 3
回答已采纳
1回答
我有下面的HandlerFunction，它接受"BookingRecord“的帖子请求。我使用ServerRequest ()从bodyToMono获得一个Mono，然后订阅Mono，因为我需要返回BookingRecord类型，使用WebClient调用REST服务以获得Mono"“。我已经将fare声明为实例变量，以便可以在return语句中使用它。
public class BookingHandler
{
private Mono<Fare> fare;
private WebClient webCli
浏览 1提问于2018-10-15得票数 0
回答已采纳
我使用spring使用包含{comment_count}的url发出Facebook图形api请求。
但是，得到这个例外
java.lang.IllegalArgumentException: Not enough variable values available to expand reactive spring
代码片段：
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.co
浏览 8提问于2019-10-01得票数 3
回答已采纳
我有一个使用的springboot项目。我们已经从1.5.3转移到了springboot 2.0.1，我们正在尝试使用WebClient进行其他异步调用。我们使用Resttemplate来处理接收到的字符串，如下所示。但是WebClient只返回Mono或Flux中的数据。如何才能将数据作为字符串。已经尝试了block()方法，但是它执行异步调用。
@Retryable(maxAttempts = 4, value = java.net.ConnectException.class,
backoff = @Backoff(delay = 3000, multiplier
浏览 0提问于2019-08-05得票数 11
回答已采纳
我正在尝试重构这段代码：
fun getCharacterFilms(serverRequest: ServerRequest): Mono<ServerResponse> {
val films = starWarsApiWebClient.findCharacter(serverRequest.pathVariable("id").toInt())
.flatMapMany { it.films.toFlux() }
.flatMap(starWarsApiWebClient::findFilm)
浏览 0提问于2019-11-18得票数 0
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
腾讯云开发者
