RabbitMQ消费函数/通道.ack

下面是一个使用RabbitMQ Python客户端库pika的示例代码，展示了如何消费消息并使用通道的basic_ack方法确认消息。

import pika

def callback(ch, method, properties, body):
    # 处理接收到的消息
    print("Received message:", body)

    # 手动确认消息
    ch.basic_ack(delivery_tag=method.delivery_tag)

def consume():
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()

    # 声明一个队列
    channel.queue_declare(queue='my_queue')

    # 设置每次只处理一条消息
    channel.basic_qos(prefetch_count=1)

    # 消费消息
    channel.basic_consume(queue='my_queue', on_message_callback=callback)

    # 开始消费
    channel.start_consuming()

if __name__ == '__main__':
    consume()

在上面的示例中，我们首先创建一个连接到RabbitMQ服务器的connection对象，然后使用connection.channel()方法创建一个通道channel。接下来，我们声明一个队列my_queue，并设置channel.basic_qos(prefetch_count=1)，以确保每次只处理一条消息。然后，我们使用channel.basic_consume()方法指定要消费的队列和回调函数callback。最后，我们使用channel.start_consuming()开始消费消息。

在callback函数中，我们首先处理接收到的消息，然后使用ch.basic_ack(delivery_tag=method.delivery_tag)手动确认消息。delivery_tag是消息的唯一标识符，可以通过method.delivery_tag获取。

请注意，basic_ack方法只能在使用channel.basic_consume()方法消费消息时使用。如果使用channel.basic_get()方法获取消息，则需要使用channel.basic_ack(delivery_tag=delivery_tag)手动确认消息。