如何在 Spring Cloud Data Flow 中实现速率限制器处理器

【问题标题】：How to implement a rate limiter processor in Spring Cloud Data Flow如何在 Spring Cloud Data Flow 中实现速率限制器处理器
【发布时间】：2021-11-11 15:36:10
【问题描述】：

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

对如何实现有任何建议？

【问题讨论】：

标签： spring-cloud-stream spring-cloud-dataflow

【解决方案1】：

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

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

【讨论】：

我实现了这个处理器并部署到spring cloud dataflow，虽然当我用TestChannelBinder测试它工作正常，但它不是在spring cloud dataflow上轮询消息。我看到它在日志中的某个时间间隔调用poll。我发布了另一个问题stackoverflow.com/questions/69383266/…。你看一下吗？