project-reactor 相关问题

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

我正在尝试使用spring webflux / reactor对数据库进行嵌套调用，以返回嵌套对象的Mono（具有其角色的用户）。该方案如下：检索具有...

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

回答 1 投票 0

[我正在使用Kotlin + Reactor（Mono和Flux），我想知道使用await ...（）（来自kotlin-coroutines-reactive）函数和subscription（）（来自Reactor）之间的区别。我给...带来了两个例子。

kotlin project-reactor kotlin-coroutines

回答 1 投票 0

doOnNext（）不会被称为Spring Webflux

我是反应式编程的新手，也是Spring Webflux的一种，我有一种方法可以从Redis获取一些键，如果该键为null或不等于指定的字符串，我想抛出一个异常...

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

回答 1 投票 1

如何将上一步的Mono <>结果传递到下一个doOnSuccess（）方法

假设我有一个方法addVoteToSong，例如：public Mono > addVoteToSong（PrincipalPrincipal，String songId，VoteKind表决者）{return ...

java spring spring-webflux project-reactor

回答 1 投票 0

具有ParallelFlux的WebClient，每个REST请求被调用两次

我想与WebClient同时调用独立请求。我之前使用RestTemplate的方法是在等待响应时阻塞线程。所以我想出了，带有...

java spring-webflux project-reactor spring-webclient

回答 1 投票 0

发布不同对象类型的FluxSink

我有一个通过流量响应的rsocket端点：@MessageMapping（“ responses”）Flux> deal（@Payload String message）{return myService.generateResponses（message）; }响应可以...

project-reactor rsocket

回答 1 投票 0

是否提供通量来表示事件而没有具体值？

如何设置带有Reactor项目的流/发布器，该项目会随着时间的推移发出事件，但没有任何具体的值。我想到了Flux ，但文档中提到Flux

java project-reactor reactive-streams

回答 1 投票 1

WebFlux：为什么需要在CRUD中使用flatMap

我在Internet上找到了示例，但这并不能完全理解我。使用WebFlux时使用标准CRUD。路由器：@Configuration公共类PersonRouter {@Bean公共...

crud spring-webflux project-reactor reactor spring5

回答 1 投票 0

如何使用Reactor-netty TcpClient链接多个发送和接收操作

我需要在由顺序发送->接收->发送->接收并返回最后一个接收值的TCP连接中执行自定义握手，但是我在链接执行时遇到问题。...]]

java reactive-programming project-reactor reactor-netty

回答 1 投票 2

如何在Spring 5 MVC中将FilePart转换为byte []

我有一个控制器方法，该方法从Web表单接收并上传文件。如何从FilePart中提取字节数组并将其保存到DB？我可以通过以下方法将FilePart保存到文件中：...

java spring spring-mvc project-reactor reactor

回答 2 投票 0

使用cassandra反应存储库的数据库更改集

我正在尝试使用projectreactor和ReactiveCassandraRepository在2个cassandra表中执行一些混合逻辑。表格看起来像这样：1）userId（pk）| hashId 2）hashIf（pk）|当我...

cassandra spring-data project-reactor spring-data-cassandra

回答 2 投票 1

如何验证在项目反应器中使用StepVerifier引发的异常

def ExpectError（）{StepVerifier.create（readDB（））.expectError（RuntimeException.class）.verify（）; }私人Mono readDB（）{// ...

spring-webflux project-reactor reactive

回答 1 投票 0

Reactor WebFlux：帮助您了解如何使用flatMap（）

[请帮助理解如何在示例中使用fkatMap（）：Flux.just（“ 1,2,3”，“ 4,5,6”）.flatMap（//做某事）.collect（Collectors .toList（））...

java spring-webflux project-reactor reactor

回答 1 投票 0

Spring Boot和Reactor-netty https多个域

我正在尝试配置Spring Cloud网关（在Reactor项目的顶部），以便在两个域之间提供HTTPS服务。但是，似乎无法使用SNI为...选择正确的证书...

spring-boot ssl netty project-reactor

回答 1 投票 0

对项目反应堆中通量中除第一个元素以外的所有元素进行采样

在项目反应堆通量中，有一个示例方法Flux＃sample java doc。它会改变通量，使其仅在指定时间段的末尾发出事件。是否可以调整此行为，然后...

java reactive-programming project-reactor

回答 1 投票 0

在TimeoutMainSubscriber的情况下将Reactor上下文复制到MDC

我一直在关注https://github.com/archie-swif/webflux-mdc/blob/master/src/main/java/com/example/webfluxmdc/MdcContextLifter.java中的代码，以从Reactor Context中放入数据使用钩子连接到MDC。 ...

java spring-webflux project-reactor mdc

回答 1 投票 0

处理来自发布者的同等消耗的数据

如何处理从Publisher并行订阅的数据？我是否应该在一群工人中循环订阅？当我在Project Reactor中调用subscription时，我仅获得了一大块数据。如何“排干所有”？ ...

java rx-java project-reactor reactive-streams

回答 1 投票 0

Reactor-如何使用filterWhen，并且如果未通过过滤器，该值是否仍用于记录目的？

我正在尝试找出执行以下操作的正确方法。我想按名称检查记录是否存在于数据库中，这是一个全局二级索引。（假设主键是id）。如果有...

kotlin project-reactor reactor

回答 1 投票 0

是否可以从Reactor Flux或RxJava2 Observable / Flowable到AkkaStreams源使用适配器？

有时有一些库，例如R2DBC，它返回一个Reactive Stream，即Reactor Flux，但是在Http层中，我们需要另一个Reactive Stream，即AkkaStreams Source，它是AkkaHttp ...

akka rx-java project-reactor akka-stream reactor

回答 1 投票 0

如何在Spring WebFlux中配置背压？

我试图了解如何在Spring WebFlux中施加反压。我了解背压的理论，但无法重现，所以我并不完全了解它。让我们看下面的...

java reactive-programming spring-webflux project-reactor backpressure

回答 1 投票 0

project-reactor 相关问题

最新问题