RabbitMQ的入门篇

RabbitMQ是一个开源的消息队列系统，用于传输消息。以下是一个简单的Python代码示例，展示如何使用pika库连接到RabbitMQ服务器，发送和接收消息。

首先，确保已经安装了pika库，如果没有安装，可以使用pip安装：

pip install pika

以下是一个简单的生产者（发送消息）和消费者（接收消息）的示例代码：

生产者（发送消息）:

import pika
 
# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
# 声明一个队列，如果没有，RabbitMQ会自动创建
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()
 
# 声明一个队列，如果没有，RabbitMQ会自动创建
channel.queue_declare(queue='hello')
 
print(' [*] Waiting for messages. To exit press CTRL+C')
 
# 定义一个回调函数来处理消息
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
 
# 开始监听队列，并在接收到消息时调用callback函数
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
# 开始监听并等待消息
channel.start_consuming()

在这个例子中，生产者和消费者都连接到本地的RabbitMQ服务器（localhost），并分别声明了一个名为"hello"的队列。生产者发送一条消息"Hello World!"到这个队列，而消费者则监听这个队列，并在收到消息时打印出来。