python使用rabbitMQ

-------生产者-------------
import pika
import random
#创建凭证
credentials = pika.PlainCredentials('guest','guest')
#新建一个连接
connection = pika.BlockingConnection(pika.ConnectionParameters('124.223.67.211',credentials=credentials))
#创建一个频道
channel = connection.channel()
#声明一个队列,队列名字叫MSG
channel.queue_declare(queue='MSG')
#向队列发送消息。
for i in range(1,100):
    code = random.randint(100000, 999999)
    channel.basic_publish(exchange='',routing_key='MSG',body='验证码：%s'%code)
connection.close()

-----------消费者----------------
import pika
credentials = pika.PlainCredentials('guest','guest')
#新建一个连接
connection = pika.BlockingConnection(pika.ConnectionParameters('124.223.67.211',credentials=credentials))
#创建一个频道
channel = connection.channel()
#声明一个队列,队列名字叫MSG
channel.queue_declare(queue='MSG')
def consumer(ch,method,properties,body):
    print('消费者收到的验证码:%s'%body.decode('utf-8'))
#第一个是队列名字，第二个是回调函数，第三个是auto_act = true。消息会一直阻塞在这，一直等待消息，队列中有消息，就执行回调函数
channel.basic_consume('MSG',consumer,True)
#开始消费，接收消息
channel.start_consuming()