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

要在RabbitMQ中创建消息和获取消息，需要使用RabbitMQ的客户端库（如pika、amqp、stomp等）来编写程序。以下是Python中使用pika库创建和获取消息的示例代码：

创建消息：

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 World!')
print(" [x] Sent 'Hello World!'")

# 关闭连接
connection.close()

获取消息：

import pika

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

# 声明队列
channel.queue_declare(queue='hello')

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

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

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

这段代码定义了一个回调函数`callback`，当程序从队列中获取到消息时，就会调用这个函数来处理消息。在`basic_consume`方法中指定了队列名称和回调函数，然后调用`start_consuming`方法开始接收消息。当程序接收到消息时，就会调用`callback`函数来处理消息。

这是一个简单的示例，如果需要在实际应用中使用RabbitMQ，还需要考虑很多其他因素，例如消息持久化、消息确认、队列和交换机的配置等。