project-reactor 相关问题

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

反应式 REST 端点无法从外部库返回 Flux

我有一个使用 io.projectreactor:reactor-core:3.6.5 构建的应用程序（连接器）。这个应用程序有它自己的 api 并返回 Flux，“项目”从网络推送到 Flux...

java spring spring-webflux project-reactor spring-webclient

回答 1 投票 0

如何像Mono一样在expediagroup graphql中实现reactor Flux？

我正在尝试以与Mono类似的方式为Flux编写数据获取器，并使用下面的代码返回CompletableFuture，但这总是返回null。？如何在 graphql 中支持 Flux expediagroup

kotlin graphql project-reactor flux

回答 1 投票 0

项目reactor从v2升级到v3？

真的没有官方项目reactor从v2到v3的升级指南吗？我进行了广泛的搜索，甚至使用 waybackmachine，但我没有运气找到 v2 t 的任何升级路径文档...

java project-reactor

回答 1 投票 0

Reactor：使用 .expand 进行递归/分页

我正在尝试调用一个 API，它返回 2 个给定日期之间的记录。但是在任何给定时间，它一次仅返回 20 条记录。要获取接下来的 20 条记录，我必须检查...

spring-webflux project-reactor

回答 1 投票 0

Spring boot 反应式缓存

在我的应用程序中，我使用 spring webflux，并使用 webclient 从某些第 3 方 API 检索详细信息。现在，我想将第一次 webClient 响应存储在内存缓存中，所以......

spring spring-boot caching spring-webflux project-reactor

回答 3 投票 0

是否可以并行启动Mono并聚合结果

我知道可以链接 Mono，例如…… Mono 结果AMino = loadA(); Mono resultBMano = resultA.flatMap(resultA -> loadB()); 这将连锁并导致 BMon...

java spring-webflux reactive-programming project-reactor

回答 2 投票 0

如何在byte[]和Flux之间进行转换<DataBuffer>

我需要在业务逻辑消耗请求正文之前读取请求正文。所以我计划在我的网络过滤器中执行以下操作：将 DataBuffer 的 Flux 转换为 byte[] 按照我的意愿使用 byte[] 附上一个...

spring-boot spring-webflux project-reactor

回答 2 投票 0

如果不存在则单声道继续

给定两个会话（A 和 B）作为字符串，我的目标是检查 A 在数据库中是否有效。如果A存在，则返回它。如果未提供 A（或数据库中不存在），我想继续

java spring-webflux project-reactor

回答 3 投票 0

Kotlin 子类与 Monos 的类型不匹配

错误：类型不匹配。必需：单色发现：单声道代码生成错误：有趣的例子(): Mono { 返回 Mono.just("") ....

kotlin project-reactor

回答 1 投票 0

Intellij 中子类与 Monos 的 Kotlin 类型不匹配

错误：类型不匹配。必需：单色发现：单声道代码生成错误：有趣的例子(): Mono { 返回 Mono.just("") ....

kotlin intellij-idea project-reactor

回答 1 投票 0

如何在Spring React中从ServerHttpRequest获取inputStream作为返回值？

我正在为第三方 SPI 编写一个基于传统 servlet 的 Spring Reactive 实现。一种方法需要请求中的 InputStream 作为返回值： /** * 返回请求...

java spring spring-webflux project-reactor spring-cloud-gateway

回答 1 投票 0

如果消息处理失败，Kafka-reactor 会再次读取相同的 kafka 消息

从 kafka 读取时，我希望保证在处理来自 kafka 的下一条消息之前，我的 kafka 消息已成功存储在数据库中。我使用java-spring kafka-reactor。这是一个简单的

java spring-kafka project-reactor reactor-kafka

回答 1 投票 0

特定 GroupedFlux 上的延迟元素等

我有一个与此类似的代码： @测试无效shouldSlowdownOnlyEvens() { 最终 Flux globalFlux = Flux.range(1, 20000) .groupBy(数字 -> 数字 % 2 == 0) ...

spring-webflux project-reactor backpressure

回答 1 投票 0

发送高流量时Web客户端超时异常

我正在使用reactor-netty中的WebClient来调用下游，下游延迟为 15 秒才响应。我正在尝试使用 Jmetter 每秒发送 20 个请求，其中一半返回 50 个...

spring-webflux project-reactor reactor-netty

回答 1 投票 0

Java 响应式编程 - 逐个获取页面并并行处理每个页面

我想迭代分页的数据库查询结果并处理每个页面。每个页面的处理应该是并行的，直到处理完 c...

java pagination reactive-programming project-reactor

回答 1 投票 0

Spring Boot 的服务器端事件消费者

鉴于我有此服务-A，此端点返回 contentType(MediaType.TEXT_EVENT_STREAM) @豆公共 RouterFunction 通知路由（CustomHandler

spring-boot spring-webflux project-reactor reactive spring-resttemplate

回答 1 投票 0

Context contextWrite / deferContextual 的 Reactor 用法

我不明白为什么这个简单的代码不起作用。我正在尝试保存我的反应器 Mono 的初始值并在以后重用它。 Mono.just(“蒂蒂卡卡”) .fla...

java project-reactor

回答 1 投票 0

有条件地取消（）通量并保留导致取消的值

我在Java中有以下Reactive Flux流， Flux.just(e1, e2, e3, e4, e5) .flatMapSequentially(/* 处理元素 */) .scan（新累加器（null，0），（元素，总计）->新累加器（

java rxjs spring-webflux reactive-programming project-reactor

回答 1 投票 0

Reactor Kafka receiveAutoAck 和至少一次语义

在Reactor Kafka中，当使用receiveAutoAck时，如果框架在用户代码处理并返回事件后确认事件，那不是尊重“至少一次”sem...

spring spring-boot apache-kafka project-reactor reactor-kafka

回答 1 投票 0

如何监听reactor netty触发doOnError的原因？

定位问题，发现是webflux的Mono触发了doOnCancel。好像是浏览器链接中断导致的，导致执行了doOnCancel。现在我想知道如何...

spring-boot spring-webflux project-reactor reactor-netty

回答 2 投票 0

project-reactor 相关问题

最新问题