RabbitMQ代码示例

以下是一个使用RabbitMQ的Python代码示例：

首先，安装pika库（RabbitMQ的Python客户端库）：

pip install pika

生产者代码示例（发送消息到队列）：

import pika

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

# 创建队列
channel.queue_declare(queue='my_queue')

# 发送消息到队列
channel.basic_publish(exchange='', routing_key='my_queue', body='Hello, RabbitMQ!')

# 关闭连接
connection.close()

消费者代码示例（接收消息并处理）：

import pika

# 定义消息处理函数
def callback(ch, method, properties, body):
    print("Received message:", body)

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

# 创建队列
channel.queue_declare(queue='my_queue')

# 设置消息处理函数
channel.basic_consume(queue='my_queue', on_message_callback=callback, auto_ack=True)

# 开始接收消息，进入无限循环阻塞状态
print('Waiting for messages...')
channel.start_consuming()

以上代码示例演示了一个简单的生产者和消费者模型，生产者将消息发送到名为`my_queue`的队列，消费者从该队列中接收消息并打印出来。你可以根据实际需求进行修改和扩展。