rabbitmq pika常用方法

1.连接到RabbitMQ服务器

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

2.声明队列

channel.queue_declare(queue='hello')

3.发送消息

channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')

4.消费消息

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

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

5.启动消费者

channel.start_consuming()

6.关闭连接

connection.close()