如何将消息发布到 RabbitMQ

首先导入库。

from amqpstorm import Connection
from amqpstorm import Message

接下来我们需要打开与 RabbitMQ 服务器的连接。

connection = Connection('127.0.0.1', 'guest', 'guest')

之后我们需要建立一个频道。每个连接可以有多个通道，通常在执行多线程任务时，建议（但不要求）每个线程有一个。

channel = connection.channel()

一旦我们建立了频道，我们就可以开始准备我们的信息了。

# Message Properties.
properties = {
    'content_type': 'text/plain',
    'headers': {'key': 'value'}
}

# Create the message.
message = Message.create(channel=channel, body='Hello World!', properties=properties)

现在我们可以通过简单地调用 publish 并提供 routing_key 来发布消息。在这种情况下，我们将把消息发送到名为 simple_queue 的队列。

message.publish(routing_key='simple_queue')