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()#关闭
相关文章
- 15.消息队列RabbitMQ
- ActiveMQ 消息持久化到数据库
- .NET为什么推荐它作为RabbitMQ消息队列的首选开发工具
- (九)RabbitMQ消息队列-通过Headers模式分发消息
- RabbitMQ消息队列(五):Routing 消息路由 2[原]
- 我这.NET菜鸟,用它开发RabbitMQ消息队列后,竟被老板一夜提拔为架构师
- (转)RabbitMQ消息队列(二):”Hello, World“
- 进击的Python【第十一章】:消息队列介绍、RabbitMQ&Redis的重点介绍与简单应用
- Redis和RabbitMQ实现消息队列
- 如果队列消息字节长度大于x-max长度字节,RabbitMQ如何处理?