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')