我有多个任务生成器,可以将工作添加到队列中.我也有多个消费者以该队列为食.由于这些队列是FIFO,因此它们按照添加的顺序出列.
在我的方案中,任务从HTTP请求添加到队列中.每个任务都与一个帐户相关联,并且没有速率限制.因此,可以让来自一个帐户的任务充斥消息队列.
为了解决这个问题,我一直在寻找一个队列实现,它允许我以循环方式处理来自多个帐户的排队任务以实现公平.
我目前使用Redis并使用一些Lua脚本来模拟循环队列,但是想知道是否有任何现有的排队拓扑可以实现这一目标？
在文档或Google上都找不到与此有关的任何内容，只是它应该绑定到服务器的可用资源上。
是否有人在工作环境中有一次真正大量交流的经验？仅创建交换不是问题（仅在达到内存限制之前），而是要在具有高消息吞吐量且主要是动态交换创建/删除的工作项目中使用它。