rabbitmq使用代码

当使用 RabbitMQ 时，你可以使用不同编程语言编写代码进行交互。以下是使用 Python 编写 RabbitMQ 代码的示例：

首先，确保你已经安装了 `pika` 库。你可以使用以下命令安装它：

pip install 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, RabbitMQ!')

# 定义一个回调函数来处理接收到的消息
def callback(ch, method, properties, body):
    print("Received message:", body)

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

print('Waiting for messages...')
channel.start_consuming()

# 关闭连接
connection.close()

这是一个简单的示例，它连接到本地的 RabbitMQ 服务器，并发送和接收消息。你可以根据自己的需求进行修改和扩展。