project-reactor 相关问题

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

如何迭代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

使用项目反应器实现过滤器

我有一个来自 Mongo 的项目列表，我需要通过远程调用结果过滤它们，如下所示： repository.findByString(String string) // Flux .filter(a -> {

java spring-webflux project-reactor

回答 1 投票 0

使用反应堆即发即忘

我的 Spring boot 应用程序中有如下方法。公共 Flux 搜索（SearchRequest 请求）{ Flux result = searchService.search(request);//返回 Flux ...

java spring spring-boot spring-webflux project-reactor

回答 3 投票 0

.subscribe(-) 与 .map(-).subscribe()

我正在阅读有关使用 Mono 和 Flux 上的转换运算符转换数据的项目反应器文档。不过我可以帮忙问一下这个问题.. 做逻辑有什么区别...

java project-reactor

回答 1 投票 0

如何在Webflux中同步rest方法？

问题在于，同时调用updateUser时，会出现错误的余额更新。 2023-09-03T18:20:53.035+03:00 信息 12668 --- [actor-tcp-nio-1] com.example.testsync.UserCont...

spring-webflux project-reactor

回答 1 投票 0

使用 StepVerifier 进行简单服务时，Groovy Spock 测试失败

我正在尝试测试我的服务 ProductService，但它失败，表明断言是 MonoJust 而不是我期望的产品。我不知道为什么测试因该问题而失败。我

spring spring-boot spring-webflux project-reactor

回答 1 投票 0

如果找到值则返回 Mono.empty() 但不执行其他步骤

这个问题很难用文字描述，所以如果标题不符合要求，抱歉。我想通过 Project Reactor Flux 和 Mono 实现特定目标，这似乎...

reactive-programming project-reactor reactive

回答 2 投票 0

使用带有 lambda 的反应式应用程序时出现问题

我对在 Java 中使用响应式还很陌生。下面是我面临的问题。我开发了一个带有控制器、服务和存储层以及 R2DBC 驱动程序的 springboot-REST 应用程序。 ...

functional-programming mono project-reactor reactive

回答 1 投票 0

在组装阶段仅订阅发布者并保持不变是否安全？

我已经在 Gitter 中询问过，但看起来这些天不太活跃.. 我很好奇，在生产代码中使用此类构造是否安全：私有 Mono someHandler() {

java spring spring-boot spring-webflux project-reactor

回答 1 投票 0

Java Spring WebFlux 与 RxJava

我开始学习 Java 响应式编程。整个反应范式对我来说是新的。在我的学习过程中，我遇到过一些术语/库，例如 Spring WebFlux、projectreactor...

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

回答 4 投票 0

多部分文件 api 不支持的媒体类型

POSTMAN 总是给出 415 unsupported media type 错误。标头包含带有边界的 multipart/form-data，如下面的 CURL 调用所示。还尝试用 RequestBody 替换 RequestPart...

spring spring-mvc spring-boot project-reactor

回答 2 投票 0

反应器迭代通量直到不为空

我有带有字符串值的反应器通量，我迭代每个值并检查数据库中是否存在给定值。我想迭代每个值，直到在数据库中找到该值。如果没有找到（之后...

java project-reactor

回答 1 投票 0

intellij 不存在类型变量 R 的实例，因此 Flux<R> 符合 Publisher<? extends DataBuffer> 问题

我正在尝试使用带有reactor和spring的java将Mono转换为Mono。我有一个可以编译并正常工作的代码，但它会生成 Intellij 错误。该...

java spring intellij-idea project-reactor

回答 1 投票 0

使用 webClient 的 HttpRequest 和 HttpResponse 的自定义日志格式

我需要以自定义格式记录 HttpRequest 正文和 HttpResponse 正文。例如 “发送请求。标头：{}，正文：{}，uri：{}” 如何获取请求正文？我试试这个： log.info("发送

java spring-webflux project-reactor spring-webclient

回答 1 投票 0

Reactive Java：在运行时更改窗口大小

我每 1 秒就有一个 Flux 发射物品，重复。如何动态改变窗口大小？公共静态无效主（字符串[] args）抛出InterruptedException { 持续时间间隔 =

java spring-webflux project-reactor reactive

回答 1 投票 0

Webflux Reactor如何合并Stream.map输出，可以是Mono和Flux成Flux

A 用于获取源。在下面的映射函数中，如果拥有源，则源是 Flux，否则源是 Mono。函数根据A的List、列表大小...

spring-webflux project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题