Pika - 处理RabbitMQ连接丢失

Posted 2021-04-16

假设您创建了一个频道并开始在其中消费消息。

channel = get_channel()
channel.queue_declare(queue=QUEUE_NAME, durable=True)

channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback, queue=QUEUE_NAME)
channel.start_consuming()

但不知何故，你失去了与RabbitMQ服务器的连接。当连接断开时，您将获得ConnectionClosed异常并且消费者停止。在消费模式下，如何处理鼠兔的连接丢失？

答案

我最后放弃pika并使用kombu代替。您可以构建一个健壮的使用者（如果连接丢失将重新连接），如本文所述：

https://medium.com/python-pandemonium/building-robust-rabbitmq-consumers-with-python-and-kombu-part-1-ccd660d17271