论坛 › Exchange › python rabbitMQ持久化队列消息

寂寞大萝卜 发表于 2017-12-9 14:01:39

python rabbitMQ持久化队列消息

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()#关闭

查看完整版本: python rabbitMQ持久化队列消息