project-reactor 相关问题

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

带 Reactor 的非阻塞 ReentrantLock

我需要限制同时处理相同资源的客户端数量所以我试图实现模拟锁.锁(); 尝试 { 做工作 } 最后 { 锁定。解锁（）； } 但在非...

java project-reactor

回答 3 投票 0

通过共享运算符将可连接的 Flux 转换为 Hot

我有下面的程序，它首先创建一个区间通量，取 5 个元素并订阅它。发布之后，我使用带有自动连接 2 的重播运算符将其转换为可连接的通量，然后转换...

java project-reactor reactive-streams

回答 1 投票 0

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

project-reactor 相关问题

最新问题