0
我正在使用項目反應器從Web服務使用rest來加載數據。這是與多個線程並行完成的。我開始打擊網絡服務的速率限制,所以我想每秒發送最多10個請求以避免發生這些錯誤。我將如何做到這一點使用反應堆?使用Reactor的請求限制率
使用zipWith(Mono.delayMillis(100))?或者有更好的方法嗎?
謝謝
我正在使用項目反應器從Web服務使用rest來加載數據。這是與多個線程並行完成的。我開始打擊網絡服務的速率限制,所以我想每秒發送最多10個請求以避免發生這些錯誤。我將如何做到這一點使用反應堆?使用Reactor的請求限制率
使用zipWith(Mono.delayMillis(100))?或者有更好的方法嗎?
謝謝
可以使用delayElements
而不是整個zipwith
。
當前的解決方案:Flux.range(1,10) .zipWith(Flux.interval(Duration.of(1,ChronoUnit.SECONDS))) .MAP(Tuple2 :: getT1) .toIterable() 。 forEach(i - > logger.info(「Received:{}」,i)); – Mavo