1回答
我是Reactor框架的新手，并试图在我们现有的一个实现中使用它。LocationProfileService和InventoryService都返回一个单声道，并且是并行执行的，并且彼此之间没有依赖关系(从MainService)。我看到调用是按顺序执行的，而其中一些应该是并行执行的。什么才是正确的方法呢？()).log();
Mono<Result<LocationPricing>> locationPricingMo
浏览 73提问于2019-01-21得票数 2
回答已采纳
org.springframework.web.bind.annotation.GetMapping;import reactor.core.publisher.Mono") return Mono.fromCallable(() -> {
Thread
浏览 4提问于2022-11-05得票数 1
2回答
我的方法应该在执行confirm方法后返回结果或错误消息，然后执行一些后台工作。我写了类似于上面的东西，但是我不确定在then中调用的方法。我错了吗？public Mono<Void> someMethod(...){
return someReactiveApiClient.confirm().onErrorMap(...).then(
浏览 2提问于2020-07-29得票数 3
回答已采纳
我看到我使用Mono创建的方法是在parallel-1线程上执行的，但是我看到了这个actor-tcp-nio-1，Mono的方法在其中执行。这个线程是什么？为什么它不在并行-1线程上执行。控制台日志 2021-04-04 23:27:04.356 INFO 7225 --- [ parallel-1] reactor.Flux.UsingWhen.1onSubscribe(FluxUsingWhen.UsingWhenSubscriber)
2021-04-
浏览 111提问于2021-04-05得票数 0
1回答
因此，我想使用Flux来运行每个Mono任务，并将每个任务等待2秒。$LoggerFactory - Using Slf4j logging framework01:58:21.473 [Test worker] INFO reactor.Mono.Just.1 - | onNext(1)
Number: 1[T
浏览 6提问于2022-04-27得票数 0
我正在处理一个Mono有多个订阅者的场景。我怎样才能从Mono中获得一个热门的出版商呢？
浏览 14提问于2021-10-21得票数 1
我在spring boot中有一个方法，可以进行多个mono调用，返回一个类型字符串。此方法最终将返回所有mono调用的结果，稍后将其转换为POJO对象。我尝试过Mono.zip，但它只接受8个元组。有没有更好的解决方案？例如： Mono<String> mono1 = <Web client call>Mono<Str
浏览 35提问于2021-09-02得票数 0
1回答
下面是正在测试的主要类：在记录反应性执行时Test worker] reactor.Mono.IgnoreThen.2
浏览 2提问于2022-05-05得票数 0
我正在尝试使用Mono.delay测试StepVerifier。我的代码如下：at reactor.core.publisher.MonoDelay.subscribe(MonoDelay.java:59)
at reactor.test.DefaultStepVerif
浏览 2提问于2016-12-27得票数 1
回答已采纳
downloadedImage;
}class ImageResizeService {
Mono<List<ImageResizeResult> resize(ImageResizeRequest request)
浏览 0提问于2018-08-27得票数 0
json.dumps({"count": row}) + '\n' .log();Mono<Void>
浏览 277提问于2019-07-03得票数 0
).andRoute(POST("/").and(contentType(APPLICATION_JSON)), handler::createPerson));}.jar:5.0.0.RELEASE]
at reactor.core.publisher.Mono.lambda$onErrorMap$19(Mono.
浏览 0提问于2017-10-23得票数 5
我希望服务器的所有调用都将并行处理，但事实并非如此。下面是简单的例子。在服务器日志中，我们可以看到请求是顺序执行的，而不是并行执行的。为什么我们在10秒后而不是5秒后收到了第一个响应？，如果我希望并行处理所有请求，如何正确创建服务器？如果我将Mono.fromCallable替换为Mono.fromFuture(CompletableFuture.supplyAsync(() -> myBusinessLogic(), execut
浏览 4提问于2021-07-16得票数 2
回答已采纳
this.greetingService = greetingService; public MonoCircuitBreaker circuitBreaker = CircuitBreaker.ofDefaults("greetingService");
Callable<Mono<String>> callable = CircuitBreaker.decorateCallab
浏览 47提问于2021-06-29得票数 1
我想为每个队列元素执行http请求。这些请求应该并行调用。 List<Mono<MyResponseDTO>> monoList = queue.stream() //await when all MONOs are completed
log.info("Start waiting fo
浏览 7提问于2019-11-20得票数 2
userService + postService + userRepo)；以下是上述情况的代码：当前工作状态：不工作； public Mono++ postService )的中的三种“删除方法”
找到溶液
public <e
浏览 5提问于2021-06-09得票数 0
1回答
我有一个芹菜任务，当被调用时，它只是在扭曲的反应器中点燃了一些并行代码的执行。()
def run_task(): reactor.callFromThread(run_task_in_reactor)
(为简单起见，请假设当worker接收到任务时，反应器已经在运行；只要worker启动，我就使用信号@worker_process_init.connect在另
浏览 0提问于2013-03-27得票数 3
2回答
这是与多线程并行完成的。我开始遇到web服务的速率限制，所以我希望每秒最多发送10个请求，以避免出现这些错误。我如何使用reactor来做到这一点呢？使用zipWith(Mono.delayMillis(100))？还是有更好的方法？
谢谢
浏览 2提问于2017-05-05得票数 10
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
