project-reactor 相关问题

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

如何基于中间数据验证来停止反应堆运行链

在reactor运行链中，它首先向另一台服务器查询响应，然后根据响应字段，继续reactor Mono链或停止。在使用reactor之前，我经常使用if else来

spring-webflux project-reactor

回答 1 投票 0

Mono<T> 和 Flux<T> 作为函数中的参数

Mono 和 Flux 作为函数参数的用例是什么。代码 Flux findByLastName(Mono 姓氏) { //执行 } 当我调用上面

java project-reactor

回答 3 投票 0

Webflux：如何拆分事件，在每个组上应用不同的地图，然后将它们合并回来

我有一个项目列表，其中有 2 种类型的 id。我需要将它们分成 2 组，然后为一组调用另一种方法，该方法将丰富 id 并提供不同的 id，而对于另一组...

grouping spring-webflux project-reactor flux

回答 1 投票 0

使用 Quarkus 和 Reactor 重写异步过滤器中的数据流

我有一个来自侧面服务的网络钩子，我尝试在控制器前面创建一个过滤器，以检查签名。就像 Spring Security 风格，但不幸的是，它是带有 Reactor 的 Quarkus。在

kotlin quarkus project-reactor

回答 1 投票 0

Project Reactor 中的方法签名和错误处理

有点绕圈子试图处理一个场景，我可能只是不以“反应性”方式看待它，只是需要休息一下才能看到更大的图景。可以说我想要...

spring-boot kotlin project-reactor

回答 1 投票 0

为什么额外的 log() 会影响用于计算 fromCallable() 的线程池？

我正在玩 Project Reactor 并面临不直观的行为。举个例子： Mono.fromCallable(() -> 计算()) //。日志（） .publishOn(Schedulers.boundedElastic())...

java project-reactor

回答 1 投票 0

上下文传播在@SpringBootTest中不起作用

我使用 WebClient（反应器）的 Spring-WebMvc 应用程序丢失了 @SpringBootTest 中的上下文。我有一个 @SpringBootApplication ，它向调用者提供 @RestController 端点。当c...

project-reactor spring-boot-test thread-local micrometer

回答 1 投票 0

Reactor Flux 保持阻塞，直到收到服务器响应

我创建了一个 Flux，它在订阅时发出 API 响应。 API 需要几秒钟的时间来响应。我还将流程切换到具有 2 个线程的调度程序。私有调度程序 sc = 调度程序。

spring-boot mono spring-webflux project-reactor flux

回答 1 投票 0

项目reactor：是否有类似finally这样无副作用的方法（不是副作用方法doFinally）

举这样一个例子： Mono.create(回调-> { 尝试{callback.success(someLogic()); } catch (异常 e) { 回调.error(e); } }) .doFinally((v) -> Mono.fromRunnable(() ->...

java reactive-programming spring-webflux project-reactor

回答 1 投票 0

如何将 Mono 和 Flux 结合起来

我正在创建一个产品通量和一个需要应用于产品的单类别对象，因为它们都被分组到同一类别中。我正在尝试添加类别...

spring-webflux reactive-programming project-reactor

回答 1 投票 0

如何将 Mono 的异常映射到另一个异常

我在 Spring Webflux (Java 20) 中有一个端点，它接收 UUID 字符串，我需要使用 UUID.fromString 来验证它。如果后者因为 String 格式错误而抛出异常，那怎么办

java reactive-programming project-reactor

回答 1 投票 0

Project Reactor - 如何检查 Mono<Void> 是否确实被调用？

我是反应式编程的新手（而且我读过很多类似的问题）。在我当前的宠物项目中，我遇到了以下问题（我为

java functional-programming spring-webflux project-reactor

回答 1 投票 0

如何创建一个真正发出元素的 Mono<Void>？

所以我想创建一个真正发出元素的 Mono（或任何 Mono）。为什么？因为我实际上想运行一个效果，而结果只是暗示了效果...

project-reactor void

回答 2 投票 0

对于反应式 Kafka 中的一个生产者和多个消费者来说，是否可以拥有恰好一次语义？

我想知道是否可以通过分布式消费者以反应方式实现一次语义。在 Reactor Kafka 的参考文档中，我们有一个 Exactly-once 交付的示例代码。 ...

apache-kafka spring-kafka project-reactor

回答 1 投票 0

Project Reactor 的 subscribeOn() 不会影响 onSubscribe() 在指定 Scheduler 中调用，如 JavaDoc 中所述

Project Reactor 的 Javadoc 声明关于方法：公共最终 Flux subscribeOn(Scheduler 调度程序) 那在指定Scheduler的Scheduler.Worker上运行subscribe、onSubscribe和request。一个...

java project-reactor

回答 1 投票 0

如何迭代Flux中的对象并对其进行操作？

我正在使用项目反应器，我想执行以下操作： @覆盖公共无效运行（ApplicationArguments args）{ Flux.from(KafkaReceiver.create(receiverOptions) ...

spring-webflux project-reactor reactor reactive-streams

回答 1 投票 0

Mono.Defer() vs Mono.create() vs Mono.just()？

有人可以帮助我理解以下之间的区别： Mono.defer() Mono.create() Mono.just() 如何正确使用？

spring-webflux project-reactor

回答 3 投票 0

Mono<Object>而不是Mono<ResponseEntity>（Java 8）

尝试为 API 练习反应式编码，但我很难理解在使用 flatMap() 和 map() 转换为 ResponseEntity 对象时我做错了什么。该错误提到 co...

java spring spring-webflux reactive-programming project-reactor

回答 1 投票 0

反应式 Kafka 消费者不断重新平衡

我们使用 60 个分区，有 70 个消费者（比分区多 10 个），任何分区中都没有消费者滞后，但重新平衡不断循环发生。每个

java apache-kafka project-reactor reactor-kafka

回答 1 投票 0

Reactor：使用 Mono<Void> 或像 Mono<Boolean>

我有一个使用 Spring 和相关库（包括 Reactor）用 Java 编写的 REST 服务，使用 Mono 来包装昂贵的操作。我正在用通常的CRUD方法重构DB相关代码...

java spring project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题