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 祝福语驱散霉运的话简短