rabbitmq监听事件

RabbitMQ 提供了一些插件可以监听消息队列的事件。其中最常用的是 `rabbitmq_event_exchange` 插件，它可以监听交换器的事件。下面是使用 Python pika 库来监听 RabbitMQ 交换器事件的示例代码：

import pika

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

# 定义交换器
channel.exchange_declare(exchange='test_exchange', exchange_type='fanout')

# 定义回调函数
def callback(ch, method, properties, body):
    print(f"Received message: {body.decode()}")

# 监听交换器事件
result = channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue

channel.queue_bind(
    exchange='test_exchange', queue=queue_name)

channel.basic_consume(
    queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()

上述代码中，我们定义了一个名为 `test_exchange` 的 fanout 类型的交换器，并创建了一个匿名的队列来绑定到交换器上。然后，我们设置了一个回调函数来处理接收到的消息。最后，我们使用 `basic_consume()` 方法来开始消费消息。当有消息到达交换器时，会触发 `callback()` 函数，并打印出消息内容。

当我们运行上述代码后，它会一直监听 RabbitMQ 服务器上的 `test_exchange` 交换器，并在有消息到达时打印出消息内容。