reactor 相关问题

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

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

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

crud spring-webflux project-reactor reactor spring5

回答 1 投票 0

如何在MongoDB中的多个表之间指定@CollectionTable关系？

我有一个用SpringBoot 2编写的项目和一个MySQL数据库，我正在尝试使用MongoDB将其重写为Spring WebFlux。有2个表：CONTRACT和CONTRACT_CONTRACTOR。事实是...

java mongodb spring-boot spring-webflux reactor

回答 1 投票 0

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

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

java spring spring-mvc project-reactor reactor

回答 2 投票 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

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

使用Flux.interval代替@Scheduled在春季启动中

我正在使用Spring Webflux构建Spring Boot应用程序，并且我希望使该应用程序完全不阻塞。应用程序本身具有一些REST端点和需要运行的批处理作业...

spring-webflux reactor

回答 1 投票 0

两个通量之差

我有两个通量，顺序不重要，我想得到一个有差的结果通量。我怎样才能做到这一点？示例：Flux remoteTweets = Flux.just（new Tweet（“ ...

spring-webflux flux reactor

回答 1 投票 0

r.netty.http.client.HttpClientConnect连接观察到错误

我有一个在spring框架中创建WebClient实例的方法。创建WebClient实例并进行呼叫时，出现以下错误：2020-01-19 00:28:17 ....

spring netty webclient reactive reactor

回答 1 投票 0

Reactor Spring处理异常

我正在使用Reactor 2和Spring4。这是我拥有的典型代码-使用仓库的使用者@Consumer公共类ApplicationService {@Selector（value =“ / applications / id”，键入...

java spring spring-mvc reactor project-reactor

回答 2 投票 6

带通量的单声道组合

我想创建一个结合了两个反应性来源的结果的服务。一个正在生产Mono，另一个正在生产Flux。对于合并，我需要为每个发射的通量使用相同的mono值。 ...

java project-reactor reactor

回答 2 投票 0

OverflowStrategy是否未考虑？

我创建了一个Flux，该Flux不断追求新的整数值。我有一个在其自己的线程（.publishOn（single（）））中运行的订阅服务器。无论我使用哪种策略（最新或其他），我总会得到...

java reactive reactor

回答 1 投票 0

如何用webclient替换resttemplate实现

我正在尝试用一个webclient替换一个resttemplate实现。这里棘手的事情是，当响应解析时，我需要从输入对象修改属性。我找不到...

spring webclient resttemplate reactor

回答 1 投票 0

如何使用反应性单声道环绕一系列非阻塞操作？

我有一组非阻塞操作，它们可以启动一个操作，检查它是否完成并获得结果。问题是start和getResult不会立即一起发生，...

spring spring-boot mono reactive-programming reactor

回答 1 投票 1

助焊剂（或类似物），如果空的助焊剂

[如果通量为空，如何调用方法（使用者），例如，如果通量为空，我想记录消息

spring-boot flux reactive reactor

回答 2 投票 0

如何通过Flux用不同的调度程序运行两个任务

我尝试使用两种策略（串行和并行）存储和解析并存储一些原始数据。Flux f = Flux.create（sink-> dataRepo.addConsumer（sink :: next）））; Flux.from（f）....

spring flux reactor

回答 1 投票 0

如何在不丢失数据的情况下与其他发布者建立反应性管道？

想象您有这样的代码：public List addUserToGroups（String username，String label）{Mono userMono = webClient.getUser（username）;用户user = userMono.block（）; ... ] >>

java reactive-programming project-reactor reactor

回答 1 投票 0

Reactor-加载分页API的所有页面

我想知道Reactor和分页的HTTP API。我有一个私人有趣的getPage（pageNumber：Int）：Mono 。该资源具有“ numberOfPages”字段，我想获取...

kotlin project-reactor reactor

回答 1 投票 1

反应堆伪装不能反序列化通量响应

我有以下控制器@RestController public void MyController {@GetMapping（“ / foo”）public Flux getFoos（）{/ *返回Foos的流量* /}}和Feign客户public ...

json spring-webflux reactor feign

回答 1 投票 0

GEKKO分批补料生物反应器的ODE方程的不可行系统

我对GEKKO以及对生物反应器建模都是新手，所以我可能缺少明显的东西。我有一个由10个ODE组成的系统，用于描述补料分批生物反应器。给出了所有常数。图片...

python bioinformatics ode reactor gekko

回答 2 投票 5

reactor 相关问题

最新问题