rabbitmq 生产者和消费者

# 消费者 import pika,time consumer = pika.BlockingConnection\ (pika.ConnectionParameters('localhost'))#建立socket链接 channel = consumer.channel()#建立管道 channel.queue_declare(queue='name',durable=True)#

>>阅读原文<<