project-reactor 相关问题

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

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

如何在java中使用Mono创建条件循环？

我需要在反应式管道中有一个条件循环。只要条件为真，它就应该继续循环，一旦条件变为假，它就应该停止循环并返回它所去的任何值...

java project-reactor

回答 1 投票 0

如何在Java Reactor中创建Tuple2、Tuple3等？

创建此问题和答案是为了帮助其他人快速查找如何创建Reactor Tuple，例如reactor.util.function.Tuple2 我在

java tuples project-reactor

回答 1 投票 0

如何使用Java中的projectreactor将错误翻转为无错误？

我有 Mono 的实例它可以具有价值，也可以是错误。现在我需要将其转换为 Mono，其中错误和无错误翻转单核细胞增多症 .doMagic( $ -> { ...

java project-reactor

回答 1 投票 0

如何测试Spring WebClient何时重试？

我需要实现以下行为：发出 REST 发布请求如果响应返回状态为 429 Too much requests，则最多重试 3 次，延迟 1 秒如果第三次重试失败或出现任何情况

rx-java reactive-programming project-reactor spring-webclient

回答 3 投票 0

如何在使用反应式数据源的 WebFlux 上编写自定义验证器

在 Spring MVC 中，我有一个 @UniqueEmail 自定义休眠验证器（用于在注册时检查电子邮件的唯一性），如下所示：公共类 UniqueEmailValidator 实现 ConstraintValidat...

spring spring-data-mongodb spring-webflux project-reactor

回答 3 投票 0

flatMap 中的单声道超时 - 在“flatMap”中的 20000 毫秒内没有观察到任何项目或终端信号（并且未配置后备）

我正在使用 Spring WebFlux 发出 POST 请求，但收到以下错误： java.util.concurrent.TimeoutException：没有观察到任何项目或 'flatMap 中 20000ms 内的终端信号...

java spring spring-webflux webclient project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题