python - 在python/pika中接收多个amqp队列

Question

我正在尝试接收多个队列，我尝试了代码:https://stackoverflow.com/a/42351395/3303330

但是有必要声明“queue_declare”。希望你们能帮助我，这是我的代码:

import pika
import time

from zeep import Client

parameters = pika.URLParameters('amqp://user:pass@theurl:5672/%2F')

connection = pika.BlockingConnection(parameters)
channel = connection.channel()

channel.queue_declare(queue='queue1', passive=True, durable=True, exclusive=False, auto_delete=False)
print(' [*] Waiting for messages. To exit press CTRL+C')

def callback(ch, method, header, body):
    print(" [x] Received %r" % body)
    time.sleep(body.count(b'.'))
    ch.basic_ack(delivery_tag = method.delivery_tag)

channel.basic_consume(callback, queue='queue1')

channel.start_consuming()

Answer 1

只要您保证队列是持久的，就没有必要多次声明队列。您可以在客户端代码中或使用 RabbitMQ 管理界面声明多个队列。

您可以使用您的 channel 来使用来自多个队列的消息。只需使用不同的 queue 参数值多次执行 channel.basic_consume 即可。