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')
热门推荐
10 感谢韩语老师祝福语简短
11 升职文案高级祝福语简短
12 花童结婚祝福语大全简短
13 向国庆送祝福语简短
14 什么寄语简短祝福语女生
15 客户回礼祝福语大全简短
16 女孩生日祝福语简短创意
17 家长回复节日祝福语简短
18 给外婆敬酒祝福语简短