rabbitMq代码示例

以下是一个简单的RabbitMQ Python示例，它将消息发送到队列并从队列中接收消息：

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!'")

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

# 从队列中接收消息
channel.basic_consume(queue='hello',
                      auto_ack=True,
                      on_message_callback=callback)

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

# 开始消费消息
channel.start_consuming()

在此示例中，我们首先连接到本地主机上运行的RabbitMQ服务器。然后，我们创建一个名为'hello'的队列，并使用`basic_publish`方法将消息“Hello World！”发送到队列中。

我们还定义了一个名为'callback'的回调函数，以处理从队列中接收到的消息。最后，我们使用`basic_consume`方法开始消费队列中的消息，并在控制台输出它们。

要运行此示例，请确保已安装pika库，并在命令行中运行以下命令：

python rabbitmq-example.py