RabbitMQ的事务确认机制代码示例

以下是RabbitMQ的事务确认机制代码示例，使用了Python的pika库：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 创建队列
channel.queue_declare(queue='example_queue', durable=True)

# 开始事务
channel.tx_select()

try:
    # 发送消息
    channel.basic_publish(exchange='',
                          routing_key='example_queue',
                          body='Hello World!',
                          properties=pika.BasicProperties(delivery_mode=2))  # 使消息持久化

    # 提交事务
    channel.tx_commit()
    print('Message sent and transaction committed.')
except:
    # 回滚事务
    channel.tx_rollback()
    print('Transaction rolled back.')

# 关闭连接
connection.close()

在以上代码中，首先连接到RabbitMQ服务器并创建了一个名为`example_queue`的队列，并使用`channel.tx_select()`开始了一个事务。然后发送一条持久化的消息，并在`channel.tx_commit()`中提交了事务。如果在提交事务之前发生了异常，则使用`channel.tx_rollback()`回滚事务。最后，关闭连接。