使用 Reactor 限制请求率

Mav*_*avo 10 java project-reactor

我正在使用项目反应器从使用休息的 Web 服务加载数据。这是与多个线程并行完成的。我开始达到 Web 服务的速率限制,因此我希望每秒最多发送 10 个请求以避免出现这些错误。我将如何使用反应器做到这一点?

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

谢谢

Sim*_*slé 5

您可以使用delayElements而不是整个zipwith.