用 pika 取消rabbitmq 消费的正确方法

Question

我想用 rabbitmq 实现 rpc 客户端。我的代码主要看起来像

def start(self):
    while True:
        self.channel.basic_consume(self.on_delivery)
 ...
 client.start() // blocking call

什么是阻止这个客户的正确方法？ 现在我从另一个线程制作channel.basic_cancel(self.on_cancel, self.consumer_tag)。不过pika faq saysIt is not safe to share one Pika connection across threads.

取消消费的首选方式是什么？

Answer 1

只要你创建一个连接每个线程，你应该没问题。

eandersson 创建了一个 here 的示例。