2017-05-05 51 views
0

我正在使用項目反應器從Web服務使用rest來加載數據。這是與多個線程並行完成的。我開始打擊網絡服務的速率限制,所以我想每秒發送最多10個請求以避免發生這些錯誤。我將如何做到這一點使用反應堆?使用Reactor的請求限制率

使用zipWith(Mono.delayMillis(100))?或者有更好的方法嗎?

謝謝

+0

當前的解決方案:Flux.range(1,10) .zipWith(Flux.interval(Duration.of(1,ChronoUnit.SECONDS))) .MAP(Tuple2 :: getT1) .toIterable() 。 forEach(i - > logger.info(「Received:{}」,i)); – Mavo

回答

0

可以使用delayElements而不是整個zipwith