Spring boot webflux如何同时保存、更新和删除多个Monos
Spring Boot WebFlux是一个基于响应式编程模型的轻量级框架，它可以用于构建高性能、可伸缩的Web应用程序。在使用Spring Boot WebFlux保存、更新和删除多个Monos时，可以采用以下方法：
- 保存多个Monos：
- 首先，创建一个包含多个Mono对象的列表，每个Mono对象代表一个要保存的实体。
- 使用Flux.fromIterable()方法将列表转换为Flux流。
- 使用flatMap()方法将每个Mono对象映射为保存操作，并返回一个Mono<Void>对象。
- 使用collectList()方法将所有保存操作的结果收集到一个Mono<List<Void>>对象中。
- 调用block()方法等待保存操作完成。
- 更新多个Monos：
- 首先，创建一个包含多个Mono对象的列表，每个Mono对象代表一个要更新的实体。
- 使用Flux.fromIterable()方法将列表转换为Flux流。
- 使用flatMap()方法将每个Mono对象映射为更新操作，并返回一个Mono<Void>对象。
- 使用collectList()方法将所有更新操作的结果收集到一个Mono<List<Void>>对象中。
- 调用block()方法等待更新操作完成。
- 删除多个Monos：
- 首先，创建一个包含多个Mono对象的列表，每个Mono对象代表一个要删除的实体。
- 使用Flux.fromIterable()方法将列表转换为Flux流。
- 使用flatMap()方法将每个Mono对象映射为删除操作，并返回一个Mono<Void>对象。
- 使用collectList()方法将所有删除操作的结果收集到一个Mono<List<Void>>对象中。
- 调用block()方法等待删除操作完成。
需要注意的是，以上操作都是异步的，可以在Spring Boot WebFlux的响应式流中进行处理。此外，Spring Boot提供了丰富的相关技术和组件，如Spring Data、Spring Security等，可以进一步增强应用程序的功能和安全性。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云云原生应用引擎（Tencent Cloud Cloud Native Application Engine）：提供全托管的云原生应用引擎，支持Spring Boot等框架，帮助开发者快速构建和部署应用程序。详细信息请参考：https://cloud.tencent.com/product/tcae
- 腾讯云数据库（TencentDB）：提供多种数据库产品，如云数据库MySQL、云数据库MongoDB等，可用于存储和管理应用程序的数据。详细信息请参考：https://cloud.tencent.com/product/cdb
- 腾讯云容器服务（Tencent Cloud Container Service）：提供容器化应用程序的托管服务，支持使用Docker容器部署和管理应用程序。详细信息请参考：https://cloud.tencent.com/product/ccs
相关·内容
1回答
如何使用从并行web请求中收集结果？
java、spring、spring-webflux、spring-webclient
我想发送并行的网页请求，并收集结果也并行。然后，我的方法应该返回聚合结果。
使用spring-webflux和WebClient听起来很简单。但是，我如何才能真正地汇总结果呢？
public List<Response> aggregate(List<Object> bodys) {
List<Mono> monos = bodys.stream(body -> send(body)).collect(Collectors.toList());
//TODO how can I get all results in parallel
浏览 1提问于2019-08-14得票数 2
回答已采纳
1回答
网络流量错误-不存在变量类型R的实例，因此Flux<UUID>符合Mono<>
java、spring-boot、spring-webflux
我使用Spring和Webflux。
在我的代码中，我尝试返回一个Flux，但是我从intellij获得了以下错误，代码被标记为红色：
no instance(s) of type variable(s) R exists so that Flux<UUID> conforms to Mono<>
我的代码：
public Flux<UUID> deleteCCProtections(Mono<ProtectionSetRequest> protectionSetRequest) {
return protectionSetReq
浏览 0提问于2020-07-14得票数 0
回答已采纳
3回答
保持操作顺序的同步spring webflux调用
spring-boot、spring-webflux、project-reactor、reactor
我有一个简单的用例，不知道该怎么做，因为我是spring webflux的新手。
我使用的是spring boot webflux starters。我需要呼叫2个端点。假设是Endpoint1和Endpoint2。
每当Endpoint1被请求击中时，我应该首先用相同的请求击中Endpoint2，并使用来自Endpoint2的响应来丰富原始请求，然后再做进一步的事情。在执行任何操作之前，需要使用来自Endpoint2的响应来丰富Endpoint1的请求对象。如何使用Spring webflux强制执行此命令?在我的示例中，原始请求对象在可以进一步使用之前没有被丰富。这方面的任何帮助都是非常感
浏览 4提问于2019-04-05得票数 1
1回答
Reactive和hMGet通量
reactive-programming、spring-webflux、spring-data-redis
我是个响应式编程新手。我正在尝试以响应式的方式查询Redis，使用Spring Webflux获取smembers，然后使用该结果查询hmget。sMembers查询的结果是Flux>，hMGet期望第二个参数作为集合。我不确定如何以正确的方式编写此函数。有没有人能帮我纠正一下。 return Flux.just(keys)
.map(key -> {
return reactiveClusterSetCommands.sMembers(ByteBuffer.wrap(key.getBytes())).flatM
浏览 16提问于2019-06-07得票数 1
回答已采纳
1回答
等待运行反应堆Mono实例完成
project-reactor、spring-webflux
我编写这段代码是为了派生出大量的WebClients (受reactor.ipc.netty.workerCount限制)，立即启动Mono，然后等待所有Monos完成：
List<Mono<List<MetricDataModel>>> monos = new ArrayList<>(metricConfigs.size());
for (MetricConfig metricConfig : metricConfigs) {
try {
monos.add(extractMetrics.qu
浏览 1提问于2018-03-21得票数 0
1回答
Spring WebFlux如何获取Flux执行结果？
spring-webflux、spring-webclient
我想在Spring中使用WebClient来调用一些WebFlux，然后将所有的monos放到flux中。当我调用Flux.blockLast时，我无法获得结果。 @Test
public void reactiveGetTest() {
long start = System.currentTimeMillis();
List<String> results = new ArrayList<>();
List<Mono<String>> monos = IntStream.ran
浏览 128提问于2019-04-04得票数 0
回答已采纳
2回答
Webflux/Reactor进行两次API调用，而不是一次
spring-webflux、project-reactor
我有一个webflux应用程序。在一个地方，我进行了3次API调用。每次调用都依赖于上一次调用的结果。 Mono<List<Book>> books = bookService.find(params); //1st API call
Mono<List<User>> users = books.flatMapMany(Flux::fromIterable)
.map(User::getId)
.collectList()
.map(allUserIds -> userService.findUsers(allUs
浏览 88提问于2021-07-26得票数 0
2回答
反应性GraphQL
graphql、graphql-java
尝试实现反应性graphql并遇到一些问题。
pom依赖关系，
<dependency>
<groupId>com.graphql-java-kickstart</groupId>
<artifactId>graphql-kickstart-spring-boot-starter-webflux</artifactId>
<version>7.0.1</version>
</dependency>
浏览 2提问于2020-05-31得票数 2
1回答
如何将Flux<Entity>转换为List<Mono<Entity>>
reactive-programming、spring-webflux、project-reactor
实际上，我有一个清单，我需要为每一个请求。
我需要等待为给定列表完成的所有请求。
如果我创建了一个Flux.fromIterable(entities)，然后创建了一个.flatMap(this::makeRequest)，那么剩下的是一个Flux<Mono<ReturnType>>
我已经做过的一件事是Mono.when(entities.stream().map(this::makeRequest).collect(Collectors.toList()).block()
但我不确定这是否是最好的方法，或者我是否可以使用Mono.zip或Flux.fromItera
浏览 2提问于2022-08-17得票数 0
回答已采纳
1回答
使用函数接口创建的Spring云流应用程序没有在Spring云数据流中进行数据通信
spring-boot、spring-cloud-stream、spring-cloud-dataflow、spring-cloud-function
我已经使用Spring云函数方法transferring创建了3个简单的Spring云流应用程序(Source/Processor/Sink)。
来源-app：
@SpringBootApplication
public class SourceApplication {
public static void main(String[] args) {
SpringApplication.run(SourceApplication.class, args);
}
@PollableBean
public Supplier<Flux<
浏览 2提问于2020-06-05得票数 0
1回答
等待从下游APIs返回所有Mono响应的正确方法是什么？
java、reactive-programming、spring-webflux、project-reactor
我对Mono和Flux很陌生。我正在尝试加入几个下游API响应。这是一个传统的阻塞应用程序。我不想收集Mono的列表，我需要从下游API返回的有效负载列表，这是我从Mono获取的。但是，有时返回给控制器的“结果”只有部分或没有下游API响应。正确的方法是什么？我读过几篇的文章
您不应该在web应用程序中的任何地方调用订阅。如果这是绑定到HTTP请求，则基本上是在触发反应性管道，而不保证资源或完成。调用订阅会触发管道，但不会等到管道完成后再调用
我应该使用CompletableFuture吗？
在我的服务中，我试图
var result = new ArrayList<List&l
浏览 36提问于2022-06-04得票数 2
回答已采纳
1回答
如何过滤空通量
project-reactor、reactive、reactor
例如，我有下面的代码，它创建一个包含3个数字1,2,3的列表的Mono。我想过滤掉数字1。结果将是一个由2个数字组成的2,3列表。我应该在flatMapMany中做些什么，这样它才能跳过数字1
Mono.just(new LinkedList<>{{
add(1);
add(2);
add(3);
}})
.flatMapMany(number -> {
if (number == 1) {
// not return
}
return number;
})
.collectList()
.map(numbers -> {
浏览 3提问于2020-04-23得票数 1
回答已采纳
2回答
具有多个顺序API调用的Spring网络流量，并将其转换为无订阅和块的通量对象。
spring、spring-boot、spring-webflux
我正在处理spring反应性，需要使用webclient对其他REST调用多个调用。问题是我能够调用多个对其他Rest的调用，但是响应不能在没有订阅或阻塞的情况下读取。由于非反应性编程，我不能使用订阅或阻塞。有没有办法，我可以合并，同时读取响应，并发送它作为流量。下面是我被卡住的代码。
private Flux<SeasonsDto> getSeasonsInfo(List<HuntsSeasonsMapping> l2, String seasonsUrl) {
for (HuntsSeasonsMapping s : l2)
{
浏览 7提问于2021-12-06得票数 0
回答已采纳
1回答
试图管理多个Flux/Mono，先启动其中的几个，然后将其中的一些组合起来，然后有点丢失。
project-reactor、reactor、spring-data-mongodb-reactive
我有一个模块，接受实体ID和“解析类型”作为参数，然后通过返回通量的多个操作异步收集数据(主要)。该解析被分解为多个(主要是，再次)异步操作，每个异步操作用于收集有助于解析的不同数据类型。我说“主要”是异步的，因为某些解析类型需要一些必须同步进行的初步操作，以便为解析的其余异步磁通操作提供信息。现在，当这个同步操作正在进行时，至少可以开始整个异步解析操作的一部分。我想在同步操作发生时启动这些Flux操作。然后，一旦解决了同步数据，我就可以为其余正在进行的操作获取每个Flux。一些解析类型将使所有Flux操作返回数据，而其他类型将收集较少的信息，而一些Flux操作将保持为空。解析度运算是时间-昂
浏览 4提问于2020-12-30得票数 0
回答已采纳
1回答
如何将Java列表从外部源连接到一个列表中
spring-boot、reactive-programming、spring-webflux
在spring 2.0 rest控制器中，我创建了如下代码，这些代码按需要工作：
@ResponseBody
@GetMapping("/test3")
Mono<List<String>> test3(){
List<String> l1 = Arrays.asList("one","two","three");
List<String> l2 = Arrays.asList("four","five","six");
浏览 2提问于2017-06-23得票数 1
回答已采纳
2回答
SpringBoot WebFlux:解析并行WebClient请求
spring-boot、spring-webflux、spring-webclient
我正在使用spring webclient对API进行并行rest调用。响应如下所示
{
"d": {
"results": [
{
"id": "1",
"name": "Test A"
},
{
"id": "2",
"name": "Test B",
}
浏览 1提问于2020-10-08得票数 0
4回答
WebFlux函数:如何检测一个空的通量并返回404？
spring、spring-boot、kotlin、spring-webflux、project-reactor
我有以下简化的处理函数(Spring和使用Kotlin的函数WebFlux )。但是，我需要一个提示，当Flux为空时，如何检测到一个空的Flux，然后对404使用noContent()。 fun findByLastname(request: ServerRequest): Mono<ServerResponse> {
val lastnameOpt = request.queryParam("lastname")
val customerFlux = if (lastnameOpt.isPresent) {
service.fi
浏览 50提问于2017-08-27得票数 11
回答已采纳
1回答
在Mono<Foo>上使用块()总是失败
java、spring、reactive-programming、spring-webflux
我有一个作用于单个元素的函数：
Mono<Foo> myFunction(String arg) {
// do shiz
return result;
}
现在，我尝试重用上面的方法来做同样的事情，但是对于一个args列表：
Mono<List<Foo>> myNewFunction(List<String> args) {
Flux.fromIterable(args)
.map(currentArg -> myFunction(currentArg))
.map(Mono::block)
.coll
浏览 7提问于2022-10-01得票数 0
回答已采纳
1回答
创建保持原始顺序的Mono Array对象
java、kotlin、reactor
我需要实现返回Mono< Array< ProcessedObject>>的函数。作为参数，它接受对象列表，并使用返回Mono< ProcessedObject>的函数处理它们。函数需要保持原始顺序，这意味着返回列表中的第一个元素必须从参数列表中的第一个元素创建。到目前为止，我有以下解决方案，但它没有保持所需的顺序。使用Flux甚至可以吗？
private fun createItems(objects: List<Someobjects>): Mono<Array<ProcessedObject>> {
浏览 9提问于2018-09-10得票数 0
回答已采纳
1回答
订阅/迭代Mono列表
java、reactive-programming、project-reactor
我有一个返回Mono<Result>的规则列表，我需要执行它们，并返回另一个带有每个函数的结果的Mono列表。
Mono<List< Rule>>到Mono<List< RuleResult>>
我有这个，但阻止执行对我来说是不正确的：
List<Rule> RuleSet
...
Mono<List<RuleResult>> result= Mono.just(RuleSet.stream().map(rule -> rule.assess(object).block()).collect(
浏览 8提问于2020-07-23得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
