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

要使用 RabbitMQ 创建和获取消息，需要遵循以下步骤：

1. 安装 RabbitMQ：在本地或者服务器上安装 RabbitMQ，可以使用官方提供的二进制文件或者使用包管理器安装。

2. 创建连接：在代码中创建 RabbitMQ 的连接，并建立通信的 channel。

3. 创建队列：在 channel 中声明队列，如果队列不存在，则会被创建。

4. 发送消息：将消息发送到队列中，并指定队列名称和消息内容。

5. 持续获取消息：在 channel 中注册一个消费者，不断地获取队列中的消息。

以下是一个示例代码，展示了如何实现以上步骤：

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, World!')

# 获取消息的回调函数
def callback(ch, method, properties, body):
    print("Received message:", body)

# 注册消费者，持续获取消息
channel.basic_consume(queue='my_queue', on_message_callback=callback, auto_ack=True)
channel.start_consuming()

在上述代码中，首先创建了 RabbitMQ 连接和 channel，然后声明了一个名为 `my_queue` 的队列。接着，通过调用 `basic_publish` 方法将一条消息发送到队列中。

最后，注册了一个名为 `callback` 的回调函数，它会在收到消息时被调用。通过调用 `basic_consume` 方法注册了一个消费者，它会不断地获取队列中的消息，并在收到消息时调用 `callback` 函数。

这样，我们就可以持续获取 RabbitMQ 中的消息了。