python连接rabbitmq集群

Python通过`pika`库连接RabbitMQ集群可以分为几个步骤：

1. 安装`pika`库：如果你还没有安装，可以在命令行运行 `pip install pika` 来安装。

2. 创建连接：首先需要创建一个连接到RabbitMQ服务器的连接实例。如果你有多个队列服务，可以建立一个连接池来管理连接，比如使用`ConnectionPool`。

import pika

# 配置参数，包括主机名、端口、虚拟主机等
connection = pika.BlockingConnection(pika.ConnectionParameters(host='cluster_nodes', port=5672, virtual_host='/'))

3. 创建频道（Channel）：通道是在连接上进行消息传递的桥梁，对于每个连接，你可以创建多个频道。

4. 消费者和生产者：如果你是要发送消息，创建一个消费者；如果是接收消息，则创建一个生产者。生产者通常会将消息发布到某个交换机（Exchange），然后由消费者订阅并消费该交换机的消息。

channel = connection.channel()
exchange_name = 'my_exchange'
routing_key = 'my_routing_key'

# 生产者模式
channel.basic_publish(exchange=exchange_name, routing_key=routing_key, body='Hello World!')

# 消费者模式
queue_name = 'my_queue'
channel.queue_declare(queue=queue_name)
channel.basic_consume(queue=queue_name, on_message_callback=lambda ch, method, properties, body: print(f"Received {body}"))
channel.start_consuming()

5. 关闭连接：处理完业务后别忘了关闭连接释放资源。

connection.close()