project-reactor 相关问题

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

将春季应用程序崩溃在Outofmemoryerror

我们有春季应用程序,已部署在云铸造厂上。此应用程序执行一些任务,例如调用不同的端点和API。最近我们遇到了一个问题:应用程序开始投掷

回答 1 投票 0




不能够使用python3.10.16`

系统信息 python- version 输出Python 3.10.16 我运行了此命令python -m pip install Insightface == 0.7.3并获取以下控制台输出 使用缓存的cython-3.0.11-cp310-cp310-

回答 1 投票 0



Spring WebClient 似乎使用 Retry.withThrowable 来抑制 WebClientResponseException

使用 Spring 的 WebClient 我想实现以下行为。 当服务器返回 HTTP 429(请求过多)时,我想提取 Retry-After 标头值。该请求应...

回答 1 投票 0

线程反应器不支持block()/blocking()

以下是从 API 获取一些信息的逻辑: 类 OneClient { 公共 Mono getSomeInformation(ClientRequest req) { 返回 getWebTarget(req) .请求...

回答 2 投票 0

同时处理反应式查询结果

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

回答 1 投票 0

基于时间的事件链(按钮点击多重性)

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 2 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

DynamicThresholdFilter 不适用于 Log4j2 中的特定包

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 3 投票 0

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

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

回答 6 投票 0

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

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

回答 2 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.