如何在 Spring 云数据流中实现速率限制器处理器

Question

我想实现一个速率限制器处理器来减慢消息流。这是图表。例如，传入消息的速率为每秒 100 条，但处理器应以每秒 10 条的速度调度。

有什么实施建议吗？

Answer 1

查看 Polled Consumer Cloud Stream 中的 Polled Consumer 支持。这实质上允许您的处理器控制何时从输入通道中提取下一条消息。

或者您可以使用 reactive 背压编程来实现处理器。对于您的用例，这可能有点矫枉过正。