RabbitMQ 是一个开源的消息队列系统，用于在分布式系统中存储和转发消息。本指南将带您快速入门 RabbitMQ。

安装 RabbitMQ

首先，您需要安装 RabbitMQ。您可以通过以下步骤进行安装：

  1. 访问 RabbitMQ 官方网站 下载适用于您的操作系统的 RabbitMQ 安装包。
  2. 运行安装程序，按照提示进行安装。

创建第一个队列

创建队列是使用 RabbitMQ 的第一步。以下是如何创建一个队列的示例：

import pika

# 连接到 RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 创建一个名为 "hello" 的队列
channel.queue_declare(queue='hello')

# 发送一个消息到队列
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")

# 关闭连接
connection.close()

发送和接收消息

现在我们已经创建了一个队列，我们可以发送和接收消息。

发送消息

以下是如何发送消息到队列的示例：

import pika

# 连接到 RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 发送一个消息到队列
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")

# 关闭连接
connection.close()

接收消息

以下是如何接收队列中消息的示例：

import pika

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

# 连接到 RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 创建一个名为 "hello" 的队列
channel.queue_declare(queue='hello')

# 设置队列的回调函数
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

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

扩展阅读

如果您想了解更多关于 RabbitMQ 的信息，可以阅读以下文章：

RabbitMQ Logo