RabbitMQ消息确认机制（ACK）示例代码

以下是 RabbitMQ 消息确认机制（ACK）的示例代码（使用 Python 的 pika 库）：

import pika

# 创建连接和 channel
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明队列
channel.queue_declare(queue='hello')

# 定义回调函数，用于处理接收到的消息
def callback(ch, method, properties, body):
    print("Received %r" % body)
    # 发送确认消息给 RabbitMQ
    ch.basic_ack(delivery_tag=method.delivery_tag)

# 告诉 RabbitMQ 只有在消费者准备就绪时才分派消息
channel.basic_qos(prefetch_count=1)

# 订阅队列，并使用回调函数处理接收到的消息
channel.basic_consume(queue='hello', on_message_callback=callback)

# 开始消费消息
print('Waiting for messages...')
channel.start_consuming()

以上代码中的 `ch.basic_ack(delivery_tag=method.delivery_tag)` 表示发送确认消息给 RabbitMQ。它会告诉 RabbitMQ 已经成功地处理了消息，可以将该消息从队列中删除。这种消息确认机制可以保证消息的可靠传递。