ruby - 为消息队列实现类似 "leaky bucket"的算法

Question

我有一个基于 ruby​​ 的应用程序，它有许多不同的消息队列(+200 个不同的队列)，所有这些都需要单独进行 throttle/速率限制。我试图用这个糖果自动售货机类比来说明问题

现在我将如何着手实现这样的系统/算法？我一直在考虑将消息/“糖果”放入不同的 redis 列表/集合或 RabbitMQ 队列中，但是让它们以单独的速率从每个队列中弹出似乎是一项艰巨的任务。是否有一些技术比 Redis 更适合这项工作？

Answer 1

你可以使用 Resque (它也使用 Redis 进行持久化)。您可以为每种类型的“糖果”使用不同的队列，并为每个队列启动一个 worker，并为 --interval 选项设置不同的值。

$ bin/resque work --queues=blue  --interval=10
$ bin/resque work --queues=green --interval=2
$ bin/resque work --queues=red   --interval=5