Python如何将消息发布到RabbitMQ
示例
从导入库开始。
from amqpstorm import Connection from amqpstorm import Message
接下来，我们需要打开与RabbitMQ服务器的连接。
connection = Connection('127.0.0.1', 'guest', 'guest')之后，我们需要建立一个频道。每个连接可以有多个通道，通常在执行多线程任务时，建议（但不是必需）每个线程一个。
channel = connection.channel()
建立频道后，我们就可以开始准备信息了。
#邮件属性。
properties = {
'content_type': 'text/plain',
'headers': {'key': 'value'}
}
#创建消息。
message = Message.create(channel=channel, body='Hello World!', properties=properties)现在，我们可以通过简单地调用publish并提供来发布消息routing_key。在这种情况下，我们将把消息发送到名为的队列simple_queue。
message.publish(routing_key='simple_queue')
热门推荐
7 简短的二胎祝福语
10 简短霸气女儿生日 祝福语
11 祝福语高考小众诗句简短
12 元旦祝福语20秒简短
13 老师过年祝福语大全 简短
14 一生祝福语简短
15 产检祝福语简短霸气
16 朋友店开张祝福语简短
17 生日爱情祝福语大全简短
18 朋友女儿生日祝福语 简短