project-reactor 相关问题

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

Flux.mergeDelayError 获取所有错误

使用 Reactor 的 mergeDelayError 时，如果发出了不止一个错误，是否有办法获取所有错误，而不仅仅是第一个错误？ Flux.mergeDelayError(10, 助焊剂

java project-reactor reactive

回答 0 投票 0

使用Reactor.core时，Mono对象要启动流是否需要显式订阅？

这是Java系统与设备通信相关的服务层代码 @服务公共类 ValveOpenSender 实现 MessageSender { 私人网络...

java project-reactor

回答 1 投票 0

Reactor 中的 operators publish() 和 map 之间的主要区别是什么

我看过java文档，但我不知道主要的使用场景这是文档； /** * 在可能转换它的函数的持续时间内共享一个 {@link Mono} 并且 *消费...

project-reactor

回答 0 投票 0

无法使用 Reactive Cassandra 访问具有复合键的 Cassandra 表

我正在使用 Spring-Reactive 和 Reactive-Cassandra [spring-boot-starter-data-cassandra-reactive] 来访问 Cassandra 上的表。我能够访问带有代表

java spring-boot cassandra project-reactor spring-data-cassandra

回答 1 投票 0

哪个版本的 reactor-kafka 适用于 Spring 3.1.0-M2？

使用 reactor-kafka 1.2.2.RELEASE 运行 Spring 3.1.0-M2 会产生以下错误。哪个版本与 3.2.0-M2 兼容？我正在尝试创建一个从 K 消费的反应式应用程序......

java spring-boot apache-kafka project-reactor

回答 1 投票 0

有没有办法让存储库调用并行运行？

在我的项目中，我同时运行多个查询。这是我目前正在做的事情的例子在我的存储库中，我正在做这样的事情 “从表中选择计数（列名）...

spring-boot project-reactor

回答 2 投票 0

Spring WebFlux，并行调用，返回类型多样的高效服务层

我正在 Spring WebFlux(2.3.5) 和 java 11 中编写一个 API，我需要创建一个具有三个顺序函数调用的高效服务层。在第一个函数中，有五个

java spring spring-webflux project-reactor

回答 0 投票 0

并行运行 Flux 操作

我有一个项目列表，我需要从不同来源检索数据、合并并返回这些项目。这些项目是完全独立的，获取数据将花费最多的时间，所以我希望它是

java asynchronous spring-webflux project-reactor

回答 1 投票 0

合并两个不同类型的 Flux 实例

使用 SpringBoot 2 和 Poi 类（兴趣点）：公共课 Poi { public Poi(String poidId, Double price, Double latitude, Double longitude) {...} 私有字符串 poidId；私人斗...

reactive-programming project-reactor

回答 3 投票 0

如何记录单声道通话结果？

我正在尝试创建一个调用多个 API 的控制器：第一次通话如果成功先调用另一个 API 调用另一个第二个 API 别的返回 API 错误为此，我使用 spring-cloud-ga ...

java spring spring-boot spring-webflux project-reactor

回答 2 投票 0

为什么 ParallelFlux 没有类似于 Flux 的 collectList()？

Flux有collectList()，用起来很方便，但是ParallelFlux中没有collectList()，我想弄明白ParallelFlux中省略collectList()的原因。

project-reactor

回答 1 投票 0

带有反应式 redis 缓存的 Webflux

我有一个 CacheConfig，我在其中设置了 ReactiveRedisConnectionFactory，我可以连接到 Redis。但是，当我尝试将任何内容保存到缓存中时，由于以下原因，它失败了原因：java.lang.

java redis spring-webflux project-reactor

回答 0 投票 0

Spring WebFlux 和 WebClient 调用不工作

我是反应式编程的新手，我有以下 rest 资源调用使用 WebClient 调用现有 Rest API 的服务： @PostMapping public Mono createU...

spring spring-boot spring-webflux project-reactor spring-webclient

回答 1 投票 0

使用反应式存储库保存 Mono

我尝试实现一个反应式端点来保存新的实体实例：保存在 SubjectRepository 中的方法仍然需要没有 Mono 包装器的 Subject。但是如何从反应包装中提取价值...

java spring spring-boot spring-webflux project-reactor

回答 1 投票 0

如何将两个 webclient mono 调用合并为一个 mono<ResponseEntity<>> call

我有两个调用 a() 和 b() 并且都 returnMono，字符串是具有不同结构的 json。我还有两种方法可以从每个 json 字符串中提取数据。我想结合...

kotlin spring-webflux project-reactor spring-webclient

回答 1 投票 0

如何将 Mono<ResponseEntity<Object>> 转换为 Mono<ResponseEntity<Void>>

您好，我有一个返回 Mono> 的 API，该 API 将调用另一个返回 Mono> 的 API，我如何将结果转换为其他 ...

spring spring-webflux reactive-programming project-reactor

回答 1 投票 0

如何为反应式 Spring Integration 流程编写过滤器？

我在我的集成流程中使用 RSocket 作为 InboundGateway，使用交互模型 REQUEST_CHANNEL。它发出我的业务对象的 Flux。我可以使用 RS 来“装饰”这些对象……

spring-integration project-reactor spring-integration-dsl

回答 1 投票 0

Spring Webflux：无法启动kafka消费者

当我尝试启动连接到本地 kafka 代理的应用程序时，一切正常。但是当我尝试使用 ssl 身份验证连接到我的托管代理时，我得到了以下错误...

apache-kafka spring-webflux project-reactor

回答 0 投票 0

如果出现意外错误，我可以重用 Mono 吗

我有以下代码 Mono fileInfoMono = getFileInfo(fileName, filelocation); 返回 fileInfoMono.map（信息 -> fileReader.read（信息） .doOnNext(这个::日志) ...

java spring spring-webflux project-reactor

回答 1 投票 0

如何在 Flux onError 中获取数据

问题不是针对数据库的，而是用数据库的例子描述的我使用反应式驱动程序从数据库中获取一些实体使用 itemMapper 在 Item 实体中转换它们。保存...

java error-handling spring-webflux project-reactor

回答 2 投票 0

project-reactor 相关问题

最新问题