我希望我能从下面的代码中清楚地了解我想要实现的目标： .flatMap(u -> commentRepository.findByUser(u.getId))
.flatMap( // here i get of course the comment object but i also need the previous user object )
浏览 14提问于2021-05-20得票数 1
1回答
最近我正在学习Spring WebFlux。当我尝试关闭连接池中的连接时，它不起作用！代码如下： return connectionPool.create().flatMap(connection -> { connection.close(); })
.flatMap
浏览 66提问于2021-07-24得票数 1
回答已采纳
我有一个简单的用例，不知道该怎么做，因为我是spring webflux的新手。
我使用的是spring boot webflux starters。我需要呼叫2个端点。在执行任何操作之前，需要使用来自Endpoint2的响应来丰富Endpoint1的请求对象。如何使用Spring webflux强制执行此命令?在我的示例中，原始请求对象在可以进一步使用之前没有被丰富。这方面的任何帮助都是非常感谢的！Mono<
浏览 4提问于2019-04-05得票数 1
我是Spring的新手，正在尝试将我的spring webflux应用程序转换为WebFlux。我从我的服务中返回一个单声道：当我这样做的时候： return mono.flatmap( (response) -> {
dataexchange.put(&qu
浏览 2提问于2019-02-12得票数 6
回答已采纳
java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)springorg.springframework.http.server.reactive.ServletServerHttpResponse并调用response.getOutputStream()时，哪一项是正确的，现在如何支持请求转发问题还记录到spring jira以供讨论-
浏览 4提问于2019-01-04得票数 0
是否可以使用仅添加了spring-boot-starter-webflux的现有spring-boot-starter-web编码方案？？没有spring-boot-starter-web的话。
浏览 71提问于2019-01-07得票数 1
5回答
pom.xml中的Jackson依赖项： <groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactIdorg.springframework.web.reactive.function.BodyExtractors.readWithMessageReaders(BodyExtractors.java:197) ~spring-webflux.在org.springframework.
浏览 0提问于2019-07-15得票数 13
回答已采纳
1回答
我创建了一个Spring webflux want客户端，我想根据我的响应重复相同的操作。对于ex:如果数据仍然是空的，我想重试获取数据。如何做到这一点？page=" + page) .flatMap(o -> {
o.subscribe
浏览 11提问于2019-09-22得票数 1
回答已采纳
我使用Spring和Security，我需要根据当前注册的用户保存数据。为了做到这一点，在我的控制器中，我需要检索从前端和主体发送的数据。@RequestBody Mono<OrderViewModel> orderViewModel, Mono<Principal> principal) { orderViewModel.flatMap(order -> this.orderSe
浏览 0提问于2021-07-29得票数 0
假设我有两个微服务，并且我想在一个使用WebFlux的Spring REST控制器中实现BFF (前端后端)模式。来自两个远程服务的域对象是： private Long id; private Longprivate Long id; private String lastName;并且API编写器必须返
浏览 22提问于2018-08-22得票数 0
我试图从一个测试H2数据库中获取数据，但是我得到了一个错误，它是空的。--如果你不使用液基，而只是把脚本放在src/test/resources中，那么一切都很好！为什么？申请-test.yaml` h2: enabled: true url: r2dbc:h2:mem:///testdb17:53:29.259 INFO 13320 --- \[ main\
浏览 20提问于2022-11-01得票数 0
无论我如何设置我的项目，我在启动时都会得到以下异常： “检测到不支持的挂起处理程序方法”。我正在尝试使用https://docs.spring.io/spring/docs/5.2.0.BUILD-SNAPSHOT/spring-framework-reference/languages.html#coroutines中描述的对协程的支持。我如何摆脱这个异常？org.jetbrains.kotlinx:kotlinx-
浏览 38提问于2020-04-05得票数 2
1回答
我正在尝试以响应式的方式查询Redis，使用Spring Webflux获取smembers，然后使用该结果查询hmget。sMembers查询的结果是Flux>，hMGet期望第二个参数作为集合。我不确定如何以正确的方式编写此函数。有没有人能帮我纠正一下。-> {
return reactiveClusterSetCommands.sMembers(ByteBuffer.wrap(key.getBytes())).flatMap
浏览 16提问于2019-06-07得票数 1
回答已采纳
我一直在使用Spring Boot 2.0.1及其Webflux库开发一个响应式web api示例。我一直在看网上的例子，试图构建它，但我被两件事难住了。下面是我的两个问题。1)我如何返回一个响应实体的Flux，当我尝试时，我得到一个错误，说只能返回一个响应实体。下面是我当前的代码。value = "/movies") }2)当我更
浏览 5提问于2018-04-29得票数 6
回答已采纳
1回答
我有一个Spring (而不是WebFlux)应用程序，它使用来自WebFlux项目的WebClient类。.supplyAsync(() => repo.findById(...), executor) }但是，对于WebClient，我不再确定如何根据public void saveFooBlocking(Foo foo) { /* uses JPA */ }
fetchFooUsingW
浏览 1提问于2020-06-03得票数 1
1回答
我正在尝试使用spring boot - webflux (功能端点)& jdbc构建一个简单的web应用程序。应用程序接收XML格式的有效负载(这是一个员工的一些详细信息)。final String someID = UUID.randomUUID().toString();
final Mono<Integer> asyncUpdate = inputMono.flatMap的世界中，我只需迭代employee对象的列表，并为每个对象调用此函数。
浏览 45提问于2020-04-22得票数 0
回答已采纳
我想知道如何用Webflux编写非阻塞代码。以下是我想做的事：
按ProductProperties字段获取所有产品(作为ProductProperties返回)、、从Flux<Product>.availabilityCalendar获取值列表、使用步骤2中检索的数据并获取其他数据(返回为Flux<>) --一切都应该是非阻塞操作。如何从Flux<Object>中获取</
浏览 4提问于2019-11-08得票数 0
1回答
我正在使用Spring5WebFlux和ReactiveMongoRepositories。假设我有两个集合"Race“和"RaceParticipation"： Race : { "name" : "Name"
RaceParticipationI应该从响应中收集ids并调用raceRepository.findAllBy
浏览 25提问于2019-03-11得票数 1
回答已采纳
从调用Spring webflux的web客户端开始，我在尝试处理不同的错误时遇到了麻烦。 .bodyToMono(InputMessage::class.java)如果出错，它仍然会从客户端的调用中返回完整的错误消息。我试过别的，像这样
retur
浏览 14提问于2019-07-26得票数 2
云服务器
ICP备案
对象存储
云直播
腾讯会议
腾讯云开发者
