使用 Spring Webflux 和几个慢速 HTTP 后端请求的背压

Question

在我的 webflux 应用程序中，我使用来自 AWS-SQS 的消息并使用它们在慢速后端调用多个 HTTP 请求（响应时间长达 5 秒）。

我意识到我消耗的消息越多，后端变得越慢，直到它因为太多的流量而死掉。

如何使用 reactor / webflux 机制来控制我发送到后端的请求数量？我尝试了一些限制/限制速率的东西，但它没有按预期工作。

您有任何示例/想法吗？

Answer 1

看看resilience4j 库。在断路器、重试、隔板等几个弹性功能中，还有rate limiting。

他们支持Project Reactor。