import pika

 connection = pika.BlockingConnection(

     pika.ConnectionParameters('localhost'))#建立一个最基本的socket

 chanel = connection.channel()#声明一个管道

 chanel.queue_declare(queue='name1',durable=True)#给管道创建一个队列，参数是管道队列名。

 #持久化队列

 chanel.basic_publish(exchange='',

                      routing_key='name1',

                      body ='HELLO WORD!',

                      properties=pika.BasicProperties(

                          delivery_mode=2))#彻底将队列中的信息持久化。

 print( '发出一个消息')

 connection.close()#关闭