java - 如何以一定的速率消费者QueueChannel？

Question

Here是如何填充和处理队列的示例。但是如何处理带有速率的消息呢？喜欢每秒处理 N 条消息？

更新 这里的“进程”:我的意思是“出队”。例如。如何每秒出队 N 条消息？

Answer 1

正如我之前提到的，您可以使用某种速率控制来编写循环(例如，通过 Thread.sleep 作为最基本的)。 您也可以尝试使用@Scheduled 注解。

这是每秒调用 100 次的方法的示例

@Scheduled(fixedRate = 10)
public void dequeue() {
        //queue.poll(..)
}