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')
热门推荐
1 如何训练狗狗不叫
2 训练狗狗不叫
3 训练狗狗随行
4 怎么训练狗狗不叫
7 训练比熊狗狗教程
10 上海狗狗训练
11 怎么训练狗狗上厕所
12 训练狗狗趴下
13 狗狗服从训练
14 训练狗狗拒食
15 训练狗狗笑
16 训练狗狗大便
17 训练狗狗立
18 训练狗狗捡东西