project-reactor 相关问题

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

我正在研究 spring webflux 文件上传。我想从控制器将文件上传到亚马逊 S3 存储桶上。所以在控制器中我收到了以下对象 org.springframework.http.codec.multip...

java spring spring-boot spring-webflux project-reactor

回答 2 投票 0

@RequestMapping(值 = "/try", 方法 = RequestMethod.GET) @ResponseBody 公共字符串演示（）{ Listdata=new ArrayList<>(); 数据.add("A1"); 数据.add("A2"); 数据...

reactive-programming project-reactor

回答 2 投票 0

Spring Webflux 在返回响应之前等待所有 Flux.fromIterable

我有一个反应式服务并且运行良好公共 Mono getCasesList(@RequestBody GetCasesListRequest 请求) { 返回 caseService.getCasesList(

spring-boot spring-webflux project-reactor

回答 1 投票 0

Project Reactor：如何定期执行任务并响应外部信号？

想象一个重复执行的任务，每次执行之间最多有 10 秒的延迟。还有一个外部信号会导致任务立即执行。（外部

project-reactor

回答 2 投票 0

Spring Reactor Context到底是什么？

在非响应式java中我们使用ThreadLocal来传递Context数据，但是对于Reactor，Spring团队建议使用Reactor Context来将数据传播到线程。在 spring 文档中它说：项目重新...

spring spring-webflux project-reactor

回答 1 投票 0

如何将 if-else 语句包含到反应流中

我有一个 Spring Webflux 反应式服务，它接收 DTO 并将其插入到多个表中。有时我们可能需要根据传入的 DTO 跳过插入某些表。这些是

java spring-webflux project-reactor

回答 3 投票 0

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

在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 相关问题

最新问题