如何在Python中使用消息隊(duì)列庫

180次閱讀

共計(jì) 997 個(gè)字符，預(yù)計(jì)需要花費(fèi) 3 分鐘才能閱讀完成。

在 Python 中，可以使用一些流行的消息隊(duì)列庫，例如 RabbitMQ、ZeroMQ、Kafka、Redis 等。下面是如何在 Python 中使用 RabbitMQ 作為消息隊(duì)列的示例：

安裝 pika 庫，它是 Python 與 RabbitMQ 通信的庫：

pip install pika

生產(chǎn)者端發(fā)送消息到隊(duì)列：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")

connection.close()

消費(fèi)者端接收消息：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

channel.basic_consume(queue='hello',
                      auto_ack=True,
                      on_message_callback=callback)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

通過以上代碼示例，你可以在 Python 中使用 RabbitMQ 作為消息隊(duì)列來實(shí)現(xiàn)消息的發(fā)送和接收功能。在實(shí)際應(yīng)用中，你可以根據(jù)需要選擇合適的消息隊(duì)列庫，并根據(jù)具體的業(yè)務(wù)需求進(jìn)行定制化開發(fā)。

丸趣 TV 網(wǎng) – 提供最優(yōu)質(zhì)的資源集合！

正文完