python rabbitmq 优先级 示例

下面是一个使用 RabbitMQ 的优先级示例：

import pika

# 连接 RabbitMQ 服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明队列
channel.queue_declare(queue='priority_queue', arguments={'x-max-priority': 10})

# 发布消息
message = 'Hello, RabbitMQ!'
channel.basic_publish(
    exchange='',
    routing_key='priority_queue',
    body=message,
    properties=pika.BasicProperties(priority=5)  # 设置消息优先级为 5
)

print("消息已发送")

# 关闭连接
connection.close()

在上面的示例中，首先我们创建了一个连接到 RabbitMQ 服务器的连接对象。然后，声明了一个名为 "priority_queue" 的队列，并通过 `arguments` 参数设置了队列的最大优先级为 10。

接下来，我们通过 `basic_publish` 方法发布了一条消息到队列，同时设置了消息的优先级为 5。这样，该消息会被放置在具有较高优先级的消息之前。

最后，我们关闭了与 RabbitMQ 的连接。

请确保你已经安装了 `pika` 库，可以使用以下命令进行安装：

pip install pika

你也需要确保已经在本地安装并运行了 RabbitMQ 服务器。