rabbitmq 持续获取_rabbitMq创建和获取消息

要创建 RabbitMQ 连接和获取消息，你需要使用 RabbitMQ 客户端库。以下是使用 Python 客户端库 pika 的示例代码：

import pika

# 建立连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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

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

# 定义回调函数，处理收到的消息
def callback(ch, method, properties, body):
    print("Received %r" % body)

# 持续获取消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
channel.start_consuming()

以上代码中，我们先建立连接，然后创建一个名为 "hello" 的队列，接着发送一条消息到队列中。最后定义了一个回调函数 callback，用于处理收到的消息。最后调用 `basic_consume` 函数，传入队列名和回调函数，开始持续获取消息。

你可以根据自己的需求，修改以上代码中的参数和逻辑，实现自己的 RabbitMQ 消息队列应用。