rabbitmq 生產者和消費者

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

>>阅读原文<<