腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Spring
Reactor
Mono
在
返回
数据
之前
等待
订阅
者
完成
其
任务
java
、
spring
、
spring-boot
、
spring-webflux
我正在尝试使用
Spring
reactor
webclient执行多个HTTP调用,该the客户端
返回
Mono
。我使用
Mono
.block()
等待
所有monos
完成
。这并不是等到subscribe()
完成
。new User();
Mono
<Address> address = WebClientUtil.
mono</
浏览 186
提问于2021-08-10
得票数 1
回答已采纳
2
回答
如何在Project
Reactor
中将一个单声道多播到多个
订阅
者
?
java
、
reactive-programming
、
project-reactor
、
reactive-streams
根据我到目前为止所读到的内容,可以使用ConnectableFlux将Flux多播到多个
订阅
者
,方法类似于以下内容:根据我对反应流的有限理解,上面的代码将冷发布
者
转换为热发布
者
我正在处理一个
Mono
有多个
订阅
者
的场景。我怎样才能从
Mo
浏览 14
提问于2021-10-21
得票数 1
1
回答
Flux.subscribe
在
处理的最后一个元素
之前
完成
spring
、
webclient
、
flux
、
reactor
,并在结果准备就绪后立即向我发送结果,而不是
等待
所有事情都
完成
,主要是为了避免将所有内容先保存在服务器的内存中,然后保存在客户端的内存中。<Void>
mono
=
Mono
.when(alerts);log.debug("All done in method"); 这是我
在
日志中得到的: 2019-07-03.4 : onComplete() 请注意,
在
mono
.blo
浏览 277
提问于2019-07-03
得票数 0
1
回答
Springboot Webclient引发读取超时错误
spring-boot
、
spring-webflux
如果我缺少任何配置,请告诉我:public WebClient webClient() {} return handleResponse(clientResponse)
浏览 0
提问于2018-12-14
得票数 4
回答已采纳
1
回答
主线程没有
等待
订阅
者
在
reactive subscriber中
完成
其
任务
java
、
spring
、
multithreading
、
spring-webflux
、
project-reactor
我
在
spring
中有一个服务,它需要使用十种不同的方法来获取
数据
。 我想让这些方法并行执行一些DB操作,然后
返回
到父线程。但是父线程应该
等待
,直到所有的响应到来,然后
返回
一个响应。
在
我目前的方法中,我使用反应式
mono
异步执行所有方法,但主线程并不
等待
subscriber方法
完成
。下面是我
订阅
的两个方法 private
Mono
<BaseResponse> getPro
浏览 13
提问于2020-01-09
得票数 1
回答已采纳
1
回答
如何
等待
订阅
完成
?
java
、
project-reactor
、
spring-webclient
我想发出一个异步rest调用,我正在使用
spring
并
返回
一个
Mono
。我还在并行地执行一些
数据
库调用,但由于某种原因,无法进行反应性调用。Map<String, Object> models = new HashMap<>(); users.mapfor users.subscribe to finish <<<<<<<<<
浏览 1
提问于2019-06-03
得票数 4
回答已采纳
2
回答
使用db调用的
Mono
<String>用org.slf4j.Logger记录编码密码(Bcrypt)
java
、
spring
、
spring-boot
、
spring-security
、
spring-webflux
我试图弄清楚如何用
Mono
<String>记录slf4j密码,但它总是
返回
一个Monotype。-3".subscribe(x -> System.out.println( x.toString())) 为了获得一些输出,但是我如何才能只使用记录器密码
在
ofc
之前
被正确地存储和编码(Bycrypt) (似乎不是问题)。( "userinputPW&quo
浏览 4
提问于2022-01-26
得票数 1
回答已采纳
1
回答
RabbitMQ
在
消费过程中阻止其他消费
者
rabbitmq
、
rabbitmq-exchange
在
将下一个
任务
/消息/项发送到另一个使用
者
之前
,队列是否有方法
等待
任务
/消息/项
在
处理过程中
完成
?这就是我想要
完成
的场景: 当发布
者
将
任务
添加到‘task’时,队列会向
任务
发送(或其中一个使用
者</e
浏览 1
提问于2018-06-18
得票数 1
1
回答
Spring
Flux
Reactor
异步使用
者
已
完成
spring-webflux
、
project-reactor
我正在调查
Spring
Reactor
flow是如何工作的,并且有一些无法处理的场景。我想在
Mono
完成
并准备
返回
结果时执行异步操作,所以我不再阻塞请求线程。我不关心exeption或异步操作的结果,那就是消费
者
。在下面的示例中,我希望
在
返回
结果后以异步方式进行图像处理:return
Mono
.fromF
浏览 1
提问于2020-12-02
得票数 0
1
回答
了解
Spring
Webflux/反应式端点
spring
、
kotlin
、
spring-webflux
我试图理解
Spring
中的反应式端点,但这让我感到困惑。someItems, )}压缩后
浏览 8
提问于2019-03-25
得票数 2
1
回答
如何在
Spring
Reactor
中的
Mono
或FLux的flatMap或flatMapMany的主体中包含多个语句?
spring
、
project-reactor
我有以下代码: return
Mono
.just("fragments/propertyfrag"); elsereturn
Mono
.just("property")
浏览 3
提问于2018-04-20
得票数 0
1
回答
使用RxJava3Adapter
返回
RxJava Single时,无法
在
WebFlux控制器中检索主体。你能解释一下是什么破坏了反应堆链吗?
java
、
rx-java
、
spring-webflux
、
project-reactor
我的WebFlux控制器: import
reactor
.adapter.rxjava.RxJava3Adapter;import("no principal"))); } 在上面的代码中,getMono
返回
主体的名称,而getSingle
返回
“无主体”。我
在
试着理解为什么。这可能与RxJava3Adapter有关。我不确定它是不是把反应堆发布
者
变成了一个“热门”的发
浏览 23
提问于2021-04-25
得票数 0
回答已采纳
1
回答
反应式编程.未正确运行的网络流量网络过滤器
java
、
reactive-programming
、
spring-webflux
、
project-reactor
的
Mono
,我需要csrf令牌和
Spring
会话凭据。方法
Mono
值
返回
一个TRUE,如果我错了,请更正),但是会出现‘onComplete()日志’。我不知道onComplete()日志到底意味着什么,因为它是
在
执行getRequestExchange方法(被调用)
之前
显示的。
Mono
.just(s.equals(""))代码段从不执行。我读过很多关于“
在
订阅
之前
什么都不会发生”的文章,但是如果
浏览 6
提问于2021-10-27
得票数 0
回答已采纳
1
回答
合并两个
Mono
并得到一个Flux。然后从那个通量中提取出一个
Mono
mono
、
spring-webflux
、
project-reactor
、
flux
、
reactor
我有2
Mono
<T>,这是从那里得到的,有两个不同的来源,比如KAFKA。然后
在
public final
Mono
<T> reduce(BiFunction<T,T,T> aggregator)中使用Flux方法来创建最终的
Mono
(因为上述两个
Mono
的响应时间可能有所不同2
在
contact上使用的方法有很多,如zip、zipWith、Flux。如何得
浏览 5
提问于2021-05-09
得票数 1
1
回答
带参数的Java调用void方法
java
、
reactive-programming
、
spring-webflux
.flatMap(user -> { return
Mono
.just
浏览 3
提问于2022-09-06
得票数 -1
2
回答
与反应流一起发出
java
、
spring
、
spring-boot
、
spring-webflux
.1 - onNext(Received: INIT)INFO
reactor
.Flux.Map.1 - onNext(Received: 2)INFO
reactor
.Flux.Map.1 - onNext(Received据我所知,我使用thenMany的方式应该是
在
每次将前面的内容标记为complete()时生成一
浏览 0
提问于2020-01-19
得票数 2
回答已采纳
1
回答
flatMap输出上的电抗器调用阻塞导致ClassCastException
spring-data
、
project-reactor
我使用的是
Spring
Boot 2.0.0.M7和Project
Reactor
。我的问题与编写单元测试时遇到的一些奇怪行为有关。
在
尝试将flatMap的输出提供给存储库时,我也遇到了这个问题。into Foo domain Entity })由于flatMap的
返回
值,这个闭包应该发出一个
Mono
<Foo>。但是,当调用block()进行
订阅
并获取结果Foo时,FluxFlatMap.trySubscribe
浏览 28
提问于2017-12-27
得票数 0
回答已采纳
1
回答
超时后不
返回
RestController上的响应,而是
等待
整个执行。
spring-webflux
、
project-reactor
org.springframework.web.bind.annotation.GetMapping;import
reactor
.core.publisher.
Mono
") return
Mono
.fromCallable(() -> { Thread
浏览 4
提问于2022-11-05
得票数 1
1
回答
反应堆Java单元测试模拟依赖项
返回
值的顺序
java
、
junit
、
mockito
、
mono
、
project-reactor
当设置一个模拟依赖项以
返回
两个不同的值时,我试图理解为什么简单的单元测试失败。此依赖项
在
正在测试的主类中被调用两次。我使用flatmap和then是有原因的,因为我希望
在
第二个
Mono
之前
完成
第一个
Mono
。这方面的一个例子可能是将
数据
写入
数据
库,然后从同一链中的
数据
库读取
数据
。]
reactor
.
Mono
.FlatMap.1
浏览 2
提问于2022-05-05
得票数 0
1
回答
弹簧反应器中嵌套条件的处理
java
、
reactive-programming
、
spring-webflux
、
project-reactor
Mono
<Boolean> isRegistered(Student std);
Mono
<Boolean> isAvailable(Student std); 我想要一个逻辑,如果任何检查
返回
如下所示的false,它将停止流并抛出错误:
Mono
<Boolean> checkAll2个para
浏览 1
提问于2022-10-13
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Boot 中的响应式编程和 WebFlux 入门
Kotlin Coroutine 是如何与 Spring WebFlux 整合的
Spring Boot 2.0的新特性解读
编程介绍-框架spring使用
Spring Boot 2.0-WebFlux framework
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券