使用Reactor的请求限制率

我正在使用项目反应器从Web服务使用rest来加载数据。这是与多个线程并行完成的。我开始打击网络服务的速率限制，所以我想每秒发送最多10个请求以避免发生这些错误。我将如何做到这一点使用反应堆？使用Reactor的请求限制率

使用zipWith（Mono.delayMillis（100））？或者有更好的方法吗？

谢谢

2017-05-05 Mavo

当前的解决方案：Flux.range（1，10） .zipWith（Flux.interval（Duration.of（1，ChronoUnit.SECONDS））） .MAP（Tuple2 :: getT1） .toIterable（）。 forEach（i - > logger.info（“Received：{}”，i））; – Mavo

可以使用delayElements而不是整个zipwith。

来源

2017-05-09 21:19:42

使用Reactor的请求限制率

回答

相关问题