project-reactor 相关问题

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

为什么Reactor的Mono.fromCompletionStage比普通的CompletableFuture慢？

我有一段简单的代码，在后台 "处理 "数据，每处理完第n个项目后，记录最后n个项目所花费的总时间： class BackgroundWorker implements AutoCloseable { private ...。

java project-reactor completable-future

回答 1 投票 1

如果Mono为空，则创建一个未找到的ServerResponse。

我正在使用Spring Boot 2.2.6、Kotlin和coroutines来实现一个简单的反应式休息API。我正在尝试使用函数式。我如何改变下面的代码来返回404 HTTP ...

spring-boot kotlin spring-webflux project-reactor kotlin-coroutines

回答 1 投票 0

用R2DBC Postgresql WebFlux无法获得响应。

我正在学习R2DBC与spring boot WebFlux和Postgresql。我已经成功地配置了PostgreSQL数据库，它运行在我的本地机器上。我使用了以下的依赖和插件......

postgresql spring-boot spring-webflux project-reactor spring-data-r2dbc

回答 1 投票 0

当ParallelFlux中发生错误时，回滚所有的变化。

我正在使用spring webflux和reactor，我有以下的flux用于上传图片，调整图片大小和存储它们。对于每个尺寸，我在一个自定义的执行器上并行执行所述的通量......。

java spring spring-webflux project-reactor reactor

回答 1 投票 0

onSubscribe([Synchronous Fuseable] FluxArray.ArraySubscription) [ INFO]...

project-reactor

回答 1 投票 0

如何使用spring web flux处理url编码的payload？

客户端发送的是编码的有效载荷(百分比编码)，而给定的代码对于非编码的有效载荷XML(content-type:applicationxml)是有效的，但对于编码的有效载荷XML文件(......)却以http 415失败。

java spring-boot http-headers spring-webflux project-reactor

回答 1 投票 0

用Spring Reactive（R2DBC）连接MSSQL。

我正在尝试与Microsoft SQL Server建立数据库连接。不幸的是，我不能理解为什么它不工作。而错误信息不幸的是，不能给我...

java spring reactive-programming spring-webflux project-reactor

回答 1 投票 1

等待Publisher完成，并将其用于另一个Publisher，该Publisher会将所需数据返回给webflux。

我有一个简单的代码，将一些数据保存在数据库中，并返回保存的值 public Flux----------。保存人员(Flux 人）{单 lastPersonId = ...

java spring-webflux project-reactor

回答 1 投票 -1

Spring Kafka云功能。没有上下文中的事务

我开始涉猎Spring云流和它的云功能支持。我在这里上传了一个示例项目来阐明这个问题->https:/github.comnmarquesantosspring-cloud-function-...

spring-kafka project-reactor spring-cloud-stream spring-cloud-function

回答 1 投票 0

如何在流量中计算项目，如果计数大于X，则返回错误，否则继续使用管道。

我是Spring中Project Reactor的新手，我不完全清楚如何执行一些事情：我有我的管道管道返回记录。一切都很好。但我想计算这些记录，然后做...

java spring reactive-programming project-reactor spring-reactor

回答 1 投票 0

Spring reactive中的MonoProcessor是用来干什么的？

在查看Spring框架的WiretapConnector源代码时，我偶然发现了一个MonoProcessor类型的对象。我试着在谷歌上搜索它的用途解释，但没有用。Javadoc ...

spring project-reactor spring-reactive

回答 1 投票 0

Spring Reactor Webflux Scheduler的并行性

对于完全无阻塞的端到端反应式调用，是否建议显式调用publishOn或 subscribeOn来切换调度器？对于耗费cpu或非耗费cpu的任务，是否有利于...

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

回答 1 投票 1

如何在文件行出现时读取文件行，并将其表示为Flux？

假设我们依赖Reactor 3（即在Spring 5应用程序中）和一个文本文件myfile.txt。我需要订阅文本文件的行数（包括现有的和将来会出现的行数），并且...

java project-reactor flux spring-reactor

回答 1 投票 1

有办法合并多个单声道错误信号吗？

有没有办法将多个错误信号合并？例如：返回Mono.zipDelayError( monoOne(), /throws ValidationException with list of validation details 1 monoTwo(), ...

java mono spring-webflux project-reactor flux

回答 1 投票 0

Aop和Mono争论

我有一个方法Mono a01(单声道) 请求）和方面@Around("callAtMyServiceSecurityAnnotation(request)") @Order(1) public ...

spring-aop project-reactor

回答 1 投票 0

项目反应器。用单体的结果来丰富通量的结果

我正在努力将反应式编程引入我的公司。我正在建立一个活动推荐系统的简单演示，以证明其性能优势。其中一个...

java reactive-programming project-reactor reactive-streams

回答 1 投票 1

创建Flux.fromIterable后如何运行onClose操作？

假设我们需要根据一个Closeable资源的内容创建一个Flux。为了清楚起见，假设有一个BufferedReader要被转换为Flux。 . BufferedReader reader = createReader("..."。

java project-reactor flux reactor autocloseable

回答 1 投票 0

流量数据取决于流中后期的数据------------------------------------------------寻找更好的模式

我对反应式编程很陌生但我想在Spring Boot应用程序中使用Project Reactor的FluxMono APIs写一些新的代码。我有一个有限的数据流（具有唯一的ID）......

java reactive-programming spring-webflux project-reactor

回答 1 投票 0

MonoFlux是否有类似于Stream Optional API中的Peek IfPresent这样的操作符？

正如标题所说，我想知道，当使用MonoFlux时，是否有任何与Java Stream API中的peek和ifPresent相当（或类似）的操作符。

java java-stream spring-webflux project-reactor

回答 1 投票 1

如何从第一次调用开始，对列表中的每个项目进行链式调用。

我有两个对象 CarParts { String id WorkItem workItem } WorkItemResponse { List 资源。

spring webclient spring-webflux project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题