如何將訊息釋出到 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')