rabbitmq(中间消息代理)在python中的使用详解

RabbitMQ在Python中的使用详解

RabbitMQ是一个开源的消息代理，它可以在分布式系统中传递消息。在Python中，我们可以使用pika库来连接和操作RabbitMQ。

安装pika库

在使用pika库之前，我们需要先安装它。可以使用pip命令来安装pika库：

pip install pika

连接RabbitMQ

在使用pika库连接RabbitMQ之前，我们需要先启动RabbitMQ服务。可以在终端中输入以下命令来启动RabbitMQ服务：

rabbitmq-server

以下是连接RabbitMQ的示例：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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

# 发送消息
channel.basic_publish(exchange='', routing_key='hello', body='Hello, World!')

# 关闭连接
connection.close()

在上面的示例中，我们使用pika库连接了RabbitMQ服务器，并创建了一个名为“hello”的队列。接着，我们使用basic_publish方法向队列发送了一条消息。最后，我们使用close方法关闭了连接。

接收消息

在使用pika库接收RabbitMQ消息之前，我们需要先启动RabbitMQ服务，并向队列发送一条消息。可以使用上面的示例中的代码向队列发送一条消息。

以下是接收RabbitMQ消息的示例：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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

# 定义回调函数
def callback(ch, method, properties, body):
    print("Received %r" % body)

# 监听队列
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

# 开始接收消息
print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

在上面的示例中，我们使用pika库连接了RabbitMQ服务器，并创建了一个名为“hello”的队列。接着，我们定义了一个回调函数，用于处理接收到的消息。最后，我们使用basic_consume方法监听队列，并使用start_consuming方法开始接收消息。

示例

以下是一个完整的示例，演示如何使用pika库连接和操作RabbitMQ：

import pika

# 连接RabbitMQ服务器
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("Sent 'Hello, World!'")

# 定义回调函数
def callback(ch, method, properties, body):
    print("Received %r" % body)

# 监听队列
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

# 开始接收消息
print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

# 关闭连接
connection.close()

在上面的示例中，我们使用pika库连接了RabbitMQ服务器，并创建了一个名为“hello”的队列。接着，我们使用basic_publish方法向队列发送了一条消息，并定义了一个回调函数，用于处理接收到的消息。最后，我们使用basic_consume方法监听队列，并使用start_consuming方法开始接收消息。