RabbitMQ和消息优先级

Question

RabbitMQ有消息优先级的概念吗？我有一个问题，一些更重要的消息由于队列中不太重要的消息而被拖慢。我希望高优先级的优先，并移动到队列的前面。

我知道我可以用两个队列来近似计算，一个是“快”队列，另一个是“慢”队列，但这看起来像是一个黑客。

有人知道使用RabbitMQ的更好的解决方案吗？

Answer 1

IIRC RabbitMQ仍然使用AMQP协议版本0.9.1（在此处获取规范）。规范明确提到了消息优先级：

Messages may have a priority level. A high priority message is sent ahead of lower     priority messages
waiting in the same message queue. When messages must be discarded in order to maintain a specific
service quality level the server will first discard low-priority messages.

以及：

Note that in the presence of multiple readers from a queue, or client transactions, or use of priority fields,
or use of message selectors, or implementation-specific delivery optimisations the queue MAY NOT
exhibit true FIFO characteristics.

规范说优先级是必须的，所以我猜RabbitMQ应该实现它，但是你可能想咨询它的留档。

Answer 2

兔子没有优先权的概念，就像布赖恩简洁地说的那样，前面的那个先到达那里

我建议实施一组队列，为您的特定消息传递需求提供服务，并让这些队列对您的优先级需求进行建模，例如，将它们称为“MyQueueP1”、“MyQueueP2”等等，然后让我们的消费者在P2之前检查P1（等），并首先从那里服务消息。

如果你有一个高优先级的消息，你会通过一个合适的路由键把它发布到合适的优先级队列中。

[更新]检查这个问题：在FIFO QUEING系统中，实现优先级消息的最佳方式是什么

[更新]根据最近的RabbitMQ 3.5.0版，此答案现已过时，应仅对本版本之前的版本有效。https://stackoverflow.com/a/29068288/489888

Answer 3

关于这个问题的答案已经过时了。从RabbitMQ 3.5.0开始，现在有了对AMQP标准每消息优先级的核心支持。文件中有所有血淋淋的细节，但简而言之：

• 您需要在创建队列时定义队列的优先级范围；
• 没有优先级集的消息获得0的优先级；
• 数字优先级高于队列上最大设置的消息将获得队列支持的最高优先级。

更多有趣的警告在文档中。读它们非常值得。