在消费者端，需要在获取消息之后手动确认消息已经被消费完成，否则消息将不会被从队列中删除。

示例代码如下：

import pika

连接到RabbitMQ服务器

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel()

创建一个名为"hello"的队列

channel.queue_declare(queue='hello')

定义回调函数，用于处理接收到的消息

def callback(ch, method, properties, body): print("Received %r" % body) # 手动确认消息已经被消费 ch.basic_ack(delivery_tag=method.delivery_tag)

设置QoS，告诉RabbitMQ同一时间最多向该消费者发送多少条消息

channel.basic_qos(prefetch_count=1)

注册回调函数

channel.basic_consume(queue='hello', on_message_callback=callback)

开始消费

print('Waiting for messages. To exit press CTRL+C') channel.start_consuming()