project-reactor 相关问题

Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。

同时处理反应式查询结果

我需要迭代大量查询结果并对每个实体执行一些业务逻辑。数据库与 Spring Data Mongo Reactive 连接，因此我得到了 Flux。简单的

project-reactor spring-data-mongodb-reactive

回答 1 投票 0

基于时间的事件链（按钮点击多重性）

我有一个程序可以生成游戏手柄按钮/轴事件流。我希望能够识别点击多重性。最后一步，有一个 Flux<> 管道：最终通量<

java project-reactor

回答 1 投票 0

WebFlux 根据不同的结果链接各种操作

我需要协调以下一系列行动： A) 检查用户是否已经付款 boolean checkUserPayment(Long userId) B) 如果上述 A) 为真，则继续 UserInformation fetchUserInformationF...

spring-webflux project-reactor

回答 1 投票 0

在反应器中流动多个对象的有效/正确方法是什么

我是反应式编程的新手，为了上手，我正在尝试构建一个接近真实的示例。当您看到反应堆教程时，他们会向您展示非常简单的示例，例如。返回 userRepository.findB...

java reactive-programming spring-webflux project-reactor

回答 2 投票 0

如何计算Java响应式进程所花费的总时间

我有一个Java反应式Spring Boot应用程序，我正在执行以下逻辑，我想记录完成整个方法需要多少时间。我可以更改方法签名，但想...

java spring-boot spring-webflux project-reactor reactive

回答 1 投票 0

如何在反应式编程中将对象转换为 Mono

我是java中的响应式编程新手。我尝试以异步方式执行以下程序。我的意思是主线程必须完成其执行而无需等待 Mono 对象。但是...

java spring-webflux project-reactor

回答 1 投票 0

DynamicThresholdFilter 不适用于 Log4j2 中的特定包

我正在尝试在 Log4j2 中应用 DynamicThresholdFilter 来过滤特定包（com.example.orange）的日志。我的目标是仅基于

java spring-boot log4j2 project-reactor slf4j

回答 1 投票 0

如何在Java spring中并行运行事务？

我们有一个初始交易，需要做一些准备工作。现在我们想暂停初始交易并产生 N 个新交易，这些交易并行地做自己的事情并且不会干扰......

java spring transactions project-reactor

回答 1 投票 0

如何压缩超过 8 种不同类型的单声道

我正在尝试同时进行 9 个 api 调用。所有这些调用都会返回不同的响应对象。在此之前我们有 8 个 api 调用，由于这些 mono 是不同的类型，我使用 Mono.zip

java spring spring-webflux project-reactor

回答 3 投票 0

在 Exchange() 之后调用 bodyToMono 时，block()/blockFirst()/blockLast() 会出现阻塞错误

我正在尝试使用 Webflux 将生成的文件流式传输到另一个位置，但是，如果文件的生成遇到错误，API 将返回成功，但会使用 DTO 详细说明错误，同时

java reactive-programming spring-webflux project-reactor

回答 6 投票 0

第一个Mono完成后调用Mono并返回第一个Mono的结果

我想在Webflux环境中执行两个业务操作，第二个操作仅在第一个操作成功后才发生。第二个做完后我想回去...

java spring spring-webflux project-reactor

回答 2 投票 0

Spring 状态机有时会出现垃圾邮件重试耗尽错误

我已经设置了一个我认为相对简单的 Spring 状态机。有时（也许每次）某些事情会触发外部事件，我会收到大量此类错误。知道我做错了什么......

spring project-reactor spring-statemachine

回答 2 投票 0

如何将 Flux<Mono<String>> 转换为 List<String>

已经使用 springboot-3.x、webflux 编写了响应式应用程序，需要将 Flux> 转换为 List

java spring-webflux project-reactor java-17 spring-boot-3

回答 1 投票 0

如何将 Mono<String> 从循环添加到 List<String>

已经使用 springboot-3.x、webflux 编写了反应式应用程序，并且需要将 String 从 Mono 添加到 for 循环内的 List 。已实现以下代码： Flux> IdFlux = Flux.e...

java spring-boot spring-webflux project-reactor spring-boot-3

回答 1 投票 0

避免 Flux<>Input 的函数方法中嵌套 Flux<Mono<>>

> 的情况，如下所述方法如下...

spring-webflux reactive-programming project-reactor spring-cloud-function

回答 1 投票 0

有没有办法创建一个 RSocket“forRequestStream”并将其作为 Pekko/Akka Sink 返回而不使用已弃用的 FluxProcessor？

在我的用例中，我需要使用 RSocket 协议通过网络创建反应流，并在客户端返回 pekko Source，在服务器端返回 pekko Sink。我没有

scala akka project-reactor rsocket pekko

回答 1 投票 0

将反应式 Mono 上下文传播到 Caffeine AsyncCache

在我们的反应式应用程序（Spring WebFlux、Reactor 项目）中，我们在反应式上下文中携带重要的日志信息。问题是当我们使用 Caffeine AsyncCache 时，上下文是......

java spring spring-webflux project-reactor caffeine-cache

回答 1 投票 0

如何从 WebFlux 中的 Mono<List<T>> 中提取内容并将其传递到调用链中

我希望能够从 Mono> 中提取 List，将其传递给下游服务进行处理（或者可能从读取（RequestParams params）返回...

spring-boot spring-webflux project-reactor

回答 2 投票 0

如果Redis是单线程的话，怎么能这么快呢？

我目前正在尝试了解Redis的一些基本实现。我知道 Redis 是单线程的，并且我已经偶然发现了以下问题：Redis 是单线程的，...

multithreading redis project-reactor single-threaded

回答 2 投票 0

终止后重新订阅 Sink

我有一个水槽，上面有一个订户。在压力测试期间，我们意识到队列已满并且接收器发出 FAIL_OVERFLOW 信号。继续测试后...

spring-webflux project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题