rabbitmq pika 使用线程时不会做超过一项工作

Question

当我阻塞channel.start_consuming()长时间运行的IOLoop时，我遇到了ConnectionResetError的问题。所以我读过这段代码：
https://github.com/pika/pika/blob/0.12.0/examples/basic_consumer_threaded.py
在这段代码中，作业在后台线程中运行。

问题是，当我的作业在线程中运行时，worker 仍然可以执行更多作业（即，不断收到 on_message 回调）。但我不希望我的员工一次处理一份以上的工作。
我该怎么办？是否可以通知队列worker“忙”并且有一段时间不能接受工作？

Answer 1

只要您通过channel.basic_qos 方法设置通道的QoS 值，您的消费者就不会收到比prefetch_count 指定的更多的未确认消息。

如果您使用prefetch_count=1 参数，您的消费者一次只会收到一条消息，并且在为该消息调用basic_ack 之前不会获得更多消息。

如果由于某种原因，您看到了不同的内容，请将您的代码全部作为附件或链接分享到pika-python 邮件列表中的邮件中，我会检查出来的。 p>

---

_{注意：RabbitMQ 团队会监控 rabbitmq-users mailing list，并且有时只回答 StackOverflow 上的问题。}