rabittmq 監聽消息

要使用 RabbitMQ 监听消息，你需要先安装 RabbitMQ，并在你的应用程序中使用 RabbitMQ 客户端库。以下是一个简单的例子，演示如何使用 RabbitMQ 客户端库在 Python 中监听消息：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print("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()

这个例子中，我们使用 `channel.queue_declare()` 声明了一个名为 `hello` 的队列，并定义了一个回调函数 `callback`，在该函数中处理接收到的消息。然后使用 `channel.basic_consume()` 开始监听队列中的消息，当有消息到达时，就会调用回调函数 `callback` 进行处理。最后使用 `channel.start_consuming()` 开始监听消息，直到手动停止或程序异常退出。