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

现在,我该如何实现这样的系统/算法呢?我一直在考虑将消息/“糖果”放入不同的redis列表/集合或RabbitMQ队列中,但让它们以单独的速率从每个队列中弹出似乎是一项艰巨的任务。有没有比redis更适合这项工作的技术?
发布于 2015-03-22 02:52:41
您可以使用Resque (它也使用Redis实现持久性)。您可以为每种类型的“糖果”使用不同的队列,并使用不同的--interval选项值为每个队列启动一个工作器。
$ bin/resque work --queues=blue --interval=10
$ bin/resque work --queues=green --interval=2
$ bin/resque work --queues=red --interval=5https://stackoverflow.com/questions/29117729
复制相似问题