python链接MQ

Python连接MQ (Message Queue) 可以通过多种库实现，其中最常用的是使用AMQP协议的pika库，它是RabbitMQ的一个客户端。以下是基本步骤：

1. 安装依赖：首先需要安装pika库，可以使用pip命令进行安装：

   pip install pika

2. 创建连接：创建到MQ服务器的连接，比如连接到RabbitMQ，通常会包含服务器地址、用户名和密码等信息：

   import pika

   connection = pika.BlockingConnection(pika.ConnectionParameters(
       host='your_mq_server',
       port=5672,
       virtual_host='/',
       credentials=pika.PlainCredentials('username', 'password')
   ))

3. 创建通道：连接建立后，我们需要创建一个频道来进行消息传递：

   channel = connection.channel()

4. 发布消息：设置一个队列并发布消息到该队列：

   result = channel.queue_declare(queue='my_queue', durable=True)
   routing_key = 'your_routing_key'
   message = "Hello World!"
   channel.basic_publish(exchange='', routing_key=routing_key, body=message)

5. 消费消息：消费者从队列中接收消息并处理它们：

   def callback(ch, method, properties, body):
       print(f"Received {body}")

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

6. 关闭连接：完成操作后别忘了关闭连接：

   channel.stop_consuming()
   connection.close()