reactor 相关问题

反应器设计模式是用于处理通过一个或多个输入同时传递给服务处理器的服务请求的事件处理模式。服务处理程序解复用传入的请求，并将它们同步分派给关联的请求处理程序。

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

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

java project-reactor flux reactor autocloseable

回答 1 投票 0

如何使用Webflux异步将一个对象放入S3？

一篇名为《AWS S3 with Java - Reactive》的文章介绍了如何在Webflux中使用AWS SDK 2.0客户端。在这个例子中，他们使用以下处理程序上传到S3，然后返回一个HTTP创建的响应。...

java amazon-web-services amazon-s3 spring-webflux reactor

回答 1 投票 0

WebFlux控制器返回流量和背压

在Spring WebFlux中，我有一个与此类似的控制器：@RestController @RequestMapping（“ / data”）公共类DataController {@GetMapping（produces = MediaType.APPLICATION_JSON_VALUE）public Flux＆...] >>> [[

spring-webflux reactor

回答 1 投票 2

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

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

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

回答 1 投票 0

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

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

spring-webflux project-reactor reactor spring-webclient

回答 2 投票 0

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

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

java spring-webflux project-reactor reactor

回答 1 投票 0

Mono 和Mono.empty（）有何不同

据我的理解，在Spring WebFlux反应器中，Mono 表示一个void Mono.empty（）表示void，因为对其进行任何调用都会得到一个空指针。这些如何站立...

java spring reactive-programming spring-webflux reactor

回答 1 投票 0

WebClient交换列表上的Flux collectList（）始终为空

我正在尝试使用WebClient执行列表请求，然后对其进行过滤以找到第一个成功的列表请求（如果有）并返回。或者，如果未成功返回默认响应。问题我'...

spring-webflux project-reactor reactor

回答 1 投票 0

收集贴图来自Flux

我遇到一个奇怪的问题。我知道我已经接近解决方案，但无法解决。我有一个Flux ，它被过滤并映射到Flux 。 ...

java spring-boot spring-webflux project-reactor reactor

回答 1 投票 -1

总会调用switchIfEmpty

我有这样的方法：fun getActiveVersionWithCacheMiss（type：String）：Mono {返回activeVersionRepository.findByType（type）.switchIfEmpty（...

kotlin reactive-programming reactor

回答 1 投票 0

我如何使用Mono 作为调用第二个方法的条件

我正在尝试以迭代方式从另一服务检查条件之后调用一个服务，如果（productService.isProductNotExcluded（product））{List {

spring-webflux reactor

回答 2 投票 0

控制对Mono执行重复任务的延迟

我正在尝试实施轮询机制。我想根据某些条件来增加或减少轮询间隔。我正在将Mono.repeat与delayElements一起使用来执行重复...

spring-boot project-reactor reactor

回答 1 投票 0

有一种方法可以等待webflux代码中的异步方法结果

我使用Spring webflux以Intellij的思想进行开发，现在我遇到的一个问题是，在我的方法中，我需要从反应性mongo获取ip（String），然后再转发请求。因此，我编写了此代码。 ..

java spring-webflux reactor

回答 1 投票 0

Spring Boot Controller返回一个scala.concurrent.Future的Mono

我正在Spring Boot应用程序中运行Akka actor系统。我有一组演员在跑步。从我的Controller类中，我调用我的服务类，该类使用Actor询问模式，发送一个...

java spring scala akka reactor

回答 1 投票 0

等待ParallelFlux完成

我创建了ParallelFlux，然后使用.sequential（），期望在那时我可以计算或“减少”并行计算的结果。问题似乎是并行线程...

java reactive-programming spring-webflux project-reactor reactor

回答 1 投票 0

如何将GroupBy结果列表添加到Webflux中的新Map

如何在Webflux中将GroupBy结果列表制作到新Map，这是我的输入列表和期望结果。那我该怎么做才能得到结果。 //期望{“ timestamp”：“ 2019-06-13T00：00：00.000”，“ ...

kotlin flux reactor

回答 1 投票 0

Java反应器-链Mono ，还有另一个异步任务产生Mono

我有以下异步任务：公共类AsyncValidationTask {//如果出错则返回Mono.error（new Exception（）），否则返回Mono.empty（）public Mono execute（Object o）; } public ...

java reactive-programming reactor

回答 1 投票 0

Spring WebClient-如何处理错误情况

作为Spring 5.1.9的一部分，我们将org.springframework.web.reactive.function.client.WebClient与reactor.netty.http.client.HttpClient一起使用，以使用exchange（）方法发出请求。文档...

java spring reactor spring-webclient

回答 1 投票 1

Reactor spring mongodb存储库将多个结果组合在一起

我是反应式编程的新手，目前正在研究基于Spring Webflux的应用程序。我陷入了几个问题。公共类FooServiceImpl {@Autowired私有FooDao fooDao; @ ...

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

回答 1 投票 0

WebFlux + RSocket + Spring

spring-webflux serversocket reactor rsocket rsocket-java

回答 1 投票 0

reactor 相关问题

最新问题