是否可以在反应堆中创建大量的 Mono 实例？

Question

我需要给一个客户端发送几万条消息，每条消息都有一个延迟时间，比如Message1需要延迟10ms再发送，Message2需要延迟200ms再发送。我正在考虑使用反应器来完成这项工作，我正在考虑为每条消息创建一个 Mono 并调用 delayElement 方法，以便根据延迟发出消息。但问题是会有太多的Mono实例。这是使用 reactor 的正确方法还是有什么建议？

Answer 1

如果延迟是动态的，我认为这是最好的解决方案

   Flux.just(messages)
            .flatMap(o -> Mono.just(o)
                    .delayElement(Duration.ofSeconds(o.getDelay())))

是否可以在反应堆中创建大量的 Mono 实例？

Is it possible to create large amounts of Mono instances in reactor?

reactor