rabbitmq中的basic_qos
时间: 2024-05-28 13:07:56 浏览: 171
RabbitMQ 开发文档(翻译)
RabbitMQ中的basic_qos是用于在消费者端限制消息传输速率的方法。通过设置每个消费者可以处理的最大未确认消息数,可以避免RabbitMQ服务器过载或消费者处理消息不及时导致消息堆积。
基本用法如下:
```python
channel.basic_qos(prefetch_count=1)
```
其中,prefetch_count参数表示每个消费者同时能够处理的最大未确认消息数。如果prefetch_count设置为1,则表示每个消费者只有在确认前一个消息之后才会接收到下一个消息。
阅读全文