RabbitMQ相同事件的多个监听者

在RabbitMQ中，可以使用多个消费者（监听者）来处理相同的事件。下面是一个使用Java语言的代码示例：

import com.rabbitmq.client.*;

import java.io.IOException;

public class Consumer {
    private static final String QUEUE_NAME = "event_queue";

    public static void main(String[] args) throws Exception {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");

        // 创建连接
        Connection connection = factory.newConnection();

        // 创建通道
        Channel channel = connection.createChannel();

        // 声明队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        // 创建多个消费者，并设置消息处理逻辑
        for (int i = 0; i < 3; i++) {
            Consumer consumer = new EventConsumer(channel, "Consumer " + i);
            channel.basicConsume(QUEUE_NAME, true, consumer);
        }
    }

    private static class EventConsumer extends DefaultConsumer {
        private final String consumerName;

        public EventConsumer(Channel channel, String consumerName) {
            super(channel);
            this.consumerName = consumerName;
        }

        @Override
        public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
            String message = new String(body, "UTF-8");
            System.out.println(consumerName + " Received: " + message);
        }
    }
}

上述代码中，首先创建了一个连接工厂和连接，然后创建了一个通道和一个队列。接下来，在一个循环中创建了三个消费者，并将它们绑定到相同的队列上。每个消费者都是一个EventConsumer类的实例，继承自DefaultConsumer类，重写了handleDelivery方法用于处理消息。在handleDelivery方法中，可以根据需要编写消息的处理逻辑。

这样，当有消息发送到队列时，多个消费者将同时监听并处理这些消息。