RabbitMQ中动态创建队列和监听 Java代码实现

RabbitMQ是一个开源的消息代理，它允许你通过发布/订阅模型来处理消息传递。动态创建队列和监听是RabbitMQ的一种高级功能，通常用于处理异步任务和事件驱动的应用场景。

在Java中，我们可以使用`AMQP`客户端库（如`Spring AMQP`、`Pika`或`Hammock`）来动态创建队列并监听。以下是一个简单的示例，展示了如何使用`Spring AMQP`：

import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.listener.ChannelAwareMessageListener;

public class DynamicQueueExample {

    private final ConnectionFactory connectionFactory;

    public DynamicQueueExample(ConnectionFactory connectionFactory) {
        this.connectionFactory = connectionFactory;
    }

    // 创建并绑定动态队列
    public void createAndBind(String queueName) {
        try (Connection connection = connectionFactory.newConnection();
             Channel channel = connection.createChannel()) {

            // 使用交换机创建并绑定队列
            String exchangeName = "myExchange";
            channel.queueDeclare(queueName, false, false, true, null);
            channel.queueBind(queueName, exchangeName, routingKey(queueName));
            
        } catch (Exception e) {
            // 处理异常
            e.printStackTrace();
        }
    }

    // 使用消费者监听队列
    public void startListening(ChannelAwareMessageListener listener) {
        try (Connection connection = connectionFactory.newConnection()) {
            // 创建消费者并监听指定队列
            Channel channel = connection.createChannel();
            channel.basicConsume(queueName, true, listener, consumerTag -> {});
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 动态生成路由键（queueName）
    private String routingKey(String queueName) {
        return "#" + queueName;
    }
}

// 实现ChannelAwareMessageListener
public class MyMessageHandler implements ChannelAwareMessageListener {
    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        // 处理接收到的消息
        String body = new String(message.getBody());
        System.out.println("Received message: " + body);
    }
}

在这个例子中，我们首先创建了一个连接工厂，然后创建并绑定动态队列。当需要消费队列中的消息时，我们创建一个监听器，并启动监听。`MyMessageHandler`实现了`ChannelAwareMessageListener`，以便在接收到消息时可以处理它们。