pyhton-pika链接mq

Python-pika是一个用于连接AMQP（Advanced Message Queuing Protocol，高级消息队列协议）的消息队列客户端库，如RabbitMQ。它提供了一种简单的方式来创建、管理以及消费RabbitMQ服务器上的消息。使用Python-pika，你可以：

1. **建立连接**：通过`pika.ConnectionParameters`设置连接参数，然后创建`Connection`实例来连上RabbitMQ服务器。

import pika

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

2. **创建频道**：在连接上创建一个或多个`Channel`，这是发送和接收消息的主要工作区域。

channel = connection.channel()

3. **声明交换机和队列**：定义消息如何路由到队列，可以声明交换机（Exchange）和绑定（Binding）它们到队列。

4. **发布消息**：使用`channel.basic_publish()`方法将消息发送到指定的交换机和队列。

5. **订阅并消费消息**：设置一个回调函数处理从队列接收到的消息，使用`basic_consume()`方法开始消费者进程。

def callback(ch, method, properties, body):
    print("Received %r" % body)

channel.basic_consume(callback, queue='my_queue', auto_ack=True)
channel.start_consuming()

6. **关闭连接**：完成操作后，记得关闭通道和连接释放资源。

connection.close()