如何使用 pika 从一个消费者的 2 个 RabbitMQ 队列中异步消费

Question

我正在编写一个需要从两个不同队列消费的消费者。

1-> 用于实际消息（事先声明的队列）。

2-> 用于控制消费者行为的命令消息（由消费者动态声明并使用特定格式的路由键绑定到现有交换（每个消费者运行实例需要一个））

我正在使用选择连接来异步消费。

    self.channel.basic_qos(prefetch_count = self.prefetch_count)
    log.info("Establishing channel with the Queue: "+self.commandQueue)
    print "declaring command queue"
    self.channel.queue_declare(queue=self.commandQueue,
                                durable = True,
                                exclusive=False,
                                auto_delete=True,
                                callback = self.on_command_queue_declared)

队列未被声明或回调未被调用。

另一方面，来自实际消息队列的消息没有被消耗，因为我添加了这段代码。

Pika 日志不会显示任何错误，消费者应用程序也不会崩溃。

有人知道为什么会这样吗，或者有更好的方法吗？

Answer 1

你看过这里的例子吗：http://pika.readthedocs.org/en/latest/examples/asynchronous_consumer_example.html？

还有一些阻塞示例： http://pika.readthedocs.org/en/latest/examples/blocking_consume.html http://pika.readthedocs.org/en/latest/examples/blocking_consumer_generator.html

阻塞和选择连接比较：http://pika.readthedocs.org/en/latest/examples/comparing_publishing_sync_async.html

pika 0.10.0 预发行版中的阻止和选择连接速度更快，并且该版本中修复了许多错误。