project-reactor 相关问题

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

使用反应式api阅读kafka主题到底

我们正在使用压缩的kafka主题来存储状态更改，并且在重新启动或重新平衡期间，需要通过将主题读到末尾并为每个键获取最后一个条目来恢复状态。对于非反应性...

java apache-kafka project-reactor

回答 1 投票 1

将一个websocket客户端的输出作为输入发送给另一个

对SO的快速搜索未能找到我类似的问题，所以我们基本上要使用Webflux的RSocket的requestChannel语法，以便能够在...之外处理接收到的Flux ...] >>

java spring-webflux project-reactor

回答 1 投票 1

使用Reactor Publisher避免GC压力

我正在寻找一种方法，通过实例化每个调用的整个管道，从而在Project Reactor中正确使用发布者，而不会产生无用的GC压力。在我们的代码中，典型的句柄函数...

java reactive-programming spring-webflux project-reactor

回答 2 投票 1

CacheFlux：如何同步查找/ onCacheMissResume？

[在Spring Boot应用程序中使用Spring Cache时，可以使用syncattribute确保一次仅一个线程/请求更新缓存：@Cacheable（value =“ myCacheName”，key =“ ...

java caching spring-webflux project-reactor

回答 1 投票 0

使用RSocket和Project Reactor实现202 ACCEPTED-重试行为

我正在实现一个典型的用例，其中客户端请求将异步生成的资源。因此，将立即生成并返回一个resourceID：1.客户端---（（POST / request -...

spring-webflux project-reactor rsocket rsocket-java

回答 1 投票 0

Project Reactor + flatMap + Multiple onErrorComplete-无法正常工作

[将多个onErrorContinue添加到管道中以处理从flatMap抛出的特定类型的异常时，异常处理无法按预期方式工作。我希望下面的代码是...

project-reactor spring-reactor

回答 1 投票 1

repeatWhenEmpty运算符在RSocket websocket请求的上下文中不起作用，但在HTTP调用中起作用

我遇到了repeatWhenEmpty运算符的奇怪行为，这对我没有任何意义。我在Github上上传了一个可复制样本最少的存储库：https：//github.com / ...

spring-boot spring-webflux project-reactor rsocket spring-rsocket

回答 1 投票 1

WebFlux（反应堆）中的文件处理

我正在一个未完成的项目中，正在进行许多文件处理IO。如果我以命令式阻塞的方式编写IO代码然后将它们包装在Mono中，然后发布...

reactive-programming spring-webflux project-reactor reactor spring-reactor

回答 1 投票 0

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

project-reactor 相关问题

最新问题