project-reactor 相关问题

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

Mono / Flux是否具有Stream API中的Peek / IfPresent这样的运算符？

正如标题所述，想知道在使用Mono / Flux时是否有任何等效（或类似的）运算符可以窥视，并且Java Stream API中是否存在ifPresent。

java java-stream spring-webflux project-reactor

回答 1 投票 1

Reactor Flux flatMap操作员的吞吐量/并发控制并实现背压

我正在使用Flux建立我的反应性管道。在管道中，我需要调用3个不同的外部系统REST API，它们的访问率非常严格。我会被节制...

spring-boot spring-webflux project-reactor reactive-streams spring-webclient

回答 1 投票 1

术语“不可知的并发”到底是什么意思？

我试图理解Java反应式库，我在这里通过关键字“ concurrency-agnostic”来实现。有人可以提供一个小的工作示例来更好地理解这一点吗？这是否意味着...

java multithreading reactive-programming project-reactor

回答 1 投票 0

如何在本测试中优化stepVeriifer的使用？

我正在使用Reactor的Flux（projectreactor.io）创建反应性流。在我的流生成方法（connect（））中，我将放入一些类型为X的消息，然后最后在...

project-reactor

回答 1 投票 1

Spring Webflux非阻塞相关资源调用

我正在使用Spring Webflux和Spring Data MongoDB Reactive。在我的REST Controller中，我试图从数据库（MongoDB）中获取所有类型的对象（例如某个品牌的所有自行车）。我当前的...

java spring spring-webflux project-reactor reactive

回答 1 投票 0

助焊剂到列表无阻塞

正在寻找将助焊剂转换为列表。如果我使用block（）会出错。因此，需要进行转换而不会阻塞呼叫。 Flux.from（Collection.find（））使用反应式编程，但graphql期望使用List和...

java reactive-programming project-reactor graphql-java

回答 1 投票 1

Spring WebClient多次重试何时处理不同的错误

我是否可以添加多个retryWhen来执行重试以处理不同的WebClient故障响应？我要实现的目标：我正在使用WebClient进行REST API调用。几乎没有错误...

spring-boot project-reactor spring-webclient spring-reactive

回答 1 投票 1

反应器有条件的两个来源

我有两个排序整数源：A和B。我需要将两个源压缩为一个限制：仅压缩A和B中都存在的这些项。例如：A为：1 2 3 10 11 12 13 14 B ...

java project-reactor

回答 1 投票 0

DirectProcessor和UnicastProcessor可以在不应该订阅上游Publisher的情况下进行订阅。为什么？

根据有关处理器的Project Reactor文档：直接（DirectProcessor和UnicastProcessor）：这些处理器只能通过直接用户操作（调用它们的...）来推送数据。

spring reactive-programming project-reactor

回答 1 投票 1

Reactor Flux：如何使用标题解析文件

最近我开始使用Project Reactor 3.3，但我不知道什么是处理线通量的最佳方法，首先将行作为列名，然后使用这些列名来处理/转换所有其他...

java project-reactor

回答 2 投票 1

Project Reactor有条件地执行独立验证步骤

我不知道，如何在没有if / else的情况下执行此方法：public Mono doAuthorization（InputDto dto）{if（isXStepNeeded（dto））{return doXStep（dto）.then（...

java reactive-programming project-reactor

回答 1 投票 0

与Flux的相交操作-Project Reactor

假设我同时拥有var a = Flux.just（“ A”，“ B”，“ C”）和var b = Flux.just（“ B”，“ C”，“ D”）能够将两个变量相交，并且结果应等于已设定的相交...

java reactive-programming spring-webflux project-reactor

回答 1 投票 0

避免使用带有助焊剂的spring webclient多次调用API

这两个调用都是客户端http api：Flux views = SavingApi.getViewFilterSavings（viewId）;通量组= groupsApi.getAllGroups（）;并返回一个...

spring-webflux project-reactor reactor spring-webclient

回答 2 投票 0

Flux.concatMap中的预取

Flux.concatMap中预取的确切用法是什么？如在文档中一样，它是“内部源产生的需求”。但是，如果我的内部源产生的值大于预取值，则它们由...

spring-webflux project-reactor

回答 1 投票 1

将两个流合并为一个磁通

如何将两个流Stream 合并为Flux？我了解的是，我可能需要使用Flux创建方法来创建它，但我对此不太确定：flux1.create（sink-> ...

java java-stream project-reactor

回答 1 投票 1

是否有可能为项目反应堆中的多个订户提供具有独立背压支持的热门发布者？

我的情况如下：我有一个生成器，可以生成随机数据。生成的数据应由多个订户接收。由于生成的数据是随机的，因此我不能使用感冒...

java reactive-programming project-reactor

回答 1 投票 0

反应式处理：具有预取和有序使用者的异步IO生产者（提供了MWE）（java Project Reactor 3.x）

问题陈述：以块的形式进行I / O。一旦一个块可用，就开始处理这些块，同时在后台读取其他块（但预先读取的块不超过X个）。处理...

java project-reactor

回答 1 投票 0

CircuitBreaker不会将状态从HALF_OPEN更改为CLOSED

我在弹簧启动的反应性应用程序中具有此断路器配置-CircuitBreakerConfig.custom（）。failureRateThreshold（5）.slowCallDurationThreshold（Duration.ofMillis（5000）...

spring-webflux project-reactor circuit-breaker resilience4j spring-reactor

回答 1 投票 0

groupby和具有无限流的过滤器之间的选择

我们在项目中使用spring webflux。在我们的项目中，我们通过websocket接收消息，然后根据消息的类型选择一条消息处理管道。与反应堆一样...

java spring-webflux project-reactor reactor

回答 1 投票 0

如何使用Web流通量和JDBC保存多个记录？

我正在尝试使用Spring Boot构建一个简单的Web应用程序-webflux（功能端点）和jdbc。该应用接收XML格式的有效负载（这是1名员工的一些详细信息）。给定代码...

spring-boot jdbc reactive-programming spring-webflux project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题