腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
告诉
Flux
在
异步
处理
后
发出
下一
项
spring-webflux
、
project-reactor
我正在使用Project Reactor和Webflux来尝试从消息队列中读取数据,然后分块
处理
(例如,一次
处理
五个),并对每个块向API
发出
请求。API
在
高吞吐量的情况下不能很好地工作,因此我需要控制并发发送多少请求。 基本上,我希望有一个WebClient调用finish,然后能够
告诉
Flux
我们已经准备好
处理
更多。requestbefore request
浏览 39
提问于2021-07-30
得票数 0
1
回答
项目反应堆中的flatMap、flatMapSequential和concatMap有什么区别?
spring-webflux
、
project-reactor
、
reactor
、
reactive-streams
我从文档中读到flatMap
异步
地将由该
Flux
发出
的元素转换为Publishers,然后将这些内部发布者压平为单个
Flux
,但按照源元素的顺序合并它们。而那个concatMap
异步
地将由该
Flux
发出
的元素转换为Publishers,然后将这些内部发布者
浏览 11
提问于2022-04-22
得票数 4
回答已采纳
1
回答
用弹簧数据弹性存储记录流量的反应性研究
elasticsearch
、
reactive-programming
、
spring-data-elasticsearch
对我来说,我有着巨大的情感流动:如何使用反应方式保存所有与弹性搜索相关的流量?以及如何阻止,直到最后一个实体
在
流动将被
处理
?
浏览 4
提问于2020-07-09
得票数 0
回答已采纳
5
回答
如何使用反应堆的通量来实现心跳式功能?
java
、
reactive-programming
、
project-reactor
假设有一个
Flux
发出
了一些有效负载: .delayElements(Duration.ofSeconds任务是将另一个信号混合到这个
Flux
中。另一个信号每隔N个时间单位就会
发出
某种信号。而且,生成的
Flux
必须在payloads
Flux
完成
后
立即完成。 它应该传播两个Fluxes中任何一个
发出
的错
浏览 15
提问于2020-10-11
得票数 0
3
回答
良好的实现/支持java.util.concurrent.Flow.Processor<T,R>
reactive-programming
、
java-9
、
project-reactor
、
reactive-streams
、
java-flow
最近,我发现projectreactor.io很好地支持Publisher: for (int i = 0; i < 10; i更新1: import org.jsoup.Jsoup;
Flux
浏览 10
提问于2017-11-17
得票数 3
回答已采纳
1
回答
Rx Java 2同步与
异步
rx-java2
我知道同步和
异步
的类型,其中可观察对象可以
在
主线程或由subscribeOn (可能是observeOn)指定的后台线程上
处理
。这个案例很清楚。哪些运算符是
异步
的?只有merge和flatMap? 当链中的所有运算符都是同步的时,是否必须使用整个链
处理
已
发出
的
项
,然后才能
处理
下一
个
项
?
浏览 3
提问于2017-09-17
得票数 0
2
回答
春季网络流量中Mono<List<T>>与
Flux
<T>的差异
spring-webflux
、
reactor
我的理解是,Mono<List<T>>是一个同步的
Flux
<T>,而
Flux
不能是rest响应。 我说的对吗?如果不是,Mono<List<T>>和
Flux
<T>之间有什么不同,或者
在
某些地方,
Flux
可以是rest响应?
浏览 3
提问于2018-10-22
得票数 15
回答已采纳
1
回答
等待ParallelFlux完成
java
、
reactive-programming
、
spring-webflux
、
project-reactor
、
reactor
TL;DR -我无法获得输出此代码的结果: .parallel() .runOn(Schedulers.elastic())
浏览 5
提问于2020-03-23
得票数 8
回答已采纳
2
回答
反应堆工程中的条件并行性
parallel-processing
、
spring-webflux
、
project-reactor
在
流中,必须根据特定字段并行解析消息。 void testParallel() {
Flux
.just(new Order(1,1)
浏览 9
提问于2022-05-28
得票数 0
3
回答
java中的多个
异步
请求
处理
java
、
android
、
multithreading
、
asynchronous
这个站点提供了一些SDK来
处理
这个api。我用它向网站提出了一些要求。,所以如果我
发出
单个请求,一切都很好:我可以
在
onComplete方法中
处理
它。但是,如果我需要
发出
多个请求,而且
下一
个请求取决于先前的响应,该怎么办?我只看到两种方式,两种方式看起来都很糟糕: 1.
在
onComplete方法中
发出
每个
下一
个请求。这似乎是过于嵌套和僵化的做法。2.进行某种同步操作:主线程执行请求
后
,以某种方式检查onComplet
浏览 6
提问于2014-10-25
得票数 0
回答已采纳
5
回答
反应性流中的单通量与单通量
reactive-programming
、
project-reactor
、
reactive-streams
根据文件: 或者,当只需要使用Mono而
Flux
无法
处理
操作时,会有一些特定的条件?请建
浏览 6
提问于2017-12-27
得票数 73
回答已采纳
1
回答
WebFlux:为什么我需要在CRUD中使用flatMap
crud
、
spring-webflux
、
project-reactor
、
reactor
、
spring5
标准CRUD
在
使用WebFlux.时@Configuration public RouterFunctionAllArgsConstructor return personRepository.fin
浏览 1
提问于2020-02-23
得票数 0
1
回答
我如何才能获得最后一
项
Flux
,而不使用reduce()或with ()来折叠它
java
、
project-reactor
、
reactive-streams
如何才能获得最后一
项
Flux
,而不使用reduce()或with ()将其折叠?这是我的用例:
Flux
<Integer> inner =
F
浏览 3
提问于2019-11-03
得票数 2
回答已采纳
2
回答
使用http调用重载Java反应堆->服务
java
、
mono
、
reactive-programming
、
spring-webflux
、
flux
onErrorResume(e -> Mono.empty())我需要给该服务打数万次电话,所以我在这里调用上面的方法:return
Flux
.fromStream(securities.stream()) .flatMap(s ->
浏览 3
提问于2021-12-30
得票数 -1
1
回答
项目反应器-合并两个发布者状态并
发出
结果
java
、
kotlin
、
reactive-programming
、
project-reactor
我想设计一个带有反应器的
处理
流水线,如下所示。 .concatMap {
Flux
.ju
浏览 1
提问于2019-05-30
得票数 1
2
回答
作为rest控制器的返回类型,ResponseEntity<Mono>和Mono<ResponseEntity>的区别是什么?
spring
、
mono
、
response
、
spring-webflux
、
flux
在
Spring中,ResponseEntity和Mono作为rest控制器的返回类型有什么区别? 什么时候最适合什么?在这个问题上,假设我需要返回一个列表,或者说Foo的几个元素,有很多返回
Flux
的例子。返回ResponseEntity或
Flux
是否有意义?
浏览 0
提问于2019-09-03
得票数 21
1
回答
可以
在
Django应用程序中执行
异步
/并行数据库查询吗?
mysql
、
django
、
postgresql
、
asynchronous
、
nonblocking
通常,
在
发出
查询
后
,Django线程/进程会被阻塞,等待返回结果,然后继续执行,直到到达
下一
个查询。 有没有办法
异步
发出
所有查询,以便数据库服务器可以并行
处理
这些查询?例如,我听说Postgresql有一个
异步
客户端库-在这种情况下我该如何使用它?
浏览 2
提问于2010-02-12
得票数 20
1
回答
使用ajax承诺加超时吗?
javascript
、
jquery
、
ajax
、
promise
、
requestanimationframe
我正在编写一个脚本,它
发出
一个
异步
调用来获取一组数组数据(大约50,000
项
),使用请求动画框架()进行多次迭代,然后再进行另一次调用,并多次遍历这些结果。我希望
在
完成与前一批的循环之后,尽快开始迭代来自后续调用的数据。我想要的是
在
第一批正在
处理
时为
下一
批进行
异步
调用,然后
在
调用返回和2)请求动画框架()迭代完成
后
立即开始
处理
下一
批。如果我
在
等待2个ajax调用,
浏览 2
提问于2017-04-07
得票数 0
回答已采纳
2
回答
如何根据
发出
的事件有条件地缓冲分组可观测/流?
java
、
rx-java
、
reactive-programming
、
rx-java2
、
project-reactor
假设具有给定ID的提交总是
在
同一个ID的一个或多个意图之前,当接收到意图时,应按其ID分组,并打开该组的“缓冲区”。当接收到同一组的提交或已配置的超时过期时,缓冲区应“关闭”。应
发出
产生的缓冲区。请注意,
在
收到结束提交之前,可以接收多个意图。(编辑:) bufferDuration应该保证,任何“打开的”缓冲区都是
在
bufferDuration时间结束
后
发出
的,因为打开缓冲区的意图已经收到,不管是否提交。<EntityEvent> groupFlux) { r
浏览 2
提问于2017-05-12
得票数 3
回答已采纳
3
回答
为什么Thread.sleep()会触发对
Flux
.interval()的订阅?
project-reactor
如果在main()方法中,我执行以下操作 .log()我
在
控制台上看到这个:[ INFO] (main) | onNext(2)如果我没有使用just(),而是使用了interval()方法:
Flux
.interval
浏览 8
提问于2020-05-13
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Reactive Spring实战 -- 理解Reactor的设计与实现
Spring Boot 中的响应式编程和 WebFlux 入门
Springboot2.0中webflux到底优秀在哪里
【iOS】MVC、Flux、Redux在iOS中的使用
Spring Boot 2.0-WebFlux framework
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券