为什么消息优先级不对 RabbitMQ 中的消息进行排序？

Question

我与生产者和消费者一起运行 elixir 程序。我为我的消息设置了优先级。但优先级不起作用。

我的程序：

出版商：

Basic.publish(channel, "my_exchange", "my_queue", "1", persistent: true, priority: 2)
Basic.publish(channel, "my_exchange", "my_queue", "2", persistent: true, priority: 3)
Basic.publish(channel, "my_exchange", "my_queue", "3", persistent: true, priority: 1)
Basic.publish(channel, "my_exchange", "my_queue", "4", persistent: true, priority: 0)
Basic.publish(channel, "my_exchange", "my_queue", "5", persistent: true, priority: 4)

消费者：

def init(_) do
Connection.open(Application.get_env(:app, :rabbitmq))
{:ok, channel} = Channel.open(conn)
:ok = Basic.qos(channel, prefetch_count: 1, global: true)
{:ok, _consumer_tag} = Basic.consume(channel, "my_queue", nil, arguments: [{"x-priority", :signedint, 100}])
{:ok, %{channel: channel}}
end

def handle_info({:basic_deliver, payload, %{delivery_tag: tag, priority: priority}}, %{channel: channel} = state) do

Logger.info("Received message with payload: #{payload} and priority: #{priority}")

Basic.ack(channel, tag)

{:noreply, state}
end

发布后，我运行消费者。

预期输出：

Received message with payload: 5 and priority: 4
Received message with payload: 2 and priority: 3
Received message with payload: 1 and priority: 2
Received message with payload: 3 and priority: 1
Received message with payload: 4 and priority: 0

实际输出：

Received message with payload: 1 and priority: 2
Received message with payload: 2 and priority: 3 
Received message with payload: 3 and priority: 1
Received message with payload: 4 and priority: 0
Received message with payload: 5 and priority: 4

我做错了什么吗？消息的优先级不起作用吗？

Answer 1

人们不应该期望消息在队列中排序，因为“队列”的基本含义是（大约任何队列都是 LIFO 或 FIFO，RabbitMQ 的队列是后者。）

对队列中的消息进行洗牌以按其在每个插入上的优先级对它们进行排序会大大降低性能。 RabbitMQ（自 3.5.0 起生效）实际允许的是：

• prioritizing queues 和
• prioritizing consumers.

NB尽管如此，从 3.5.0 开始 RabbitMQ 允许对队列中卡的消息进行排序，假设消费者得到他们进入队列的消息较慢。在这种情况下，未使用的消息将被排序。

不过，它仍然无法保证排序。优先级仅允许您让一些队列/消费者“举手”首先接收消息除非它们被阻止。否则，优先级链中的下一个将收到一条消息。

如果您需要对收入进行排序（很难想象为什么在这种情况下您会选择消息队列，但仍然如此），您必须在发送到发布者中的队列之前对其进行排序 em>，或者在从队列中收集所有预期消息之后在消费者中。

Answer 2

为了消除任何疑问，您的消费者和生产者似乎同时连接和处理。发生这种情况时，消息会直接（基本上）路由到消费者，而不需要排队。

所以，RabbitMQ 工作正常，但您的期望需要稍作调整。消息优先级只会对队列中的消息进行操作，即使这样，也有可能不尊重优先级的情况（例如并行消费者）。

底线 - 不要编写要求以任何特定顺序传递消息的单元测试，因为那是 not a guarantee provided by message queuing systems。

Answer 3

正如here所指出的，正确的队列参数是x-max-priority。您正在使用x-priority，因此您的队列没有被声明为优先级队列。

文档：https://www.rabbitmq.com/priority.html