reactor 相关问题

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

如何创建被动“中间用户”?如何结合所有Flux 零件和加工结果进一步链(转换为Mono )?

我正在使用spring webflux + mongodb-reactive将二进制文件(图像)保存到Mongo DB。不幸的是spring-boot-starter-data-mongodb-reactive:2.0.5.RELEASE不支持反应...

回答 1 投票 1

如何使用.net_reactor?

有人之前使用过.net_reactor来保护代码吗?我已经保护可执行程序集但不知何故没有许可证文件,我仍然设法运行可执行文件Tried示例项目,...

回答 1 投票 0

保持原始排序,创建单声道数组对象

我需要实现返回Mono <Array <ProcessedObject >>的函数。作为参数,它接受对象列表并使用返回Mono <ProcessedObject>的函数处理它们。功能......

回答 1 投票 0

Project reactor:flatMap之后的onErrorResume

Flux.just(“a”,“b”)。flatMap(s - > s.equals(“a”)?Mono.error(new RuntimeException():Flux.just(s +“1”,s +“2) “))。onErrorResume(throwable - > Mono.empty()).subscribe(...

回答 2 投票 0

如何在基于弹簧的响应式应用程序中从身份验证中排除路径?

在非反应式spring应用程序中,我通常会创建一个配置类,扩展WebSecurityConfigurerAdapter并配置WebSecurity,如:@Override public void configure(...

回答 1 投票 1

Reactor 3 - 如何在Mono Error上返回Flux?

这是样板代码:我想做这样的事情 - 公共Flux getSomething(String email){method1(email).map(result - > {// method1返回Mono ...

回答 2 投票 2

如何限制活动的Spring WebClient调用的数量

我有一个要求,我使用Spring Batch从SQL DB中读取一堆行(数千),并在将其写入Kafka主题之前调用REST服务来丰富内容。使用Spring时......

回答 1 投票 3

© www.soinside.com 2019 - 2024. All rights reserved.